去除限流

src/main/java/cn/van/business/mq/MessageConsumerService.java

@@ -30,9 +30,9 @@ import static cn.van.business.util.WXUtil.WX_BASE_URL;
 public class MessageConsumerService implements RocketMQListener<JSONObject> {
 
     private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class);
-    private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS
-            1, // 预热期 5 秒
-            TimeUnit.SECONDS);
+    //private static final RateLimiter rateLimiter = RateLimiter.create(4, // 1 QPS
+    //        1, // 预热期 5 秒
+    //        TimeUnit.SECONDS);
 
     private final WxtsUtil wxtsUtil;
 
@@ -47,7 +47,7 @@ public class MessageConsumerService implements RocketMQListener<JSONObject> {
         try {
             logger.info("消费消息：{}", message);
             //logger.info("[RateLimiter] 开始处理消息，当前时间：{}", System.currentTimeMillis());
-            rateLimiter.acquire();
+            //rateLimiter.acquire();
             //logger.info("[RateLimiter] 获得令牌，当前时间：{}", System.currentTimeMillis());
 
 

src/main/java/cn/van/business/util/JDUtil.java

@@ -1279,7 +1279,7 @@ public class JDUtil {
                         //textList.add("闲鱼方案的文案：\n");
                         textList.add(String.valueOf(sb1));
                         StringBuilder sb2 = new StringBuilder();
-                        sb2.append("(帮你买) ").append(replaceAll).append("\n").append(WENAN_ZCXS);
+                        sb2.append("(一键代下) ").append(replaceAll).append("\n").append(WENAN_ZCXS);
                         //textList.add("闲鱼正常销售：\n");
                         textList.add(String.valueOf(sb2));
                         StringBuilder sb3 = new StringBuilder();