RabbitMQ对接指南

注意

仅支持本地DockerCompose版本

本文介绍如何使用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>

步骤二: 接收消息

关于更多客户端的使用可以参考RabbitMq官网的使用。

注意

配置消费者的时候，一定要注意Queue的设置是：开放topic + 您的访问凭证AccessKeyId。
(比如: 开放topic是"rq-demo-topic",您的访问凭证是"rq-demo-accessKeyId",那么您的Queue应该为 "rq-demo-topic/rq-demo-accessKeyId")

RabbitMQ对接指南

步骤一: 准备工作#

步骤二: 接收消息#

步骤一: 准备工作

步骤二: 接收消息