针对初次接触消息队列RocketMQ版的工程师,本文以TCP协议下的Java为例,提供操作示例帮助您从零开始搭建消息队列RocketMQ版测试工程。Demo工程包含普通消息、顺序消息、事务消息、定时和延时消息的测试代码,以及相关Spring的配置。
前提条件
- 安装IDE。
您可以使用IntelliJ IDEA或者Eclipse,本文以IntelliJ IDEA为例。
请下载IntelliJ IDEA Ultimate版本,并参见IntelliJ IDEA说明进行安装。更多信息,请参见下载地址。
- 下载Demo工程。
下载到本地并解压后即可看到本地新增了rocketmq-demo-master文件夹,该文件夹包括纯Java、Spring以及Spring Boot的示例代码。更多信息,请参见rocketmq-demo。
- 下载安装JDK。更多信息,请参见JDK下载地址。
配置Demo工程
- 将Demo工程文件导入IntelliJ IDEA。
- 创建资源。
您需要先到控制台创建所需资源,包括消息队列RocketMQ版的实例、Topic、Group ID(GID),以及鉴权需要的AccessKey(AK)。
更多详细信息和操作指导,请参见创建资源。
- 配置Demo。
您需将在步骤2中创建好的资源信息配置到2个文件:MqConfig
类和common.xml。
- 按以下说明配置
MqConfig
类。public static final String TOPIC = "您刚创建的Topic";
public static final String GROUP_ID = "您刚创建的Group ID";
public static final String ORDER_TOPIC = "您刚创建的用于收发顺序消息的Topic";
public static final String ORDER_GROUP_ID = "您刚创建的用于收发顺序消息的Group ID";
public static final String ACCESS_KEY = "您的阿里云账号的AccessKey ID";
public static final String SECRET_KEY = "您的阿里云账号的AccessKey Secret";
public static final String TAG = "您自定义的消息Tag属性";
public static final String NAMESRV_ADDR = "您刚创建的消息队列RocketMQ版实例的TCP接入点,可在消息队列RocketMQ版控制台的实例详情页面获取TCP协议客户端接入点";
说明
- 创建AccessKey(包括AccessKey ID和AccessKey Secret)的具体步骤,请参见创建AccessKey。
- 如果RAM子账号拥有该Topic的权限以及自己的AccessKey,那么也可以使用RAM子账号的AccessKey。
- 参数与接口的更多信息,请参见接口和参数说明。
- 配置common.xml。
<props>
<prop key="AccessKey">XXX</prop> <!-- 使用前请修改这些资源信息 -->
<prop key="SecretKey">XXX</prop>
<prop key="GROUP_ID">XXX</prop>
<prop key="Topic">XXX</prop>
<prop key="NAMESRV_ADDR">XXX</prop>
</props>
以Main方式运行Demo
- 发送消息。
- 接收消息。
- 接收普通消息:
- 以纯Java方式接收普通消息:运行
SimpleMQConsumer
类。
- 以Spring方式接收普通消息:运行
ConsumerClient
类。
- 以Spring Boot方式接收普通消息:运行
ConsumerClient
类。
- 接收事务消息:
- 以纯Java方式接收事务消息:运行
SimpleMQConsumer
类。
- 以Spring方式接收事务消息:运行
ConsumerClient
类。
- 以Spring Boot方式接收事务消息:运行
ConsumerClient
类。
- 接收顺序消息:
- 以纯Java方式接收顺序消息:运行
SimpleOrderConsumer
类。
- 以Spring方式接收顺序消息:运行
OrderConsumerClient
类。
- 以Spring Boot方式接收顺序消息:运行
OrderConsumerClient
类。
- 接收定时和延时消息:运行
SimpleMQConsumer
类。
说明 Spring和Spring Boot框架暂不支持收发定时和延时消息。
可以看到消息被接收打印的日志。因为有初始化,所以需等待几秒,在生产环境中不会经常初始化。
结果验证:在消息队列RocketMQ版控制台,查看消费者状态,可以看到启动的消费端已经在线,并且订阅关系一致。
在文档使用中是否遇到以下问题
更多建议
匿名提交