为什么招聘网站做不大,建设零食网站的可行性,大商创官网,中国制造网外贸平台app“Spring Event” 是 Spring 框架通过事件驱动的编程模型来处理应用程序中的事件。开发者可以定义自己的事件#xff0c;然后在应用程序中触发这些事件。Spring 框架提供了用于发布和监听事件的机制#xff0c;以实现松散耦合的组件间通信。
有两个核心组件#xff1a;
事…“Spring Event” 是 Spring 框架通过事件驱动的编程模型来处理应用程序中的事件。开发者可以定义自己的事件然后在应用程序中触发这些事件。Spring 框架提供了用于发布和监听事件的机制以实现松散耦合的组件间通信。
有两个核心组件
事件监听器
案例代码 1.创建事件
Getter
public class UserRegisterEvent extends ApplicationEvent {private User user;public UserRegisterEvent(Object source, User user) {super(source);System.out.println(source);this.user user;}
}2.创建监听器
Slf4j
Component
public class UserRegisterListener {Autowiredprivate UserBackpackService userBackpackService;EventListener(classes UserRegisterEvent.class)public void sendCard(UserRegisterEvent event) {User user event.getUser();System.out.println(给user.getId()发改名卡...);}
}3.发布事件
Service
public class UserServiceImpl implements UserService {AutowiredApplicationEventPublisher applicationEventPublisher;Overridepublic void register(User user) {userDao.save(user);applicationEventPublisher.publishEvent(new UserRegisterEvent(this, user));}
}4.结果
com.cong.common.user.service.impl.UserServiceImpl16cc5e51
给11009发改名卡...EventListener 和 TransactionalEventListener 是 Spring Framework 中用于处理事件的两个注解它们之间主要的区别在于对事务的处理方式。
总结一下
EventListener
事件监听器和发布事件方法默认是同步同一个线程执行想让监听器异步执行在监听器上加Async注解需要在启动类Application上使用EnableAsync注解引入对Async的支持。
value用于指定监听的事件类型。可以是单个事件类型也可以是一个事件类型数组。如果不提供该参数则默认监听所有事件。classes与 value 参数类似用于指定监听的事件类型。可以是单个事件类型也可以是一个事件类型数组。与 value 不同的是classes 是 EventListener 注解的属性名称。fallbackExecution用于指定当事件处理方法无法执行时是否执行备用方法。默认值为 true表示如果事件处理方法无法执行则执行备用方法设置为 false 表示如果事件处理方法无法执行则不执行备用方法。condition用于指定在何种条件下执行事件监听器方法。可以使用 SpEL 表达式来定义条件。如果条件求值为 false则事件监听器方法不会执行。 TransactionalEventListener用于标记一个方法表示它是一个事件监听器并且该方法应该在事务的不同阶段进行调用。
value用于指定监听的事件类型。可以是单个事件类型也可以是一个事件类型数组。如果不提供该参数则默认监听所有事件。phase指定要监听的事务阶段可以是AFTER_COMMIT、AFTER_ROLLBACK或AFTER_COMPLETION。默认是AFTER_COMMIT。fallbackExecution用于指定当事务无法提交时是否执行事件监听器。默认值为 true表示如果事务无法提交则执行事件监听器设置为 false 表示如果事务无法提交则不执行事件监听器。condition用于指定在何种条件下执行事件监听器方法。可以使用 SpEL 表达式来定义条件。如果条件求值为 false则事件监听器方法不会执行。
EventListener和TransactionalEventListener的使用场景比较什么时候该用哪个
EventListener
事务处理
不会开启新的事务事件监听器方法将在发布事件的同一事务中执行。如果事件监听器方法抛出异常不会影响到发布事件的事务。
执行阶段
事件监听器方法默认在事务提交后TransactionPhase.AFTER_COMMIT执行。不支持指定执行阶段。
适用场景
适用于不需要事务支持的简单事件处理场景。当事件处理逻辑不依赖于事务或者对事务没有特殊要求时。
TransactionalEventListener
事务处理
会开启新的事务事件监听器方法在新的事务中执行。事件监听器方法的事务与发布事件的事务独立互不影响。如果事件监听器方法抛出异常该事务将回滚影响到发布事件的事务。
执行阶段
可以指定事件监听器方法的执行阶段包括事务提交前、事务提交后、事务回滚后等。支持更精细的事务控制。
适用场景
适用于需要事务支持的场景例如希望在新事务中执行或者希望根据事务阶段执行不同的逻辑。当事件处理逻辑对事务有特殊要求时例如需要在事务提交前执行某些操作。
总体建议 如果事件处理逻辑简单不需要事务支持或者事务隔离不是关键考虑因素可以选择使用 EventListener。 如果事件处理逻辑需要事务支持或者需要在事务的不同阶段执行不同的逻辑可以选择使用 TransactionalEventListener。 总之发布事件方法加了事务用TransactionalEventListener没加事务用EventListener
MQ和SpringEvent两种对比什么时候该用哪个
消息队列MQ和 Spring 事件机制ApplicationEvent 和相关注解如 EventListener是两种不同的通信机制它们各自有适用的场景和优势。以下是它们的对比和在何时选择使用哪个的一些建议
MQ消息队列
分布式系统
MQ 适用于分布式系统可以实现异步、解耦、松散耦合的组件通信。当系统需要将不同服务或模块进行解耦降低它们之间的直接依赖性时可以使用消息队列。
持久性
MQ 提供消息的持久性消息可以被持久化到队列中确保在消息发送和接收之间出现故障时消息不会丢失。当系统对消息的可靠性和持久性要求较高时可以选择使用消息队列。
异步通信
MQ 支持异步通信生产者将消息发送到队列而不需要等待消费者的响应。当系统需要异步处理提高系统的吞吐量和响应性能时可以使用消息队列。
消息传递的中间件
MQ 是专门设计用于消息传递的中间件有多种消息队列系统可供选择如 RabbitMQ、Apache Kafka、ActiveMQ 等。当系统需要高度可配置和专门优化的消息传递机制时可以选择适合的消息队列。
Spring 事件机制
单体应用或微服务内部通信
Spring 事件机制更适用于单体应用或微服务内部的组件通信通过 Spring 的事件机制不同组件之间可以进行解耦但通信相对于 MQ 更为简单。当系统是一个相对较小规模的单体应用或内部微服务通信较为简单时可以选择使用 Spring 事件机制。
松散耦合
Spring 事件机制通过发布-订阅的方式实现组件之间的松散耦合。当系统中的组件需要解耦但又不需要引入消息队列等复杂的中间件时可以选择使用 Spring 事件机制。
同步通信
Spring 事件机制是同步的发布者会等待所有监听器执行完毕后再继续执行。这与 MQ 的异步通信有所不同。当系统中的组件之间需要同步通信且不需要引入异步处理时可以选择使用 Spring 事件机制。
简化配置和集成
Spring 事件机制是 Spring 框架的一部分可以方便地与其他 Spring 特性集成且不需要引入额外的中间件。当系统中已经使用 Spring 框架且通信需求较为简单时可以选择使用 Spring 事件机制。
如何选择 如果系统是一个分布式系统需要异步、解耦、持久性、高可靠性的通信机制可以考虑使用消息队列。 如果系统是一个单体应用或者微服务内部通信相对简单需要简化配置和集成可以考虑使用 Spring 事件机制。 在一些场景中也可以同时使用两者根据具体的通信需求选择合适的机制。 总的来说选择 MQ 还是 Spring 事件机制取决于系统的规模、架构、通信需求和对可维护性的要求。
