Skip to content

Latest commit

 

History

History

alibaba-stream-rocketmq

Alibaba RocketMQ

特征

  • 同步发送消息
  • 异步发送消息
  • 以单向模式发送消息
  • 发送有序消息
  • 发送批量消息
  • 发送交易消息
  • 发送具有延迟级别的预定消息
  • 以并发模式(广播/集群)消费消息
  • 消费有序消息
  • 使用标记或 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.