#

qlsxk

2025-10-11 cfb5a68740880c52c9acada94f25a06614f2407a

#

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -82,6 +82,7 @@
    }

    private void initFakeThread(){
        if (enableFake) {
        ThreadHandler thread = new FakeNyShuttleThread(redisUtil, gatewayPort, enableFake, enableFakeDeviceThread);
        new Thread(thread).start();
        SlaveConnection.put(SlaveType.FakeThread, 1, thread);
@@ -94,6 +95,7 @@
        new Thread(thread3).start();
        SlaveConnection.put(SlaveType.FakeThread, 3, thread3);
    }
    }


    @PreDestroy

 src/main/java/com/zy/core/thread/impl/NyShuttleThread.java

@@ -64,6 +64,7 @@
                    );
                    Thread.sleep(200);
                } catch (Exception e) {
                    closeSocket();
                    e.printStackTrace();
                }
            }
@@ -301,6 +302,8 @@
                return false;
            }

            this.lastConnectTime = System.currentTimeMillis();

            if(this.deviceConfig.getFake()) {
                return fakeConnect();
            }else {
@@ -310,7 +313,6 @@
                    deviceSocket.setSoTimeout(10000);
                    deviceSocket.setKeepAlive(true);
                    this.socket = deviceSocket;
                    this.lastConnectTime = System.currentTimeMillis();
                    log.info(MessageFormat.format("【{0}】四向穿梭车Socket链接成功 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), deviceConfig.getDeviceNo(), deviceConfig.getIp(), deviceConfig.getPort()));
                }
            }

 src/main/resources/application.yml

@@ -30,6 +30,6 @@
  # 网关端口
  gatewayPort: 8888
  # 启动模拟器
  enableFake: true
  enableFake: false
  # 启动模拟器设备线程
  enableFakeDeviceThread: true