本文以社区版Apache RocketMQ Client为例,提供操作示例帮助您从零开始搭建阿里云消息队列RocketMQ版收发消息的测试工程。Demo工程包含普通消息、顺序消息、事务消息的测试代码。
配置Demo工程
- 将Demo工程文件导入IntelliJ IDEA。
- 在IntelliJ IDEA界面,选择Import Project,选择mq-demo/rocketmq/java-rocketmq-demo文件夹。
- 选择Import类型为Maven。
- 默认单击Next,直到导入完成。Demo工程需要加载依赖的JAR包,因此导入过程需要等待2-3分钟。
- 创建资源。
您需要先到控制台创建所需资源,包括阿里云消息队列RocketMQ版的实例、Topic、Group ID(GID),以及鉴权需要的AccessKey(AK)。
更多详细信息和操作指导,请参见步骤二:创建资源。
- 配置Demo。
您需将在
步骤2中创建好的资源信息配置到文件:
MqConfig
类。
public static final String TOPIC = "刚才创建的Topic";
public static final String GROUP_ID = "刚才创建的Group ID";
public static final String ACCESS_KEY = "您的阿里云账号的AccessKeyId";
public static final String SECRET_KEY = "您的阿里云账号AccessKeySecret";
public static final String NAMESRV_ADDR = "您的阿里云RocketMQ实
例的TCP接入点,在控制台实例详情页面的获取接入点信息区域获取";
说明
- 创建AccessKey(包括AccessKeyId和AccessKeySecret)的具体步骤,请参见创建AccessKey。
- 如果RAM子账号拥有该Topic的权限以及自己的AccessKey,那么也可以使用RAM用户的AccessKey。
以Main方式运行Demo
- 发送消息。
- 接收消息
- 接收普通消息:运行
RocketMQConsumer
类。
- 接收事务消息:运行
RocketMQConsumer
类。
- 接收顺序消息:运行
RocketMQOrderConsumer
类。
可以看到消息被接收打印的日志。因为有初始化,所以需等待几秒,在生产环境中不会经常初始化。
从消息队列RocketMQ版控制台进入Group管理>消费者状态,可以看到启动的消费端已经在线,并且订阅关系一致。
在文档使用中是否遇到以下问题
更多建议
匿名提交