- 同步发送消息
- 异步发送消息
- 以单向模式发送消息
- 发送有序消息
- 发送批量消息
- 发送交易消息
- 发送具有延迟级别的预定消息
- 以并发模式(广播/集群)消费消息
- 消费有序消息
- 使用标记或 sql92 表达式过滤消息
- 支持消息追踪
- 支持认证和授权
- 支持请求-回复消息交换模式
- 使用推/拉模式消费消息
- JDK 1.8 及以上
- Maven 3.0 及以上
- Spring Boot 2.0 及以上
使用 maven 添加依赖项:
<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-starter-stream-rocketmq</artifactId>
</dependency>
<!--或者-->
<!--<dependency>
<groupId>com.alibaba.cloud</groupId>
<artifactId>spring-cloud-stream-binder-rocketmq</artifactId>
</dependency>-->
Please see the rocketmq-spring-boot-samples.
Please see the wiki page.