SpringBoot整合activemq的案例代码 SpringBoot整合activemq的案例代码

ActiveMQ是什么
1.安装activemq(linux)
2.SpringBoot整合activemq案例

2.1 pom.xml
2.2 application.properties
2.3 消息实体
2.4 主程序
2.5 定义消息的发送和接收方法
2.6 测试

ActiveMQ是什么 ActiveMQ是消息队列技术，为解决高并发问题而生
ActiveMQ生产者消费者模型（生产者和消费者可以跨平台、跨系统）
ActiveMQ支持如下两种消息传输方式

点对点模式，生产者生产了一个消息，只能由一个消费者进行消费
发布/订阅模式，生产者生产了一个消息，可以由多个消费者进行消费

1.安装activemq(linux) 1.下载压缩包，地址链接: https://activemq.apache.org/components/classic/download/.

文章图片

文章图片

2.利用xshell上传压缩包到linux上，并且解压

文章图片

3.进入到bin目录启动，通过./activemq start命令启动activemq

文章图片

4.在宿主主机范文虚拟机ip地址加上端口号8161，会出现登录弹框叫我们输入用户名和密码，用户名和密码都是admin。如下界面即代表active安装成功

文章图片

5.要注意的坑！
1）linux主机和宿主主机的防火墙都要关闭
2）linux主机和宿主主机一定要互ping得通
3）如果linux主机和宿主主机互ping得通，但是却访问不了activemq的端口，那就参考这篇文章，把conf目录下的jetty.xml文件中的地址为linux主机的ip地址，就可以访问了。文章链接: https://www.jb51.net/LINUXjishu/810589.html.
4）activemq还依赖java环境，所以linux上也要安装java环境

2.SpringBoot整合activemq案例
2.1 pom.xml

4.0.0org.springframework.bootspring-boot-starter-parent2.6.3 com.yljms0.0.1-SNAPSHOTjmsDemo project for Spring Boot11org.springframework.bootspring-boot-starter-activemqspring-boot-starter-webspring-boot-starter-testtestorg.springframework.bootspring-boot-maven-plugin

2.2 application.properties

# activemq的配置# 地址spring.activemq.broker-url=tcp://192.168.244.135:61616# 信任所有的包spring.activemq.packages.trust-all=true# 用户名spring.activemq.user=admin# 密码spring.activemq.password=admin

2.3 消息实体

package com.yl.jms.model; import java.io.Serializable; import java.util.Date; public class Message implements Serializable {private String content; private Date date; public String getContent() {return content; }public void setContent(String content) {this.content = content; public Date getDate() {return date; public void setDate(Date date) {this.date = date; @Overridepublic String toString() {return "Message{" +"content='" + content + '\'' +", date=" + date +'}'; }

2.4 主程序

package com.yl.jms; import org.apache.activemq.command.ActiveMQQueue; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; import javax.jms.Queue; @SpringBootApplicationpublic class JmsApplication {public static void main(String[] args) {SpringApplication.run(JmsApplication.class, args); }@BeanQueue queue() {return new ActiveMQQueue("yl-queue"); }

2.5 定义消息的发送和接收方法

package com.yl.jms.config; import com.yl.jms.model.Message; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.annotation.EnableJms; import org.springframework.jms.annotation.JmsListener; import org.springframework.jms.core.JmsMessagingTemplate; import org.springframework.stereotype.Component; import javax.jms.Queue; @Componentpublic class JmsComponent {//消息发送模板@AutowiredJmsMessagingTemplate jmsMessagingTemplate; Queue queue; //发送消息public void send(Message message) {jmsMessagingTemplate.convertAndSend(queue,message); }//接收消息@JmsListener(destination = "yl-queue")public void receive(Message message) {System.out.println("message:" + message); }

2.6 测试