帮助中心
帮助中心主页
安装与部署
开发与集成
RDS脚本方法字典
MQTT 订阅信息(使用配置文件的topic)
  • 方法说明
    向配置的 topic 订阅信息 。
typescript
function MQTTSubscribe(): string;
1
  • 输入参数
    无。
  • 输出参数
    订阅到的信息。
  • 异常
    本方法不会抛出异常。
  • 使用示例
      1. 在 application-biz.yml 里面开启MQTT,并完成相应的配置,如下:
yaml
# 是否开启 MQTT 服务
mqttConfigView:
  enable: true
  pubConfig:
    # 服务器端点url
    broker: tcp://broker.emqx.io:1883
    # 订阅的主题,MQTT允许使用通配符订阅主题,不允许使用通配符pub发布消息
    topics:
      - Examples/1/123
    # 设置message的服务质量(0:消息最多传递一次(零次或一次)1:至少传递一次(一次或多次)。2:只传递一次)
    qos: 2
    # 客户端唯一标识
    clientId: RDS-Pub
    # 连接的用户名,不需要就填 null
    username: null
    # 连接的密码,不需要就填 null
    password: null
    # 设置是否清空session,false表示服务器会保留客户端的连接记录,true每次都以新的身份连接服务器
    cleanSession: false
    # 超时时间(seconds)
    connectionTimeout: 30
    # 设置会话心跳时间(seconds)
    keepAliveInterval: 60
    # 设置断开后重新连接
    automaticReconnect: true
    # 表示发送的消息需要一直持久保存(不受服务器重启影响),不但要发送给当前的订阅者,并且以后新来的订阅了此Topic name的订阅者会马上得到推送。
    retained: false
    # 作为publish的遗嘱消息,会存到服务器,在publish端非正常断连的情况下,发送给所有订阅的客户端
    # 不需要就填 null
    willMsg: null
    # 遗嘱消息发布的topic
    willTopic: Examples1
  subConfig:
    # 服务器端点url
    broker: tcp://broker.emqx.io:1883
    # MQTT允许使用通配符sub订阅主题,但不允许使用通配符pub发布消息
    topics:
      - Examples/1/123
    # 设置message的服务质量(0:消息最多传递一次(零次或一次)1:至少传递一次(一次或多次)。2:只传递一次)
    qos: 1
    # 客户端唯一标识
    clientId: RDS-Sub
    # 连接的用户名,不需要就填 null
    username: null
    # 连接的密码,不需要就填 null
    password: null
    # 设置是否清空session,false表示服务器会保留客户端的连接记录,true每次都以新的身份连接服务器
    cleanSession: false
    # 超时时间(seconds)
    connectionTimeout: 30
    # 设置会话心跳时间(seconds)
    keepAliveInterval: 60
    # 设置断开后重新连接
    automaticReconnect: true
    # 表示发送的消息需要一直持久保存(不受服务器重启影响),不但要发送给当前的订阅者,并且以后新来的订阅了此Topic name的订阅者会马上得到推送。
    retained: false
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
    1. 编写脚本方法
javascript
var data = jj.MQTTSubscribe();
jj.scriptLog("info","sub",data);
1
2
最近更新 2022/12/06
文章内容