#

whycq

2025-05-28 78489da7e2185f53faaec9356fa1a8997cedab70

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

@@ -1,6 +1,7 @@
package com.zy.core.thread;

import com.core.common.Cools;
import com.zy.common.utils.News;
import com.zy.core.Slave;
import com.zy.core.ThreadHandler;
import lombok.Data;
@@ -55,6 +56,8 @@

    @Override
    public boolean connect() {
        String methodName = Thread.currentThread().getStackTrace()[1].getMethodName();

        try {
            close();  //1.主动释放连接 //2.某些服务器对指定ip有链路数限制
            socket = new Socket();
@@ -63,10 +66,10 @@
            socket.connect(socketAddress, 1000); //某些服务器ping延迟高时要增加,否则会报错connect timeout
            dataOutputStream = new DataOutputStream(socket.getOutputStream());
            dataInputStream = new DataInputStream(socket.getInputStream());
//            log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
//            News.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        } catch (Exception e) {
            socket = null;
            log.error("条码扫描仪连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
            News.error(methodName + ":条码扫描仪连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
            return false;
        }
        return true;
@@ -89,7 +92,7 @@
        }
        socket = null;
        } catch (IOException e) {
            log.error("SocketClient close Exception:" + e.getMessage());
            News.error("SocketClient close Exception:" + e.getMessage());
        }
    }