1. 优化心跳机制；采用pub/sub解耦部分业务;2. 完成 任务队列和任务节点 在ltsAdmin Web 控制台的展示 后面开发计划：节点的动态上线下，任务队列任务的编辑修改，任务日志的查询 等等

胡贵 · 胡贵 · commit 8a61816c5deb · 2015-06-07T22:13:04.000+08:00
diff --git a/lts-admin/src/main/java/com/lts/job/web/controller/api/JobQueueApiController.java b/lts-admin/src/main/java/com/lts/job/web/controller/api/JobQueueApiController.java
@@ -14,7 +14,7 @@
 import java.util.List;
 
 /**
- * Created by hugui on 6/6/15.
+ * @author Robert HG (254963746@qq.com) on 6/6/15.
  */
 @RestController
 public class JobQueueApiController extends AbstractController {
diff --git a/lts-admin/src/main/java/com/lts/job/web/support/AdminAppFactoryBean.java b/lts-admin/src/main/java/com/lts/job/web/support/AdminAppFactoryBean.java
@@ -13,7 +13,7 @@
 import java.util.Map;
 
 /**
- * Created by hugui on 6/6/15.
+ * @author Robert HG (254963746@qq.com) on 6/6/15.
  */
 public class AdminAppFactoryBean implements FactoryBean<AdminApplication>, InitializingBean {
 
diff --git a/lts-admin/src/main/java/com/lts/job/web/support/AjaxUtils.java b/lts-admin/src/main/java/com/lts/job/web/support/AjaxUtils.java
@@ -3,7 +3,7 @@
 import javax.servlet.http.HttpServletRequest;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class AjaxUtils {
 
diff --git a/lts-admin/src/main/java/com/lts/job/web/support/AppConfig.java b/lts-admin/src/main/java/com/lts/job/web/support/AppConfig.java
@@ -5,7 +5,7 @@
 import org.springframework.context.annotation.Configuration;
 
 /**
- * Created by hugui on 6/6/15.
+ * @author Robert HG (254963746@qq.com) on 6/6/15.
  */
 @Configuration
 public class AppConfig {
diff --git a/lts-admin/src/main/java/com/lts/job/web/support/ExceptionHandlerResolver.java b/lts-admin/src/main/java/com/lts/job/web/support/ExceptionHandlerResolver.java
@@ -15,7 +15,7 @@
 import java.io.StringWriter;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 @Component
 public class ExceptionHandlerResolver implements HandlerExceptionResolver {
diff --git a/lts-core/src/main/java/com/lts/job/core/domain/JobQueueRequest.java b/lts-core/src/main/java/com/lts/job/core/domain/JobQueueRequest.java
@@ -4,7 +4,7 @@
 import java.util.Map;
 
 /**
- * Created by hugui on 6/6/15.
+ * @author Robert HG (254963746@qq.com) on 6/6/15.
  */
 public class JobQueueRequest extends PageRequest {
 
diff --git a/lts-core/src/main/java/com/lts/job/core/domain/PageResponse.java b/lts-core/src/main/java/com/lts/job/core/domain/PageResponse.java
@@ -3,7 +3,7 @@
 import java.util.List;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class PageResponse<T> {
 
diff --git a/lts-core/src/main/java/com/lts/job/core/util/CharacterUtils.java b/lts-core/src/main/java/com/lts/job/core/util/CharacterUtils.java
@@ -4,7 +4,7 @@
 import java.util.regex.Pattern;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class CharacterUtils {
 
diff --git a/lts-core/src/main/java/com/lts/job/store/jdbc/SqlBuilder.java b/lts-core/src/main/java/com/lts/job/store/jdbc/SqlBuilder.java
@@ -7,7 +7,7 @@
 import java.util.List;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class SqlBuilder {
 
diff --git a/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/JobQueue.java b/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/JobQueue.java
@@ -5,7 +5,7 @@
 import com.lts.job.queue.domain.JobPo;
 
 /**
- * Created by hugui on 6/6/15.
+ * @author Robert HG (254963746@qq.com) on 6/6/15.
  */
 public interface JobQueue {
 
diff --git a/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/NodeGroupStore.java b/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/NodeGroupStore.java
@@ -6,7 +6,7 @@
 import java.util.List;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public interface NodeGroupStore {
 
diff --git a/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/NodeGroupStoreFactory.java b/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/NodeGroupStoreFactory.java
@@ -5,7 +5,7 @@
 import com.lts.job.core.extension.SPI;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 @SPI("mysql")
 public interface NodeGroupStoreFactory {
diff --git a/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/domain/NodeGroupPo.java b/lts-queue/lts-queue-api/src/main/java/com/lts/job/queue/domain/NodeGroupPo.java
@@ -3,7 +3,7 @@
 import com.lts.job.core.cluster.NodeType;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class NodeGroupPo {
 
diff --git a/lts-queue/lts-queue-mongo/src/main/java/com/lts/job/queue/mongo/AbstractMongoJobQueue.java b/lts-queue/lts-queue-mongo/src/main/java/com/lts/job/queue/mongo/AbstractMongoJobQueue.java
@@ -11,7 +11,7 @@
 import java.util.List;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public abstract class AbstractMongoJobQueue extends MongoRepository implements JobQueue{
 
diff --git a/lts-queue/lts-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoNodeGroupStore.java b/lts-queue/lts-queue-mongo/src/main/java/com/lts/job/queue/mongo/MongoNodeGroupStore.java
@@ -0,0 +1,62 @@
+package com.lts.job.queue.mongo;
+
+import com.lts.job.core.cluster.Config;
+import com.lts.job.core.cluster.NodeType;
+import com.lts.job.core.util.CollectionUtils;
+import com.lts.job.core.util.DateUtils;
+import com.lts.job.core.util.JobQueueUtils;
+import com.lts.job.queue.NodeGroupStore;
+import com.lts.job.queue.domain.NodeGroupPo;
+import com.lts.job.store.mongo.MongoRepository;
+import com.mongodb.DBCollection;
+import com.mongodb.DBObject;
+import com.mongodb.DuplicateKeyException;
+import org.mongodb.morphia.query.Query;
+
+import java.util.List;
+
+/**
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
+ */
+public class MongoNodeGroupStore extends MongoRepository implements NodeGroupStore {
+
+    public MongoNodeGroupStore(Config config) {
+        super(config);
+        setTableName(JobQueueUtils.NODE_GROUP_STORE);
+
+        // create table
+        DBCollection dbCollection = template.getCollection();
+        List<DBObject> indexInfo = dbCollection.getIndexInfo();
+        // create index if not exist
+        if (CollectionUtils.isEmpty(indexInfo)) {
+            template.ensureIndex("idx_nodeType_name", "nodeType,name", true, true);
+        }
+    }
+
+    @Override
+    public void addNodeGroup(NodeType nodeType, String name) {
+        try {
+            NodeGroupPo nodeGroupPo = new NodeGroupPo();
+            nodeGroupPo.setNodeType(nodeType);
+            nodeGroupPo.setName(name);
+            nodeGroupPo.setGmtCreated(DateUtils.currentTimeMillis());
+            template.save(nodeGroupPo);
+        } catch (DuplicateKeyException e) {
+            // ignore
+        }
+    }
+
+    @Override
+    public void removeNodeGroup(NodeType nodeType, String name) {
+        Query<NodeGroupPo> query = template.createQuery(NodeGroupPo.class);
+        query.field("nodeType").equal(nodeType).field("name").equal(name);
+        template.delete(query);
+    }
+
+    @Override
+    public List<NodeGroupPo> getNodeGroup(NodeType nodeType) {
+        Query<NodeGroupPo> query = template.createQuery(NodeGroupPo.class);
+        query.field("nodeType").equal(nodeType);
+        return query.asList();
+    }
+}
diff --git a/lts-queue/lts-queue-mysql/src/main/java/com/lts/job/queue/mysql/MysqlNodeGroupStore.java b/lts-queue/lts-queue-mysql/src/main/java/com/lts/job/queue/mysql/MysqlNodeGroupStore.java
@@ -18,7 +18,7 @@
 import java.util.List;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class MysqlNodeGroupStore extends JdbcRepository implements NodeGroupStore {
 
diff --git a/lts-queue/lts-queue-mysql/src/main/java/com/lts/job/queue/mysql/MysqlNodeGroupStoreFactory.java b/lts-queue/lts-queue-mysql/src/main/java/com/lts/job/queue/mysql/MysqlNodeGroupStoreFactory.java
@@ -7,7 +7,7 @@
 import com.lts.job.store.jdbc.JdbcRepository;
 
 /**
- * Created by hugui on 6/7/15.
+ * @author Robert HG (254963746@qq.com) on 6/7/15.
  */
 public class MysqlNodeGroupStoreFactory implements NodeGroupStoreFactory {
 
