| | |
| | | } |
| | | |
| | | 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) { |
| | |
| | | } |
| | | |
| | | // 获取服务器响应 |
| | | // 尝试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 { |