# 主题订阅

# 订阅

# URI

POST /mqtt/subscribe

# 请求消息

名称类型描述
topicString主题,与 topics 至少指定其中之一
topicsString, 分割的多个主题,使用此字段能够同时订阅多个主题
clientidString客户端标识符
qosIntegerQoS

# 响应消息

名称类型描述
codeInteger0

# 请求示例

$ curl -u app_id:app_secret -X POST {api}/mqtt/subscribe
1
{
  "topic": "d",
  "qos": 1,
  "clientid": "emqx_c_1"
}
1
2
3
4
5

# 响应示例

{
  "code": 0
}
1
2
3

# 取消订阅

# URI

POST /mqtt/unsubscribe

# 请求消息

名称类型描述
topicString主题
clientidString客户端标识符

# 响应消息

名称类型描述
codeInteger0

# 请求示例

$ curl -u app_id:app_secret -X POST {api}/mqtt/unsubscribe
1
{
  "topic": "a",
  "clientid": "emqx_c_1"
}
1
2
3
4

# 响应示例

{
  "code": 0
}
1
2
3

# 批量主题订阅

# URI

POST /mqtt/subscribe_batch

# 请求消息

名称类型描述
[].topicString主题,与 topics 至少指定其中之一
[].topicsString, 分割的多个主题,使用此字段能够同时订阅多个主题
[].clientidStringclientid
[].qosIntegerQoS 等级

# 响应消息

名称类型描述
codeInteger0
dataArray of Objects所有订阅信息
data[].clientidStringclientid
data[].topicString订阅主题
data[].codeInteger0

# 请求示例

$ curl -u app_id:app_secret -X POST {api}/mqtt/subscribe_batch
1

# 响应示例

{
  "data": [
    {
      "topic": "testtopic/#",
      "qos": 0,
      "node": "emqx@10.12.50.36",
      "clientid": "emqx_c_1"
    },
    {
      "topic": "topic/a",
      "qos": 0,
      "node": "emqx@10.12.50.36",
      "clientid": "emqx_c_1"
    }
  ],
  "code": 0
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

# 批量取消主题订阅

# URI

POST /mqtt/unsubscribe_batch

# 请求消息

名称类型描述
[].topicString主题,与 topics 至少指定其中之一
[].topicsString, 分割的多个主题,使用此字段能够同时订阅多个主题
[].clientidStringclientid
[].qosIntegerQoS 等级

# 响应消息

名称类型描述
codeInteger0
dataArray of Objects所有订阅信息
data[].clientidStringclientid
data[].topicString订阅主题
data[].codeInteger0

# 请求示例

$ curl -u app_id:app_secret -X POST {api}/mqtt/unsubscribe_batch
1
[
  {
    "topic": "a",
    "clientid": "emqx_c_1"
  }
]
1
2
3
4
5
6

# 响应示例

{
  "data": [
    {
      "topic": "a",
      "code": 0,
      "clientid": "emqx_c_1"
    }
  ],
  "code": 0
}
1
2
3
4
5
6
7
8
9
10