fix bug

Author: qq254963746

job-core/src/main/java/com/lts/job/core/cluster/MasterElector.java

@@ -51,7 +51,7 @@ public void addNodes(List<Node> nodes) {
                 }
             }
         }
-        if (master != newMaster) {
+        if (master == null || !master.equals(newMaster)) {
             master = newMaster;
             notifyListener();
         }

job-core/src/main/java/com/lts/job/remoting/netty/NettyServerConfig.java

@@ -1,13 +1,15 @@
 package com.lts.job.remoting.netty;
 
+import com.lts.job.core.constant.Constants;
+
 /**
  * Netty服务端配置
  */
 public class NettyServerConfig {
     private int listenPort = 8888;
     private int serverWorkerThreads = 32;
     private int serverCallbackExecutorThreads = 0;
-    private int serverSelectorThreads = 8;
+    private int serverSelectorThreads = Constants.AVAILABLE_PROCESSOR * 2;
     private int serverOnewaySemaphoreValue = 32;
     private int serverAsyncSemaphoreValue = 64;
     private int serverChannelMaxIdleTimeSeconds = 120;

job-core/src/main/java/com/lts/job/remoting/protocol/RemotingCommand.java

@@ -39,7 +39,7 @@ public class RemotingCommand {
     private static final Logger LOGGER = LoggerFactory.getLogger(RemotingCommand.class);
 
     private static final int RPC_TYPE = 0; // 0, REQUEST_COMMAND
-    private static final int RPC_ONEWAY = 1; // 0, RPC
+    private static final int RPC_ONEWAY = 1; // 1, RPC
     // 1, Oneway
     private static AtomicInteger RequestId = new AtomicInteger(0);
     /**