修正redis 最大连接数

device-manager/src/main/java/com/mortals/xhx/busiz/web/TestSendMsgController.java

@@ -5,6 +5,7 @@ import cn.hutool.core.util.StrUtil;
 import cn.hutool.http.HttpUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.mortals.framework.common.Rest;
 import com.mortals.framework.service.ICacheService;
 import com.mortals.framework.service.ILogService;
 import com.mortals.framework.service.impl.FileLogServiceImpl;
@@ -65,17 +66,14 @@ public class TestSendMsgController {
     }
 
     @GetMapping("updateDevice")
-    public String updateDevice() {
-        log.info("刷新设备的产品编码");
-        ApiResp<DeviceResp> rsp = new ApiResp<>();
-        rsp.setCode(ApiRespCodeEnum.SUCCESS.getValue());
+    public Rest<Void> updateDevice() {
         List<DeviceEntity> updateProductCodeList = deviceService.find(new DeviceQuery());
 
         for (DeviceEntity deviceEntity : updateProductCodeList) {
             deviceService.update(deviceEntity);
         }
 
-        return JSON.toJSONString(rsp);
+        return Rest.ok();
     }
 
 

device-manager/src/main/java/com/mortals/xhx/common/key/Constant.java

@@ -45,6 +45,7 @@ public final class Constant {
     public static final String DES_STR = "FZV1D&tr";
 
     public static final Integer SERVER_PORT = 28074;
+    public static  Integer SEND_INTEVEL = 1000;
     public static final Integer CLIENT_PORT = 28073;
     /**
      * 设备心跳检查时间（秒）

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceSendThirdPartyService.java

@@ -16,6 +16,7 @@ import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
 
 import static com.mortals.xhx.common.key.Constant.PARAM_SERVER_PHP_IN_HTTP_URL;
+import static com.mortals.xhx.common.key.Constant.SEND_INTEVEL;
 import static com.mortals.xhx.common.key.RedisKey.KEY_DEVICE_THIRDPARTY_QUEUE;
 
 @Component
@@ -41,7 +42,7 @@ public class DeviceSendThirdPartyService implements IApplicationStartedService {
         log.info("初始化发送线程数量");
         //启动短信发送响应更新线程
         sendTaskThreadPool.execute(() -> {
-            int waitTime = 1000;
+            int waitTime = SEND_INTEVEL;
             while (!stopped) {
                 try {
                     DeviceReq deviceReq = cacheService.lpop(KEY_DEVICE_THIRDPARTY_QUEUE, DeviceReq.class);
@@ -51,10 +52,10 @@ public class DeviceSendThirdPartyService implements IApplicationStartedService {
                         log.info("sendThirty resp ==>{}", JSON.toJSONString(resp));
                     }
 
-                    try {
-                        Thread.sleep(waitTime);
-                    } catch (InterruptedException e2) {
-                    }
+//                    try {
+//                        Thread.sleep(waitTime);
+//                    } catch (InterruptedException e2) {
+//                    }
 
                 } catch (Exception e) {
                     log.error("异常", e);