liunx 安装ActiveMQ 及 spring boot 初步整合 activemq

V2AS问路

liunx 安装ActiveMQ 及 spring boot 初步整合 activemq

阅读原文时间：2023年07月09日阅读：2

源码地址： https://gitee.com/kevin9401/microservice.git

一、安装 ActiveMQ：

1. 下载 ActiveMQ

wget https://archive.apache.org/dist/activemq/5.14.0/apache-activemq-5.14.0-bin.tar.gz

2. 解压并且重命名为 activemq

tar -zxvf apache-activemq-5.14.0-bin.tar.gz && mv apache-activemq-5.14.0 activemq

3. 配置环境变量（不做也行，暂时没发现用处）

vim /etc/profile

添加

export ACTIVEMQ_HOME=/usr/local/softwares/activemq

export PATH=:$JAVA_HOME/bin:$ACTIVEMQ_HOME/bin:$PATH

使配置生效：

source /etc/profile

4. 进入目录，启动 activemq

cd /usr/local/softwares/activemq/bin/linux-x86-64

执行

./activemq start

5. 访问

ip:8161

点击 Manage ActiveMQ broker

6. 如果要输入用户名、密码，默认的是 admin/admin

【备注】如果访问不了，应该是被防火墙阻挡了，可以选择关闭防火墙，或者在放行列表中添加 8161(web管理页面端口）、61616（activemq服务监控端口）两个端口

如果防火墙是开启的：

打开linux防火墙端口

/sbin/iptables -I INPUT -p tcp --dport 8161 -j ACCEPT&&/etc/init.d/iptables save&&service iptables restart&&/etc/init.d/iptables status

/sbin/iptables -I INPUT -p tcp --dport 61616 -j ACCEPT&&/etc/init.d/iptables save&&service iptables restart&&/etc/init.d/iptables status

二、spring boot 整合 activemq

1. 引入依赖

org.springframework.boot spring-boot-starter-activemq

2. 创建消息队列对象

@Configuration
public class QueueConfig {

/\*\*  
 \* 创建 名称为 active.queue 的消息队列对象  
 \*  
 \* @return  
 \*/  
@Bean  
public Queue queue() {  
    return new ActiveMQQueue("active.queue1");  
}

}

3. 创建消息生产者

@RestController
public class QueueController {

@Autowired  
private JmsMessagingTemplate messagingTemplate;

@Autowired  
private Queue queue;

/\*\*  
 \* 消息生产者  
 \*/  
@RequestMapping(value = "/send")  
public void send() {  
    messagingTemplate.convertAndSend(queue, "hello world");  
}

}

4. 在 application.yml 中配置连接

spring:
activemq:
broker-url: tcp://ip:61616

5. 启动项目，调用发送消息接口

6. 查看消息队列

参考：https://www.cnblogs.com/shamo89/p/7645651.html

------------恢复内容开始------------

源码地址：