1. 获取Bean对象
applicationContext.getBean(beanName, bean.class);
public interface SendMsgHandle {
void sendMsg(String msg);
}
@Service("statusUpdateMsgHandler")
@Slf4j
public class StatusUpdateMsgHandler implements SendMsgHandle{
@Override
public void sendMsg(String msg) {
log.info("receive msg: {}", msg);
}
}
SendMsgHandle handler = webApplicationContext.getBean("statusUpdateMsgHandler", SendMsgHandle.class);
handler.sendMsg(JSON.toJSonString("test"));
2. 发布消息事件
// obj为传递的事件对象
applicationContext.publishEvent(Object obj);
// 订阅消息事件：使用注解@EventListener，该注解默认是同步执行的，若要实现异步执行，需加@Async。方法参数为事件对象，指明要监听订阅的事件。
public void execute(Object obj) {}
====================================== 分隔符 ======================================
// 1.创建要发送的内容对象
OrderDTO orderDTO = OrderDTO.builder().no("6853738696568484").build();
// 发送创建订单成功相关消息
applicationContext.publishEvent(orderDTO);
// 2.监听接收
@Component
@Slf4j
public class OrderDTOListener {
@EventListener
@Async("async_thread_pool_bean_name")
public void execute(OrderDTO orderDTO) {
// 发送创建订单成功相关消息
if (Objects.nonNull(orderDTO) && StringUtils.isNotEmpty(orderDTO.getNo())){
String jsonData = JSONObject.toJSonString(orderDTO);
log.info("接收: {}", jsonData);
}
}
}
