#

Junjie

2025-05-08 a9a915e7042ab588dfeb0f8ac290fc8ce26a0f29

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

@@ -1118,6 +1118,7 @@

    //发出请求
    private JSONObject requestCommand(NyShuttleHttpCommand httpCommand) throws IOException {
        try {
        if (this.socket == null) {
            return null;
        }
@@ -1158,6 +1159,10 @@
            }
        }
        return result;//返回Body结果集
        }catch (Exception e) {
            e.printStackTrace();
        }
        return null;
    }

    private void requestCommandAsync(NyShuttleHttpCommand httpCommand) throws IOException {
@@ -1165,6 +1170,7 @@
            return;
        }

       try {
        //压缩数据包
        JSONObject data = JSON.parseObject(JSON.toJSONString(httpCommand));
        data.remove("nodes");
@@ -1174,6 +1180,9 @@
        writer.write(JSON.toJSONString(data) + "\r\n");
        writer.flush();
//            System.out.println("Sent message to server: " + JSON.toJSONString(httpCommand));
       }catch (Exception e) {
           e.printStackTrace();
       }
    }

    private JSONObject filterBodyData(JSONObject data) {