#输出socket下发日志

Junjie

2025-03-18 545a4359905f23dcddc00ced4de46513146e8019

#输出socket下发日志

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

@@ -203,7 +203,7 @@
        }
    }

    public JSONObject getRequestBody(String type) {
    public JSONObject getRequestBody(String type, String taskId) {
        try {
            // 获取服务器响应
            JSONObject result = null;
@@ -220,12 +220,17 @@
                JSONObject resultResponse = JSON.parseObject(socketResult.get("response").toString());
                JSONObject resultBody = JSON.parseObject(resultResponse.get("body").toString());
                String responseType = resultBody.get("responseType").toString();
                String responseTaskId = resultBody.get("taskId").toString();
                if (DEBUG) {
                    result = socketResult;
                    break;
                }

                if (!responseType.equals(type)) {
                    continue;//响应类型与请求类型不一致，不在调试模式下
                }

                if (!responseTaskId.equals(taskId)) {
                    continue;//响应ID与请求ID不一致，不在调试模式下
                }

@@ -1079,8 +1084,10 @@
//            System.out.println("Sent message to server: " + JSON.toJSONString(httpCommand));

        String requestType = null;
        String taskId = null;
        try {
            requestType = httpCommand.getRequest().getBody().get("requestType").toString();
            taskId = httpCommand.getRequest().getBody().get("taskId").toString();
        } catch (Exception e) {
            return null;
        }
@@ -1089,7 +1096,7 @@
        // 尝试100次
        JSONObject result = null;
        for (int i = 0; i < 100; i++) {
            result = getRequestBody(requestType);
            result = getRequestBody(requestType, taskId);
            if (result == null) {
                try {
                    Thread.sleep(100);