#

Junjie

2025-03-29 b91acaec84806fa7215ada0e55f999bf33def586

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

@@ -78,6 +78,7 @@
            while (true) {
                try {
                    listenSocketMessage();
                    listenInit();//监听初始化事件
                } catch (Exception e) {
                    e.printStackTrace();
                }
@@ -136,7 +137,6 @@
        Thread otherThread = new Thread(() -> {
            while (true) {
                try {
                    listenInit();//监听初始化事件
                    saveLog();//保存数据
                } catch (Exception e) {
                    e.printStackTrace();
@@ -195,15 +195,22 @@
            }

            JSONObject result = JSON.parseObject(sb.toString());//得到响应结果集
            if (result.containsKey("workingMode")) {
                //read
                socketReadResults.add(result);
            }else {
                if (!socketResults.isEmpty() && socketResults.size() >= 20) {
                    socketResults.remove(0);//清理头节点

            String msgType = result.getString("msgType");
            if ("responseMsg".equals(msgType)) {
                JSONObject response = result.getJSONObject("response");
                JSONObject body = response.getJSONObject("body");
                if (body.containsKey("workingMode")) {
                    //read
                    socketReadResults.add(body);
                    return;
                }
                socketResults.add(result);//添加数据
            }

            if (!socketResults.isEmpty() && socketResults.size() >= 20) {
                socketResults.remove(0);//清理头节点
            }
            socketResults.add(result);//添加数据
        } catch (Exception e) {
//            e.printStackTrace();
        }
@@ -738,8 +745,8 @@

        InnerSuhttleExtend extend = (InnerSuhttleExtend) this.shuttleProtocol.getExtend();
        boolean res = this.shuttleProtocol.getMode() == 0
                && !this.shuttleProtocol.getErrorCode().equals("0")
                && extend.getSuspendState() == 1
                || !this.shuttleProtocol.getErrorCode().equals("0")
                || extend.getSuspendState() == 1
                ;
        return res;
    }