From 10f3396b8cedbdf2a64071a54f3a900532609f59 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=B7=E6=AC=A7=EF=BC=88=E6=9E=97=E5=B9=B3=E5=87=A1?= =?UTF-8?q?=EF=BC=89?= Date: Wed, 22 Jan 2025 13:41:52 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=81=E4=B8=9A=E5=BE=AE=E4=BF=A1=E6=8E=A8?= =?UTF-8?q?=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/van/business/mq/MessageConsumerService.java | 8 ++++++-- src/main/java/cn/van/business/util/WXUtil.java | 12 +++--------- 2 files changed, 9 insertions(+), 11 deletions(-) diff --git a/src/main/java/cn/van/business/mq/MessageConsumerService.java b/src/main/java/cn/van/business/mq/MessageConsumerService.java index 898f6e6..2daec83 100644 --- a/src/main/java/cn/van/business/mq/MessageConsumerService.java +++ b/src/main/java/cn/van/business/mq/MessageConsumerService.java @@ -31,11 +31,15 @@ public class MessageConsumerService implements RocketMQListener { private static final Logger logger = LoggerFactory.getLogger(MessageConsumerService.class); - @Autowired - private WxtsUtil wxtsUtil; + private final WxtsUtil wxtsUtil; // create a rate limiter of 1 qps RateLimiter rateLimiter = RateLimiter.create(0.5); + @Autowired + public MessageConsumerService(WxtsUtil wxtsUtil) { + this.wxtsUtil = wxtsUtil; + } + @Override public void onMessage(JSONObject jsonObject) { // 处理消息 diff --git a/src/main/java/cn/van/business/util/WXUtil.java b/src/main/java/cn/van/business/util/WXUtil.java index 2385b91..4f0c35b 100644 --- a/src/main/java/cn/van/business/util/WXUtil.java +++ b/src/main/java/cn/van/business/util/WXUtil.java @@ -50,14 +50,6 @@ public class WXUtil { private String secretKey; } - // 通过构造函数注入所有依赖项，Spring将自动注入这些依赖 - @Autowired // @Autowired 在构造函数上可以省略，如果类只有一个构造函数 - public WXUtil(WxtsUtil wxTsUtil, MessageProducerService messageProducerService) { - this.messageProducerService = messageProducerService; - this.wxTsUtil = wxTsUtil; - } - - // 初始化超级管理员 public void initSuperAdmins() { SuperAdmin admin1 = new SuperAdmin("wxid_ytpc72mdoskt22", "凡", "2014264913", "98e21c89ae5610240ec3f5f575f86a59", "3dcb6b23a1104639ac433fd07adb6dfb"); @@ -112,7 +104,9 @@ public class WXUtil { @Autowired - public WXUtil(Environment env) { + public WXUtil(Environment env, WxtsUtil wxTsUtil, MessageProducerService messageProducerService) { + this.messageProducerService = messageProducerService; + this.wxTsUtil = wxTsUtil; this.env = env; WX_BASE_URL = env.getProperty("config.WX_BASE_URL"); System.out.println("WX_BASE_URL:" + WX_BASE_URL);