土工平台修改

src/main/java/com/patzn/cloud/service/lims/rcp/InitBalanceMap.java

@@ -4,9 +4,6 @@ import net.jodah.expiringmap.ExpirationPolicy;
 import net.jodah.expiringmap.ExpiringMap;
 import org.springframework.beans.factory.InitializingBean;
 import org.springframework.stereotype.Component;
-
-import java.sql.Connection;
-import java.util.List;
 import java.util.concurrent.TimeUnit;
 @Component
 public class InitBalanceMap implements InitializingBean {

src/main/java/com/patzn/cloud/service/lims/rcp/Runner.java

 package com.patzn.cloud.service.lims.rcp;
-
-import com.patzn.cloud.service.lims.socket.ServerConfig;
 import com.patzn.cloud.service.lims.socket.SocketProperties;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.InitializingBean;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.boot.CommandLineRunner;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Component;
 
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.util.concurrent.ArrayBlockingQueue;
-import java.util.concurrent.ThreadPoolExecutor;
-import java.util.concurrent.TimeUnit;
+import java.util.concurrent.ExecutorService;
 
 @Component
-public class Runner implements CommandLineRunner {
-
+public class Runner implements InitializingBean {
+    private static final Logger logger = LoggerFactory.getLogger(Runner.class);
     @Autowired
     private SocketProperties properties;
+    @Autowired
+    @Qualifier(value = "crawlExecutorPool")
+    private ExecutorService pool;
 
     @Override
-    public void run(String... args) throws Exception {
-        System.out.println("设备服务器已经开启, 监听端口:" + properties.getPort());
-        new NettyServer().bind(6800);
-//        ThreadPoolExecutor pool = new ThreadPoolExecutor(
-//                properties.getPoolCore(),
-//                properties.getPoolMax(),
-//                properties.getPoolKeep(),
-//                TimeUnit.SECONDS,
-//                new ArrayBlockingQueue<>(properties.getPoolQueueInit()),
-//                new ThreadPoolExecutor.DiscardOldestPolicy()
-//        );
-
+    public void afterPropertiesSet()  {
+        pool.execute(() -> {
+            try {
+                try {
+                    System.out.println("设备服务器已经开启, 监听端口:6800");
+                    new NettyServer().bind(6800);
+                    logger.error("SOCKET 端口 启动Success");
+                }catch (Exception e){
+                    logger.error("SOCKET 端口 启动失败"+e.getMessage());
+                }
+            } catch (Exception e) {
+                e.printStackTrace();
+            }
+            System.out.println(Thread.currentThread().getName() + "======定时任务执行完成======");
+        });
 
     }
 }

src/main/java/com/patzn/cloud/service/lims/rcp/ServerHandler.java

@@ -32,6 +32,8 @@ public class ServerHandler extends ChannelInboundHandlerAdapter {
 
         System.out.println();
 
+        logger.error("目前天平库的信息为："+mapValue.toString());
+
         System.out.println("接收到客户端信息:" + request.toString());
         //返回的数据结构
         RpcResponse response = new RpcResponse();

src/main/java/com/patzn/cloud/service/lims/rcp/ThreadPush.java

+package com.patzn.cloud.service.lims.rcp;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+
+@Component
+@Configuration
+public class ThreadPush {
+
+    @Bean(name = "crawlExecutorPool")
+    public ExecutorService crawlExecutorPool() {
+        // 获取Java虚拟机的可用的处理器数，最佳线程个数，处理器数*2。根据实际情况调整
+        int curSystemThreads = Runtime.getRuntime().availableProcessors() * 2;
+        System.out.println("------------系统可用线程池个数：" + curSystemThreads);
+        // 创建线程池
+        ExecutorService pool = Executors.newFixedThreadPool(curSystemThreads);
+        return pool;
+    }
+}