本文介绍如何使用Java,完成对领域事件的RabbitMQ消息接收。步骤一: 准备工作#
1.在AIoT平台创建属于您的访问凭证,并获取对应的AccessKeyId和AccessKeySecret。2.创建Maven项目工程,在pom.xml中引入rabbitmq客户端依赖: <dependency>
<groupId>com.rabbitmq</groupId>
<artifactId>amqp-client</artifactId>
<version>5.9.0</version>
</dependency>
步骤二: 接收消息#
配置消费者的时候,一定要注意Queue的设置是:开放topic + 您的访问凭证AccessKeyId。
(比如: 开放topic是"rq-demo-topic",您的访问凭证是"rq-demo-accessKeyId",那么您的Queue应该为 "rq-demo-topic/rq-demo-accessKeyId")