修改host模块消息重试队列订阅数量redis有效时间

soc-modules/soc-modules-host/src/main/java/com/xunmei/host/websocket/redis/WebsocketPublisher.java

@@ -45,7 +45,8 @@ public class WebsocketPublisher {
         //此处记录订阅数量与发送失败数量,是因为在重试时需要所有的监听都发送失败了 才能认为这次消息重试发送失败
         if (message.getContent() instanceof IotWebsocketMsg) {
             IotWebsocketMsg iotWebsocketMsg = (IotWebsocketMsg) message.getContent();
-            RedisUtils.setCacheObject(RedisConstant.TOPIC_SUBSCRIBERS_NUMS + iotWebsocketMsg.getId(), new SubscribersAndFailNums(subscribers, 0),1000 * 60 * 60 * 24);
+            RedisUtils.setCacheObject(RedisConstant.TOPIC_SUBSCRIBERS_NUMS + iotWebsocketMsg.getId(),
+                    new SubscribersAndFailNums(subscribers, 0),1000 * 60 * 60);
         }
     }
 }

soc-modules/soc-modules-host/src/main/java/com/xunmei/host/websocket/redis/vo/SubscribersAndFailNums.java

@@ -34,7 +34,7 @@ public class SubscribersAndFailNums {
             if (tryLock) {
                 final SubscribersAndFailNums failNums = RedisUtils.getCacheObject(RedisConstant.TOPIC_SUBSCRIBERS_NUMS + msgId);
                 failNums.setFailNums(failNums.getFailNums() + 1);
-                RedisUtils.setCacheObject(RedisConstant.TOPIC_SUBSCRIBERS_NUMS + msgId, failNums, 1000 * 60 * 60 * 24);
+                RedisUtils.setCacheObject(RedisConstant.TOPIC_SUBSCRIBERS_NUMS + msgId, failNums, 1000 * 60 * 60);
                 return failNums;
             }
         } catch (InterruptedException e) {