服务端订阅

概念说明

服务端订阅主要用于物联网平台的设备数据实时转发到用户自建的服务器，每个消费组有单独指定的用户自建服务器连接信息。

目前支持的消费组类型有：MQTT、AMQP。

一、创建订阅信息

操作说明

1. 新建订阅后，选择产品绑定的消费组与功能类型
2. 其中消费组由上一章节介绍，支持的类型为MQTT或AMQP
3. 其中功能类型与Topic绑定，比如选择了属性上报，则服务端将监听所有分类于属性上报的Topic，接收到数据后就将其转发至分配的消费组。
4. 数据创建好之后将订阅配置启用，服务端在1分钟内进行配置更新，然后就可以进行转发订阅的测试了。

系统界面3

二、自建服务测试MQTT订阅

1. 找到blade-demo工程下的relay-mqtt工程，这是mqtt服务端订阅的demo工程。
2. 修改application.yml中的mqtt配置，注意port参数需要和消费组的连接端口配置一致。

系统界面4

3. 修改application-dev.yml的spring.datasource配置，指向自建服务。

系统界面5

4. 启动RelayMqttApplication，启动成功后，可以在控制台等待查看订阅推送的数据。

系统界面6

5. 打开设备模拟器模拟上报数据，可以看到控制台输出订阅的数据与上报操作的数据完全一致。

系统界面7

三、自建服务测试AMQP订阅

1. AMQP协议的订阅服务，我们一般采用RabbitMQ构建，Docker启动命令如下。

docker run --name rabbitmq -d \
  -p 15672:15672 -p 5672:5672 \
  -e RABBITMQ_DEFAULT_USER=root \
  -e RABBITMQ_DEFAULT_PASS=root \
  rabbitmq:3.12-management

2. 启动成功后访问：http://localhost:15672/，使用root/root登录。看到如下界面则说明RabbitMQ服务启动成功。

系统界面8

3. 找到blade-demo工程下的relay-amqp工程，这是amqp服务端订阅的demo工程。
4. 修改application-dev.yml的spring.rabbitmq配置与spring.datasource配置，指向自建服务。

系统界面9

5. 启动RelayAmqpApplication，启动成功后，可以在控制台等待查看订阅推送的数据。

系统界面10

6. 打开设备模拟器模拟上报数据，可以看到控制台输出订阅的数据与上报操作的数据完全一致。

系统界面1