#

Junjie

2023-09-04 3f48e38eeaf31f85ec8b68489c8079800ca65e0f

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

@@ -87,7 +87,7 @@

    private void read() {
        try {
            if (!this.socket.isConnected()) {
            if (this.socket == null || !this.socket.isConnected()) {
                //链接断开重新链接
                this.connect();
            }
@@ -252,6 +252,7 @@
        try {
            Socket socket = new Socket(slave.getIp(),slave.getPort());
            socket.setSoTimeout(60000);
            socket.setKeepAlive(true);
            this.socket = socket;
        } catch (IOException e) {
            OutputQueue.SHUTTLE.offer(MessageFormat.format("【{0}】四向穿梭车Socket链接失败 ===>> [id:{1}] [ip:{2}] [port:{3}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort()));