Junjie
2025-03-18 fabfa0238b52b508c7c64445f8817e27c25a6e62
src/main/java/com/zy/core/thread/impl/NyShuttleThread.java
@@ -458,13 +458,21 @@
            }
            for (NyShuttleHttpCommand requestCommand : commandList) {
                JSONObject result = requestCommand(requestCommand);
                if (result == null) {
                    return response;//请求失败
                while (true) {
                    int i = 0;
                    i++;
                    JSONObject result = requestCommand(requestCommand);
                    if (result == null) {
//                        return response;//请求失败
                        News.info("Socket命令下发失败,任务数据={},次数={}", JSON.toJSON(command), i);
                        continue;//请求失败尝试重新请求
                    }
                    this.shuttleProtocol.setSendTime(System.currentTimeMillis());//指令下发时间
                    response.setMessage(JSON.toJSONString(result));
                    response.setResult(true);
                    News.info("Socket命令下发成功,任务数据={},次数={},响应数据={}", JSON.toJSON(command), i, JSON.toJSONString(result));
                    break;
                }
                this.shuttleProtocol.setSendTime(System.currentTimeMillis());//指令下发时间
                response.setMessage(JSON.toJSONString(result));
                response.setResult(true);
            }
            return response;
        } catch (Exception e) {
@@ -1078,9 +1086,9 @@
        }
        // 获取服务器响应
        // 尝试10次
        // 尝试100次
        JSONObject result = null;
        for (int i = 0; i < 10; i++) {
        for (int i = 0; i < 100; i++) {
            result = getRequestBody(requestType);
            if (result == null) {
                try {