CC/Jarvis_java
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
cc
2024-12-01 02:43:21 +08:00
parent 8011eaf9fd
commit 9cfbf2ae2d
3 changed files with 13 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/cn/van/business/mq/MessageProducerService.java
View File

@@ -1,5 +1,6 @@
package cn.van.business.mq; package cn.van.business.mq;
import com.alibaba.fastjson2.JSONObject;
import org.apache.rocketmq.spring.core.RocketMQTemplate; import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import org.springframework.stereotype.Service;
@@ -16,7 +17,10 @@ public class MessageProducerService {
@Autowired @Autowired
private RocketMQTemplate rocketMQTemplate; private RocketMQTemplate rocketMQTemplate;
public void sendMessage(String topic, String message) { private static final String topic = "wx-message";
this.rocketMQTemplate.convertAndSend(topic, message);
public void sendMessage(JSONObject jsonObject) {
this.rocketMQTemplate.convertAndSend(topic, jsonObject.toJSONString());
} }
} }

13
src/main/java/cn/van/business/util/WXUtil.java
View File

@@ -3,6 +3,7 @@ package cn.van.business.util;
import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.ObjectUtil;
import cn.hutool.http.HttpRequest; import cn.hutool.http.HttpRequest;
import cn.van.business.enums.WXReqType; import cn.van.business.enums.WXReqType;
import cn.van.business.mq.MessageProducerService;
import com.alibaba.fastjson2.JSON; import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject; import com.alibaba.fastjson2.JSONObject;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
@@ -63,7 +64,8 @@ public class WXUtil {
public static String WX_BASE_URL; public static String WX_BASE_URL;
private Environment env; private Environment env;
@Autowired @Autowired
private RocketMQTemplate rocketMQTemplate; private MessageProducerService messageProducerService;
@Autowired @Autowired
public WXUtil(Environment env) { public WXUtil(Environment env) {
this.env = env; this.env = env;
@@ -140,14 +142,7 @@ public class WXUtil {
//wxReqDate.setData(jsonObject); //wxReqDate.setData(jsonObject);
if (Util.isNotEmpty(wxid)) { if (Util.isNotEmpty(wxid)) {
// 把消息发送到RocketMQ，使用'wx-message'作为topic，jsonObject作为消息内容。 // 把消息发送到RocketMQ，使用'wx-message'作为topic，jsonObject作为消息内容。
rocketMQTemplate.convertAndSend("wx-message", jsonObject); messageProducerService.sendMessage(jsonObject);
String responseStr = HttpRequest.post(WX_BASE_URL)
.body(JSON.toJSONString(jsonObject)).execute().body();
if (ObjectUtil.isNotEmpty(responseStr)) {
JSONObject response = JSON.parseObject(responseStr);
logger.info("消息响应：{}", response.toString());
//return response;
}
} }
} }

2
src/main/resources/application-dev.yml
View File

@@ -60,7 +60,7 @@ rocketmq:
name-server: 192.168.8.88:9876 # RocketMQ Name Server 地址 name-server: 192.168.8.88:9876 # RocketMQ Name Server 地址
producer: producer:
group: wx_producer # 生产者组名 group: wx_producer # 生产者组名
send-msg-timeout: 3000 # 发送消息超时时间 send-msg-timeout: 1000 # 发送消息超时时间
consumer: consumer:
group: wx_consumer # 消费者组名 group: wx_consumer # 消费者组名
consume-thread-min: 20 # 消费线程池最小线程数 consume-thread-min: 20 # 消费线程池最小线程数