#

Junjie

2025-03-29 c967b16a28cb4a1b19fe82de7598c18233f06ac9

#

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

@@ -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(result);
                    return;
                }
                socketResults.add(result);//添加数据
            }

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