ActiveMQ是Apache提供的开源组件,是基于JMS标准的实现组件。下面将利用SpringBoot整合ActiveMQ组件,实现队列消息的发送与接收。
第一步:引入依赖
第二步:修改application.yml文件,进行ActiveMQ的配置
第三步:定义消息消费监听类
第四步:定义消息生产者业务接口
第五步: 定义消息业务实现类
第六步:定义JMS消息发送配置类
第七步:测试发送消息
查看结果:
本文采用ActiveMQ实现了消息的发送与接收处理。每当有消息接收到时,都会自动执行MessageConsumer类,进行消息消费。