# Spring Boot 集成 （二） apache
# RocketMQ-Spring
帮助开发者在Spring Boot中快速集成RocketMQ。支持Spring Message规范，方便开发者从其它MQ快速切换到RocketMQ。
# 功能特性
- 同步发送
- 异步发送
- one-way发送
- 发送顺序消息
- 批量发送
- 发送事务消息
- 发送延迟消息
- 并发消费（广播/集群）
- 顺序消费
- 支持消息过滤（使用tag/sql）
- 支持消息轨迹
- 认证和授权
- request-reply模式
# 使用方法
添加maven依赖：
<!--在pom.xml中添加依赖-->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>${RELEASE.VERSION}</version>
</dependency>
1
2
3
4
5
6
2
3
4
5
6
# ACL功能
Producer 端要想使用 ACL 功能，需要多配置两个配置项:
## application.properties
rocketmq.name-server=127.0.0.1:9876
rocketmq.producer.group=my-group
rocketmq.producer.access-key=AK
rocketmq.producer.secret-key=SK
1
2
3
4
5
6
2
3
4
5
6
Consumer 端 ACL 功能需要在 @RocketMQMessageListener中进行配置
@Service
@RocketMQMessageListener(
topic = "test-topic-1",
consumerGroup = "my-consumer_test-topic-1",
accessKey = "AK",
secretKey = "SK"
)
public class MyConsumer implements RocketMQListener<String> {
...
}
1
2
3
4
5
6
7
8
9
10
2
3
4
5
6
7
8
9
10
注意: 可以不用为每个 @RocketMQMessageListener 注解配置 AK/SK，在配置文件中配置 rocketmq.consumer.access-key 和 rocketmq.consumer.secret-key 配置项，这两个配置项的值就是默认值
# 支持配置多个 RocketMQTemplate
参考org.apache.rocketmq.spring.autoconfigure.RocketMQAutoConfiguration 的配置。
参考文档