add

mqtt信息发送

nb-service/iot-service/src/main/java/com/nb/aliyun/service/consumer/NBAndFourGConsumerGroupService.java

@@ -166,7 +166,7 @@ public class NBAndFourGConsumerGroupService extends AbstractAliConsumer {
             int queueSize = threadPoolExecutor.getQueue().size();
             
             // 实现过载保护机制：当队列中待处理的任务数量超过阈值时，将消息重新返回队列
-            if (queueSize > 50) {
+            if (queueSize > 200) {
                 log.warn("消息队列已满，当前待处理任务数量: {}，将消息重新返回队列", queueSize);
                 // 不进行acknowledge操作，让消息重新入队
                 return;