消息机制是使用消息通知的方式，解耦生产者与消费者。编程上体现的是职责分割，使得消息处理的扩展性得到增强，符合设计原则中的单一职责以及开闭原则。
Spring的ApplicationListener接口
ApplicationListener是Spring应用监听器基础接口，是消费者需要实现，用来消费特定事件的，接口如下：
public interface ApplicationListener<E extends ApplicationEvent>
extends EventListener {
/**
* Handle an application event.
* @param event the event to respond to
*/
void onApplicationEvent(E event);
}
如何使用
利用Spring消息机制进行业务处理，逻辑非常简单，只需要以下几个步骤：
- 定义事件消息，即需要发布的消息对象，例如：
public class ApplicationEventSimple extends ApplicationEvent
- 定义处理器，并声明能够处理的消息类型，即实现ApplicationListener接口，实现类被Spring托管后，会自动被识别，并加入到消息监听器集合中，使用实例：
@Component
public class DefaultListener
implements ApplicationListener<ApplicationEventSimple>
- 发布消息，通过ApplicationContext.publishEvent(ApplicationEvent event)发布消息，Spring会自动找到对应的处理器进行处理。
Spring内置事件
Spring在容器启动阶段或者销毁阶段，提供了相关的事件通知，通过传递整个ApplicationContext，以便使用者在容器启停阶段能够植入自己的逻辑。
消息类的基类为：ApplicationContextEvent，具体实现有ContextStartedEvent（容器开始启动事件），ContextClosedEvent（容器关闭时事件），ContextRefreshedEvent（IOC容器启动完成事件），ContextStoppedEvent（容器停止事件）。
如果想要监听这些事件，只需要实现监听程序即可，我司RPC自动注册就是通过ContextRefreshedEvent消息的监听，然后处理的。
最后，Spring消息消费可以控制异步或者同步执行，而正确的使用消息机制对于代码的逻辑控制将会非常的灵活。
网友评论