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);