Spring Boot 集成 ActiveMQ (Artemis
Apache ActiveMQ 是一款基于 Java 的消息服务器,它使用行业标准协议,支持我们把各种语言和平台开发的系统连接在一起。目前 ActiveMQ 分为两个版本:ActiveMQ 5 和 ActiveMQ Artemis (下一代ActiveMQ)。当 ActiveMQ Artemis 达到 ActiveMQ 功能时当会变为 ActiveMQ 6 。
activemq-5-activemq-artermis.pngSpring JMS 是专门用来处理 Spring 消息的模块。它支持主流的消息中间键,能完美结合 ActiveMQ 。Spring Boot 应用通过集成 Spring JMS 模块整合 ActiveMQ ,本文涉及 ActiveMQ 5 和 ActiveMQ Artemis 两种配置方法,跟据项目实际使用 ActiveMQ 的版本,采取一种配置即可。
引入依赖
- 引入activemq
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-activemq</artifactId>
</dependency>
- 引入activemq artemis (与 activemq 二选一)
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-artemis</artifactId>
</dependency>
配置
在 application.yml 中增加:
- 配置 activemq
spring:
activemq:
broker-url: tcp://${ACTIVEMQ_HOST, localhost}:61616 # activemq连接地址
user: ${ACTIVEMQ_USER, admin} # 用户名
password: ${ACTIVEMQ_PASSWORD, admin} # 密码
send-timeout: # 发送超时时间
pool:
enabled: false # 是否创建 JmsPoolConnectionFactory 连接池
idle-timeout: 30s # 空闲连接超时时间
max-connections: 50 # 连接池中最大连接数
max-sessions-per-connection: 100 # 每个连接最大会话
- 配置 activemq artemis
spring:
artemis:
mode: native
host: ${ARTEMIS_HOST, localhost} # artermis连接地址
port: ${ARTEMIS_PORT, 9876} # artermis连接端口
user: ${ARTEMIS_USER, admin} # 用户名
password: ${ARTEMIS_PASSWORD, admin} # 密码
send-timeout: # 发送超时时间
pool:
enabled: false # 是否创建 JmsPoolConnectionFactory 连接池
idle-timeout: 30s # 空闲连接超时时间
max-connections: 50 # 连接池中最大连接数
max-sessions-per-connection: 100 # 每个连接最大会话
Spring JMS 中默使用 CachingConnectionFactory 创建连接池,如果指定 JmsPoolConnectionFactory 连接池,测在 spring.jms.* 中配置连接池属性。
spring:
jms:
session-cache-size: 5
关于 Activemq (Artemis) 和 Apring Jms 更多配置,可参考:Spring Boot Integration Properties
使用
JmsTemplate 是 Spring JMS 中用来发送消息的类。做完以上配置,在 Spring Boot 启动入口加上 @EnableJms
注解,项目在启动时会自动装配,在项目中直接注入 JmsTemplate 对象。
@SpringBootApplication
@EnableJms
public class Application {
@Autowired
private JmsTemplate jmsTemplate;
public static void main(String[] args) {
SpringApplication.run(Application.class);
}
}
发送文本消息示例:
public void send(String msg) {
log.info("发送消息:{}", msg);
jmsTemplate.send(DEST_NAME, new MessageCreator() {
@Override
public Message createMessage(Session session) throws JMSException {
// 也可以创建对象 session.createObjectMessage()
TextMessage textMessage = session.createTextMessage();
textMessage.setText(msg);
return textMessage;
}
});
}
接收使用 @JmsListener
注解:
/**
* 监听消息
* @param content
*/
@JmsListener(destination = DEST_NAME, concurrency = "消费线程数")
public void recive(String content) {
log.info("收到消息:{}", content);
}
发送消息和接收消息的 DEST_NAME 要保持一至。 concurrency 属性非必须,用来设置消费消息的程序数。关于 ActiveMQ 的详细介绍会在专门的章节讲解。
除非注明,否则均为"攻城狮·正"原创文章,转载请注明出处。
本文链接:https://engr-z.com/137.html