通常情况下,为了提高系统开发的灵活性和可维护度,我们会采用消息队列队系统进行解耦。下面是一个采用spring redis实现的消息队列实例,但此实例会由于网络延迟和阻塞等情况导致消息处理的延时,因而不能确保消息处理的顺序,所以使用时需要注意。
pom.xml中添加如下配置
添加版本配置
properties文件中添加如下配置
applicationContext.xml中添加如下配置:
定义消息发送者(生产者):
定义消息处理者(消费者):
调用:/queue/redis
新建applicationContext-redis.xml,内容如下:
目录结构