Merge pull request #34 from qq254963746/develop

Develop

Author: qq254963746

README.md

@@ -11,7 +11,7 @@ LTS 轻量级分布式任务调度框架(Light Task Schedule)
 框架支持实时任务，也支持定时任务，同时也支持CronExpression, 有问题，请加QQ群：109500214 一起完善，探讨
 
 ##架构图
-![Aaron Swartz](https://raw.githubusercontent.com/qq254963746/light-task-schedule/master/doc/%E6%9E%B6%E6%9E%84%E5%9B%BE.png)
+![Aaron Swartz](https://raw.githubusercontent.com/qq254963746/light-task-schedule/master/doc/LTS_architecture.png)
 ##节点组:
 * 1. 一个节点组等同于一个集群，同一个节点组中的各个节点是对等的，外界无论连接节点组中的任务一个节点都是可以的。
 * 2. 每个节点组中都有一个master节点(master宕机，会自动选举出新的master节点)，框架会提供接口API来监听master节点的变化，用户可以自己使用master节点做自己想做的事情。

doc/LTS_architecture.png

@@ -6,7 +6,7 @@
 import com.lts.job.remoting.exception.RemotingCommandException;
 import com.lts.job.remoting.protocol.RemotingCommand;
 import com.lts.job.tracker.domain.JobTrackerApplication;
-import com.lts.job.tracker.support.JobDistributor;
+import com.lts.job.tracker.support.JobPusher;
 import io.netty.channel.ChannelHandlerContext;
 
 /**
@@ -15,20 +15,20 @@
  */
 public class JobPullProcessor extends AbstractProcessor {
 
-    private JobDistributor jobDistributor;
+    private JobPusher jobPusher;
 
     public JobPullProcessor(RemotingServerDelegate remotingServer, JobTrackerApplication application) {
         super(remotingServer, application);
 
-        jobDistributor = new JobDistributor(application);
+        jobPusher = new JobPusher(application);
     }
 
     @Override
     public RemotingCommand processRequest(final ChannelHandlerContext ctx, final RemotingCommand request) throws RemotingCommandException {
 
         JobPullRequest requestBody = request.getBody();
 
-        jobDistributor.distribute(remotingServer, requestBody);
+        jobPusher.push(remotingServer, requestBody);
 
         return RemotingCommand.createResponseCommand(JobProtos.ResponseCode.JOB_PULL_SUCCESS.code(), "");
     }

doc/架构图.png

@@ -32,24 +32,24 @@
  * @author Robert HG (254963746@qq.com) on 8/18/14.
  *         任务分发管理
  */
-public class JobDistributor {
+public class JobPusher {
 
-    private final Logger LOGGER = LoggerFactory.getLogger(JobDistributor.class);
+    private final Logger LOGGER = LoggerFactory.getLogger(JobPusher.class);
     private JobTrackerApplication application;
     private final ExecutorService executor;
 
-    public JobDistributor(JobTrackerApplication application) {
+    public JobPusher(JobTrackerApplication application) {
         this.application = application;
         executor = Executors.newFixedThreadPool(Constants.AVAILABLE_PROCESSOR * 5
-                , new NamedThreadFactory(JobDistributor.class.getSimpleName()));
+                , new NamedThreadFactory(JobPusher.class.getSimpleName()));
     }
 
-    public void distribute(final RemotingServerDelegate remotingServer, final JobPullRequest request) {
+    public void push(final RemotingServerDelegate remotingServer, final JobPullRequest request) {
         executor.submit(new Runnable() {
             @Override
             public void run() {
                 try {
-                    _sendJob(remotingServer, request);
+                    pushJob(remotingServer, request);
                 } catch (Exception e) {
                     LOGGER.error(e.getMessage(), e);
                 }
@@ -64,7 +64,7 @@ public void run() {
      * @param remotingServer
      * @param request
      */
-    private void _sendJob(RemotingServerDelegate remotingServer, JobPullRequest request) {
+    private void pushJob(RemotingServerDelegate remotingServer, JobPullRequest request) {
 
         String nodeGroup = request.getNodeGroup();
         String identity = request.getIdentity();