消息总线用法2.4+
最后更新于：2022-04-02 07:10:29
# 消息总线使用集成2.4+
[TOC]
> 【发布订阅】本模块提供对消息总线的封装使用具体用法如下
## 1. 注入消息发送客户端
```
@Autowired
private RabbitMqClient rabbitMqClient;
```
## 2. 发送远程事件示例代码
```
BaseMap params = new BaseMap();
params.put("orderId", "123456");
rabbitMqClient.publishEvent("demoBusEvent", params);
```
## 3. 编写消息监听监听器
~~~
/**
* 消息处理器
*/
@Slf4j
@Component("demoBusEvent")
public class DemoBusEvent implements JeecgBusEventHandler {
@Override
public void onMessage(EventObj obj) {
if (ObjectUtil.isNotEmpty(obj)) {
BaseMap baseMap = obj.getBaseMap();
String orderId = baseMap.get("orderId");
log.info("业务处理----订单ID:" + orderId);
}
}
}
~~~
注：如果多个业务模块都存在相同的beanName定义，则可同时接收消息进行业务处理
';