修正redis 最大连接数

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

 package com.mortals.xhx.daemon.applicationservice;
 
+import cn.hutool.core.net.url.UrlBuilder;
+import com.alibaba.fastjson.JSON;
+import com.mortals.framework.ap.GlobalSysInfo;
 import com.mortals.framework.service.ICacheService;
 import com.mortals.framework.springcloud.service.IApplicationStartedService;
 import com.mortals.xhx.base.system.message.MessageService;
+import com.mortals.xhx.busiz.rsp.ApiResp;
+import com.mortals.xhx.common.pdu.DeviceReq;
 import com.mortals.xhx.common.utils.SendTaskThreadPool;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 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
 @Slf4j
@@ -30,6 +40,39 @@ public class DeviceSendThirdPartyService implements IApplicationStartedService {
     @Override
     public void start() {
         log.info("初始化发送线程数量");
+
+        Thread sendThread = new Thread(new Runnable() {
+            @Override
+            public void run() {
+                int waitTime = SEND_INTEVEL;
+                while (!stopped) {
+                    try {
+                    DeviceReq deviceReq = cacheService.lpop(KEY_DEVICE_THIRDPARTY_QUEUE, DeviceReq.class);
+                    if (!ObjectUtils.isEmpty(deviceReq)) {
+                        String phpInUrl = GlobalSysInfo.getParamValue(PARAM_SERVER_PHP_IN_HTTP_URL, "http://172.15.28.116:8090");
+                        ApiResp<String> resp = messageService.sendThirdParty(UrlBuilder.of(phpInUrl).addPath(thirdPartyPath).build(), deviceReq);
+                        log.info("sendThirty resp ==>{}", JSON.toJSONString(resp));
+                    }
+
+//                    try {
+//                        Thread.sleep(waitTime);
+//                    } catch (InterruptedException e2) {
+//                    }
+
+                    } catch (Exception e) {
+                        log.error("异常", e);
+
+                        try {
+                            Thread.sleep(waitTime);
+                        } catch (InterruptedException e2) {
+                        }
+                    }
+                }
+            }
+        });
+
+        sendThread.start();
+
         //启动短信发送响应更新线程
      /*   sendTaskThreadPool.execute(() -> {
             int waitTime = SEND_INTEVEL;