当前位置：首页 > news >正文

Spring事件发布ApplicationEventPublisher原理

news 来源：原创 2024/5/20 11:17:38

借鉴：https://blog.csdn.net/zxfhahaha/article/details/112558429
https://blog.csdn.net/qq_46940224/article/details/131043987
https://blog.csdn.net/weixin_37672801/article/details/128803430
https://www.cnblogs.com/shamo89/p/15715091.html
https://blog.csdn.net/laohuangaa/article/details/119772453

Spring事件发布原理(ApplicationEventPublisher接口)

1.事件发布的使用：

事件驱动机制其实是观察者模式（又称发布订阅）具体实现，事件对象（HtwBikeRoadSignEvent）相当于被观察对象, 事件监听(EventListener) 相当于观察者。@EventListener（）括号里面是哪个对象就是监听哪个对象。

HtwBikeRoadSignAction.java: 自己定义的类，在方法中发布事件

@Service
public class HtwBikeRoadSignAction implements AssetInBoundAction {@Autowiredprivate HtwBikeRepository htwBikeRepository;@Resourceprivate ApplicationContext applicationContext;@Resourceprivate CityExtInfoIntegrationService cityExtInfoIntegrationService;@Autowiredprivate AssetAddressAndStatusConvertManager convertManager;@Overridepublic AssetsInBoundResult apply(AssetContext context, AssetsInBoundParam param) {AssetsInBoundResult assetsResult = new AssetsInBoundResult();List<Long> bikeIds = Collections.emptyList();bikeIds.add(12245L);List<HtwBikeEntity> htwBikeEntityList = htwBikeRepository.getByIds(bikeIds);HtwBikeRoadSignEvent htwBikeRoadSignEvent = HtwBikeRoadSignEvent.builder().context(context).htwBikeEntities(htwBikeEntityList).build();//更新车辆信息modifyHtwBikeInfo(context, htwBikeEntityList);*/// 5.发送车辆绑定事件applicationContext.publishEvent(htwBikeRoadSignEvent);assetsResult.setInBoundResult(true);return assetsResult;}
}

HtwBikeRoadSignEvent.java:

/*** 路面签收事件*/
@Data
@Builder
public class HtwBikeRoadSignEvent extends AssetSopEvent {/*** 操作上下文*/private AssetContext context;/*** 车辆信息*/private List<HtwBikeEntity> htwBikeEntities;/*** 车辆更新字段*/private Map<String,Object> bikeUpdateMap;/*** 锁更新字段*/private Map<String,Object> lockUpdateMap;
}

HtwBikeRoadSignSrmHandler.java:

/*** 车辆路面签收通知*/
@Component
public class HtwBikeRoadSignSrmHandler {@Value("${srm.producer.topic}")private String                  srmGatewayTopic;/*@Resource(name = "exporterBlocMessageProducer")private BlocMessageProducerImpl producer;*/@Async@EventListener(HtwBikeRoadSignEvent.class)public void onRoadSign(HtwBikeRoadSignEvent event) {AssetContext context = event.getContext();List<HtwBikeEntity> htwBikeEntities = event.getHtwBikeEntities();AssetChangeOrderMessageDTO assetChangeOrderMessageDTO = new AssetChangeOrderMessageDTO();assetChangeOrderMessageDTO.setChangeType(1);//producer.sendMessage(srmGatewayTopic, assetChangeOrderMessageDTO);}}@Async 添加注解表示这个方法要异步执行

2.Spring的两种监听器的实现有两种方式：

实现ApplicationListener接口：方法是onApplicationEvent(E event);
注解@EventListener

3.原理： 待自己补充：TODO ，先看这个里面的有源码贴图： https://www.cnblogs.com/shamo89/p/15715091.html 或者 https://blog.csdn.net/laohuangaa/article/details/119772453

4.观察者模式：

包含观察者和目标(被观察者)两种对象。目标和观察者之间存在一对多的关系，通过建立目标与观察者之间的联系，当目标的某个状态发生变化时，所有与之关联的观察者都会得到通知并执行各自的任务。

也称发布-订阅模式：
订阅：观察者向目标对象注册自己，告诉目标对象自己在观察它。
发布：当目标对象的状态发生改变时，向它所有的观察者发送通知，观察者收到通知后执行各自的操作。

优点：降低了目标与观察者之间的耦合关系。
缺点：目标与观察者之间没有完全解耦，还可能出现循环引用；当观察者对象很多时，通知的发布可能会很耗时。

5.Spring5种标准事件： Spring源码中也是用了事件发布，下面的是监听对象即事件

上下文更新事件（ContextRefreshedEvent）： ApplicationContext初始化或刷新，或者说在容器实例化(refresh())时发布事件；
上下文开始事件（ContextStartedEvent）：Spring容器启动时，即调用ConfigurableApplicationContext接口的start()时发布事件；
上下文停止事件（ContextStoppedEvent）：Spring容器停止时，即调用ConfigurableApplicationContext接口的stop()时发布事件，关闭的容器可以通过start()重启；
上下文关闭事件（ContextClosedEvent）：Spring容器关闭时，即调用ConfigurableApplicationContext接口的close()时发布事件，所有的Bean已被销毁，无法重启容器；
请求处理事件（RequestHandledEvent）：当一个请求被处理完成时发布事件。