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
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.6.3</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.yl</groupId>
<artifactId>jms</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>jms</name>
<description>Demo project for Spring Boot</description>
<properties>
<java.version>11</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
<artifactId>spring-boot-starter-web</artifactId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>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=admin2.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;
@Override
public 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;
@SpringBootApplication
public class JmsApplication {
public static void main(String[] args) {
SpringApplication.run(JmsApplication.class, args);
}
@Bean
Queue 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;
@Component
public class JmsComponent {
//消息发送模板
@Autowired
JmsMessagingTemplate 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 测试
到此这篇关于SpringBoot整合activemq的文章就介绍到这了,更多相关SpringBoot整合activemq内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！
