From ab7a74dfb4d0748175a1f8fcaf9d1a20b3919d2a Mon Sep 17 00:00:00 2001 From: 野心家 <1051256694@qq.com> Date: 星期二, 20 六月 2023 16:42:02 +0800 Subject: [PATCH] 孚能 --- src/main/java/com/zy/core/ServerBootstrap.java | 22 +++++++++++----------- 1 files changed, 11 insertions(+), 11 deletions(-) diff --git a/src/main/java/com/zy/core/ServerBootstrap.java b/src/main/java/com/zy/core/ServerBootstrap.java index 76c63e0..dddcf0c 100644 --- a/src/main/java/com/zy/core/ServerBootstrap.java +++ b/src/main/java/com/zy/core/ServerBootstrap.java @@ -74,10 +74,10 @@ for (Slave car : slaveProperties.getCar()) { MessageQueue.init(SlaveType.Car, car); } - // 鍒濆鍖杝ocket mq - for (Slave socket : slaveProperties.getSocket()) { - MessageQueue.init(SlaveType.Socket, socket); - } +// // 鍒濆鍖杝ocket mq +// for (Slave socket : slaveProperties.getSocket()) { +// MessageQueue.init(SlaveType.Socket, socket); +// } } private void initThread(){ @@ -103,13 +103,13 @@ SlaveConnection.put(SlaveType.Barcode, barcode.getId(), barcodeThread); } - // 鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼ - log.info("鍒濆鍖朣ocket绾跨▼..................................................."); - for (SocketSlave socket : slaveProperties.getSocket()) { - SocketThread socketThread = new SocketThread(socket); - new Thread(socketThread).start(); - SlaveConnection.put(SlaveType.Socket, socket.getId(), socketThread); - } +// // 鍒濆鍖栨潯鐮佹壂鎻忎华绾跨▼ +// log.info("鍒濆鍖朣ocket绾跨▼..................................................."); +// for (SocketSlave socket : slaveProperties.getSocket()) { +// SocketThread socketThread = new SocketThread(socket); +// new Thread(socketThread).start(); +// SlaveConnection.put(SlaveType.Socket, socket.getId(), socketThread); +// } // // 鍒濆鍖朙ED绾跨▼ // log.info("鍒濆鍖朙ED绾跨▼..................................................."); // for (LedSlave led : slaveProperties.getLed()) { -- Gitblit v1.9.1