实现方便#xff0c;代码方面基本只需要定义消息体和消费者#xff0c;适用于小型应用程序。

不依赖外部中间件因此稍微学习一下如何使用并了解一下这种实现方式的优缺点。

实现方便代码方面基本只需要定义消息体和消费者适用于小型应用程序。

不依赖外部中间件因而不需要复杂的配置、部署。

无法提供消息持久性项目一旦重启消息就会丢失因而不适合实现延迟队列。

对比消息队列无法实现复杂的消息过滤、路由过滤。

无法实现跨应用程序的事件通信。

不同应用程序之间的事件发布和订阅更为容易。

发布订阅模式的优缺点我就不说了就说说不同实现方式之间的优缺点。

一、创建消息类

消息类需要继承ApplicationEvent类。

因为java调用构造函数的机制就是默认会调用父类的构造函数而ApplicationEvent类只有一个单参数的构造函数无法自动调用每个构造函数都需要显式调用父类的构造函数。

也就是super(source);

package

org.jeecg.modules.test.testPublic;

import

org.springframework.context.ApplicationEvent;

import

触发事件的对象可随便传不过建议传自己可能用得到的对象。

好像在调用放直接this的挺多*

param

{super(source);this.taskIdtaskId;this.sourceTypesourceType;}public

String

myEvent.sourceType);}Overridepublic

int

发布消息可以直接使用ApplicationContext对象调用publishEvent方法。

因为ApplicationContext接口继承了ApplicationEventPublisher接口。

注意消息类必须要继承ApplicationEvent类才能作为参数发布消息。

package

org.jeecg.modules.test.testPublic;import

import

io.swagger.annotations.ApiOperation;

import

org.springframework.beans.factory.annotation.Autowired;

import

org.springframework.context.ApplicationContext;

import

org.springframework.web.bind.annotation.GetMapping;

import

org.springframework.web.bind.annotation.RequestMapping;

import

org.springframework.web.bind.annotation.RestController;/***

ClassName:

applicationContext;ApiOperation(testEvent)GetMapping(/testEvent)public

void

MyEvent(this,123456,1);applicationContext.publishEvent(myEvent);}ApiOperation(testEvent1)GetMapping(/testEvent1)public

void

MyEvent(this,123456,2);applicationContext.publishEvent(myEvent);}

三、监听消息

监听消息类需要实现ApplicationListener接口并通过泛型传入要监听的消息类并重写onApplicationEvent方法。

spring内的同一个消息可以有多个监听类一旦监听到消息监听该消息的全部监听类都会执行。

监听类1

org.jeecg.modules.test.testPublic;import

org.springframework.context.ApplicationListener;

import

org.springframework.stereotype.Component;/***

ClassName:

{System.out.println(消费者开始消费event.toString()event.getSource().toString());}

消费者2

org.jeecg.modules.test.testPublic;import

org.springframework.context.ApplicationListener;

import

org.springframework.stereotype.Component;/***

ClassName:

{System.out.println(消费者1开始消费event.toString()event.getSource().toString());}

四、测试

结果均符合预期可以通过在消息体里面加一个字段来区分消息来着不同的触发场景。

即使没有在结构体加上区分消息来源的标识也可以用消息一开始传入的源对象来大概定位到是哪一个类里面触发的消息。