管理监控API (REST API)

REST API 访问URL地址:

Basic 认证

使用 REST API 必须携带 HTTP Basic 格式的认证(Authentication)信息。因此，需要使用 Dashboard 中来创建的 AppID 和 AppSecret 进行认证:

curl -v --basic -u <appid>:<appsecret> -k http://localhost:8080/api/v3/brokers

API 信息

API 定义:

GET api/v3/

请求示例:

GET api/v3/

返回数据:

{
  "code": 0,
  "data": [
    {
      "name": "list_clientid",
      "method": "GET",
      "path": "/auth_clientid",
      "descr": "List available clientid in the cluster"
    },
    {
      "name": "lookup_clientid",
      "method": "GET",
      "path": "/auth_clientid/:clientid",
      "descr": "Lookup clientid in the cluster"
    },
    {
      "name": "add_clientid",
      "method": "POST",
      "path": "/auth_clientid",
      "descr": "Add clientid in the cluster"
    },
    {
      "name": "update_clientid",
      "method": "PUT",
      "path": "/auth_clientid/:clientid",
      "descr": "Update clientid in the cluster"
    },
    {
      "name": "delete_clientid",
      "method": "DELETE",
      "path": "/auth_clientid/:clientid",
      "descr": "Delete clientid in the cluster"
    },
    {
      "name": "list_username",
      "method": "GET",
      "path": "/auth_username",
      "descr": "List available username in the cluster"
    },
    {
      "name": "lookup_username",
      "method": "GET",
      "path": "/auth_username/:username",
      "descr": "Lookup username in the cluster"
    },
    {
      "name": "add_username",
      "method": "POST",
      "path": "/auth_username",
      "descr": "Add username in the cluster"
    },
    {
      "name": "update_username",
      "method": "PUT",
      "path": "/auth_username/:username",
      "descr": "Update username in the cluster"
    },
    {
      "name": "delete_username",
      "method": "DELETE",
      "path": "/auth_username/:username",
      "descr": "Delete username in the cluster"
    },
    {
      "name": "auth_user",
      "method": "POST",
      "path": "/auth",
      "descr": "Authenticate an user"
    },
    {
      "name": "create_user",
      "method": "POST",
      "path": "/users/",
      "descr": "Create an user"
    },
    {
      "name": "list_users",
      "method": "GET",
      "path": "/users/",
      "descr": "List users"
    },
    {
      "name": "update_user",
      "method": "PUT",
      "path": "/users/:name",
      "descr": "Update an user"
    },
    {
      "name": "delete_user",
      "method": "DELETE",
      "path": "/users/:name",
      "descr": "Delete an user"
    },
    {
      "name": "change_pwd",
      "method": "PUT",
      "path": "/change_pwd/:username",
      "descr": "Change password for an user"
    },
    {
      "name": "list_all_alarms",
      "method": "GET",
      "path": "/alarms/present",
      "descr": "List all alarms"
    },
    {
      "name": "list_node_alarms",
      "method": "GET",
      "path": "/alarms/present/:node",
      "descr": "List alarms of a node"
    },
    {
      "name": "list_all_alarm_history",
      "method": "GET",
      "path": "/alarms/history",
      "descr": "List all alarm history"
    },
    {
      "name": "list_node_alarm_history",
      "method": "GET",
      "path": "/alarms/history/:node",
      "descr": "List alarm history of a node"
    },
    {
      "name": "add_app",
      "method": "POST",
      "path": "/apps/",
      "descr": "Add Application"
    },
    {
      "name": "del_app",
      "method": "DELETE",
      "path": "/apps/:appid",
      "descr": "Delete Application"
    },
    {
      "name": "list_apps",
      "method": "GET",
      "path": "/apps/",
      "descr": "List Applications"
    },
    {
      "name": "lookup_app",
      "method": "GET",
      "path": "/apps/:appid",
      "descr": "Lookup Application"
    },
    {
      "name": "update_app",
      "method": "PUT",
      "path": "/apps/:appid",
      "descr": "Update Application"
    },
    {
      "name": "list_banned",
      "method": "GET",
      "path": "/banned/",
      "descr": "List banned"
    },
    {
      "name": "create_banned",
      "method": "POST",
      "path": "/banned/",
      "descr": "Create banned"
    },
    {
      "name": "delete_banned",
      "method": "DELETE",
      "path": "/banned/:who",
      "descr": "Delete banned"
    },
    {
      "name": "list_brokers",
      "method": "GET",
      "path": "/brokers/",
      "descr": "A list of brokers in the cluster"
    },
    {
      "name": "get_broker",
      "method": "GET",
      "path": "/brokers/:node",
      "descr": "Get broker info of a node"
    },
    {
      "name": "get_all_configs",
      "method": "GET",
      "path": "/configs/",
      "descr": "Get all configs"
    },
    {
      "name": "get_all_configs",
      "method": "GET",
      "path": "/nodes/:node/configs/",
      "descr": "Get all configs of a node"
    },
    {
      "name": "update_config",
      "method": "PUT",
      "path": "/configs/:app",
      "descr": "Update config of an application in the cluster"
    },
    {
      "name": "update_node_config",
      "method": "PUT",
      "path": "/nodes/:node/configs/:app",
      "descr": "Update config of an application on a node"
    },
    {
      "name": "get_plugin_configs",
      "method": "GET",
      "path": "/nodes/:node/plugin_configs/:plugin",
      "descr": "Get configurations of a plugin on the node"
    },
    {
      "name": "update_plugin_configs",
      "method": "PUT",
      "path": "/nodes/:node/plugin_configs/:plugin",
      "descr": "Update configurations of a plugin on the node"
    },
    {
      "name": "list_connections",
      "method": "GET",
      "path": "/connections/",
      "descr": "A list of connections in the cluster"
    },
    {
      "name": "list_node_connections",
      "method": "GET",
      "path": "nodes/:node/connections/",
      "descr": "A list of connections on a node"
    },
    {
      "name": "lookup_node_connections",
      "method": "GET",
      "path": "nodes/:node/connections/:clientid",
      "descr": "Lookup a connection on node"
    },
    {
      "name": "lookup_connections",
      "method": "GET",
      "path": "/connections/:clientid",
      "descr": "Lookup a connection in the cluster"
    },
    {
      "name": "lookup_node_connection_via_username",
      "method": "GET",
      "path": "/nodes/:node/connection/username/:username",
      "descr": "Lookup a connection via username in the cluster "
    },
    {
      "name": "lookup_connection_via_username",
      "method": "GET",
      "path": "/connection/username/:username",
      "descr": "Lookup a connection via username on a node "
    },
    {
      "name": "kickout_connection",
      "method": "DELETE",
      "path": "/connections/:clientid",
      "descr": "Kick out a connection"
    },
    {
      "name": "list_listeners",
      "method": "GET",
      "path": "/listeners/",
      "descr": "A list of listeners in the cluster"
    },
    {
      "name": "list_node_listeners",
      "method": "GET",
      "path": "/nodes/:node/listeners",
      "descr": "A list of listeners on the node"
    },
    {
      "name": "list_all_metrics",
      "method": "GET",
      "path": "/metrics/",
      "descr": "A list of metrics of all nodes in the cluster"
    },
    {
      "name": "list_node_metrics",
      "method": "GET",
      "path": "/nodes/:node/metrics/",
      "descr": "A list of metrics of a node"
    },
    {
      "name": "list_nodes",
      "method": "GET",
      "path": "/nodes/",
      "descr": "A list of nodes in the cluster"
    },
    {
      "name": "get_node",
      "method": "GET",
      "path": "/nodes/:node",
      "descr": "Lookup a node in the cluster"
    },
    {
      "name": "list_all_plugins",
      "method": "GET",
      "path": "/plugins/",
      "descr": "List all plugins in the cluster"
    },
    {
      "name": "list_node_plugins",
      "method": "GET",
      "path": "/nodes/:node/plugins/",
      "descr": "List all plugins on a node"
    },
    {
      "name": "load_plugin",
      "method": "PUT",
      "path": "/nodes/:node/plugins/:plugin/load",
      "descr": "Load a plugin"
    },
    {
      "name": "unload_plugin",
      "method": "PUT",
      "path": "/nodes/:node/plugins/:plugin/unload",
      "descr": "Unload a plugin"
    },
    {
      "name": "reload_plugin",
      "method": "PUT",
      "path": "/nodes/:node/plugins/:plugin/reload",
      "descr": "Reload a plugin"
    },
    {
      "name": "mqtt_subscribe",
      "method": "POST",
      "path": "/mqtt/subscribe",
      "descr": "Subscribe a topic"
    },
    {
      "name": "mqtt_publish",
      "method": "POST",
      "path": "/mqtt/publish",
      "descr": "Publish a MQTT message"
    },
    {
      "name": "mqtt_unsubscribe",
      "method": "POST",
      "path": "/mqtt/unsubscribe",
      "descr": "Unsubscribe a topic"
    },
    {
      "name": "list_routes",
      "method": "GET",
      "path": "/routes/",
      "descr": "List routes"
    },
    {
      "name": "lookup_routes",
      "method": "GET",
      "path": "/routes/:topic",
      "descr": "Lookup routes to a topic"
    },
    {
      "name": "list_sessions",
      "method": "GET",
      "path": "/sessions/",
      "descr": "A list of sessions in the cluster"
    },
    {
      "name": "list_node_sessions",
      "method": "GET",
      "path": "nodes/:node/sessions/",
      "descr": "A list of sessions on a node"
    },
    {
      "name": "lookup_session",
      "method": "GET",
      "path": "/sessions/:clientid",
      "descr": "Lookup a session in the cluster"
    },
    {
      "name": "lookup_node_session",
      "method": "GET",
      "path": "nodes/:node/sessions/:clientid",
      "descr": "Lookup a session on the node"
    },
    {
      "name": "clean_presisent_session",
      "method": "DELETE",
      "path": "/sessions/persistent/:clientid",
      "descr": "Clean a persistent session in the cluster"
    },
    {
      "name": "clean_node_presisent_session",
      "method": "DELETE",
      "path": "nodes/:node/sessions/persistent/:clientid",
      "descr": "Clean a persistent session on the node"
    },
    {
      "name": "list_stats",
      "method": "GET",
      "path": "/stats/",
      "descr": "A list of stats of all nodes in the cluster"
    },
    {
      "name": "lookup_node_stats",
      "method": "GET",
      "path": "/nodes/:node/stats/",
      "descr": "A list of stats of a node"
    },
    {
      "name": "list_subscriptions",
      "method": "GET",
      "path": "/subscriptions/",
      "descr": "A list of subscriptions in the cluster"
    },
    {
      "name": "list_node_subscriptions",
      "method": "GET",
      "path": "/nodes/:node/subscriptions/",
      "descr": "A list of subscriptions on a node"
    },
    {
      "name": "lookup_client_subscriptions",
      "method": "GET",
      "path": "/subscriptions/:clientid",
      "descr": "A list of subscriptions of a client"
    },
    {
      "name": "lookup_client_subscriptions_with_node",
      "method": "GET",
      "path": "/nodes/:node/subscriptions/:clientid",
      "descr": "A list of subscriptions of a client on the node"
    },
    {
      "name": "create_rule",
      "method": "POST",
      "path": "/rules/",
      "descr": "Create a rule"
    },
    {
      "name": "list_rules",
      "method": "GET",
      "path": "/rules/",
      "descr": "A list of all rules"
    },
    {
      "name": "show_rule",
      "method": "GET",
      "path": "/rules/:id",
      "descr": "Show a rule"
    },
    {
      "name": "delete_rule",
      "method": "DELETE",
      "path": "/rules/:id",
      "descr": "Delete a rule"
    },
    {
      "name": "list_actions",
      "method": "GET",
      "path": "/actions/",
      "descr": "A list of all actions"
    },
    {
      "name": "show_action",
      "method": "GET",
      "path": "/actions/:name",
      "descr": "Show an action"
    },
    {
      "name": "list_resources",
      "method": "GET",
      "path": "/resources/",
      "descr": "A list of all resources"
    },
    {
      "name": "create_resource",
      "method": "POST",
      "path": "/resources/",
      "descr": "Create a resource"
    },
    {
      "name": "show_resource",
      "method": "GET",
      "path": "/resources/:id",
      "descr": "Show a resource"
    },
    {
      "name": "get_resource_status",
      "method": "GET",
      "path": "/resource_status/:id",
      "descr": "Get status of a resource"
    },
    {
      "name": "start_resource",
      "method": "POST",
      "path": "/resources/:id",
      "descr": "Start a resource"
    },
    {
      "name": "delete_resource",
      "method": "DELETE",
      "path": "/resources/:id",
      "descr": "Delete a resource"
    },
    {
      "name": "list_resource_types",
      "method": "GET",
      "path": "/resource_types/",
      "descr": "List all resource types"
    },
    {
      "name": "show_resource_type",
      "method": "GET",
      "path": "/resource_types/:name",
      "descr": "Show a resource type"
    },
    {
      "name": "list_resources_by_type",
      "method": "GET",
      "path": "/resource_types/:type/resources",
      "descr": "List all resources of a resource type"
    },
    {
      "name": "list_events",
      "method": "GET",
      "path": "/rule_events/",
      "descr": "List all events with detailed info"
    }
  ]
}

集群与节点

获取集群基本信息

API 定义:

GET api/v3/brokers/

请求示例:

GET api/v3/brokers/

返回数据:

{
  "code": 0,
  "data": [
    {
      "datetime": "2019-04-29 10:56:41",
      "node": "emqx@127.0.0.1",
      "node_status": "Running",
      "otp_release": "R21/10.3.2",
      "sysdescr": "EMQ X Broker",
      "uptime": "3 minutes, 59 seconds",
      "version": "v3.1.0"
    }
  ]
}

获取节点基本信息

API 定义:

GET api/v3/brokers/${node}

请求示例:

GET api/v3/brokers/emqx@127.0.0.1

返回数据:

{
  "code": 0,
  "data": {
    "datetime": "2019-04-29 10:59:59",
    "node_status": "Running",
    "otp_release": "R21/10.3.2",
    "sysdescr": "EMQ X Broker",
    "uptime": "7 minutes, 16 seconds",
    "version": "v3.1.0"
  }
}

获取集群监控数据

API 定义:

GET api/v3/nodes/

请求示例:

GET api/v3/nodes/

返回数据:

{
  "code": 0,
  "data": [
    {
      "connections": 2,
      "load1": "2.75",
      "load15": "2.87",
      "load5": "2.57",
      "max_fds": 7168,
      "memory_total": "76.45M",
      "memory_used": "59.48M",
      "name": "emqx@127.0.0.1",
      "node": "emqx@127.0.0.1",
      "node_status": "Running",
      "otp_release": "R21/10.3.2",
      "process_available": 262144,
      "process_used": 331,
      "uptime": "1 days,18 hours, 45 minutes, 1 seconds",
      "version": "v3.1.0"
    }
  ]
}

获取节点监控数据

API 定义:

GET api/v3/nodes/${node}

请求示例:

GET api/v3/nodes/emqx@127.0.0.1

返回数据:

{
  "code": 0,
  "data": {
    "connections": 1,
    "load1": "2.75",
    "load15": "2.87",
    "load5": "2.57",
    "max_fds": 7168,
    "memory_total": 80162816,
    "memory_used": 62254160,
    "name": "emqx@127.0.0.1",
    "node_status": "Running",
    "otp_release": "R21/10.3.2",
    "process_available": 262144,
    "process_used": 331,
    "uptime": "1 days,18 hours, 45 minutes, 1 seconds",
    "version": "v3.1.0"
  }
}

连接信息(Connections)

获取集群连接信息

API 定义:

GET api/v3/connections/

请求示例:

GET api/v3/connections/?_page=1&_limit=10000

返回数据:

{
  "code": 0,
  "data": [
    {
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "conn_mod": "emqx_connection",
      "connected_at": "2019-04-29 11:05:01",
      "heap_size": 2586,
      "ipaddress": "127.0.0.1",
      "is_bridge": false,
      "keepalive": 60,
      "mailbox_len": 0,
      "node": "emqx@127.0.0.1",
      "peercert": "nossl",
      "port": 64899,
      "proto_name": "MQIsdp",
      "proto_ver": 3,
      "recv_cnt": 2,
      "recv_msg": 0,
      "recv_oct": 47,
      "recv_pkt": 2,
      "reductions": 3588,
      "send_cnt": 2,
      "send_msg": 0,
      "send_oct": 9,
      "send_pend": 0,
      "send_pkt": 2,
      "username": "undefined",
      "zone": "external"
    }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 1
  }
}

获取节点连接信息

API 定义:

GET api/v3/nodes/${node}/connections/

请求示例:

GET api/v3/nodes/emqx@127.0.0.1/connections/?_page=1&_limit=10000

返回数据:

{
  "code": 0,
  "data": [
   {
     "client_id": "mosquitto_mqtt",
     "conn_mod": "emqx_connection",
     "connected_at": "2019-04-29 11:05:01",
     "heap_size": 610,
     "ipaddress": "127.0.0.1",
     "is_bridge": false,
     "keepalive": 60,
     "mailbox_len": 0,
     "node": "emqx@127.0.0.1",
     "peercert": "nossl",
     "port": 64899,
     "proto_name": "MQIsdp",
     "proto_ver": 3,
     "recv_cnt": 5,
     "recv_msg": 0,
     "recv_oct": 53,
     "recv_pkt": 5,
     "reductions": 6081,
     "send_cnt": 5,
     "send_msg": 0,
     "send_oct": 15,
     "send_pend": 0,
     "send_pkt": 5,
     "username": "undefined",
     "zone": "external"
   }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 1
  }
}

获取集群指定连接信息

API 定义:

GET api/v3/connections/${clientid}

请求示例:

GET api/v3/connections/mosquitto_mqtt

返回数据:

{
  "code": 0,
  "data": [
    {
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "conn_mod": "emqx_connection",
      "connected_at": "2019-04-29 11:05:01",
      "heap_size": 610,
      "ipaddress": "127.0.0.1",
      "is_bridge": false,
      "keepalive": 60,
      "mailbox_len": 0,
      "peercert": "nossl",
      "port": 64899,
      "proto_name": "MQIsdp",
      "proto_ver": 3,
      "recv_cnt": 8,
      "recv_msg": 0,
      "recv_oct": 59,
      "recv_pkt": 8,
      "reductions": 8560,
      "send_cnt": 8,
      "send_msg": 0,
      "send_oct": 21,
      "send_pend": 0,
      "send_pkt": 8,
      "username": "undefined",
      "zone": "external"
    }
  ]
}

获取节点指定连接信息

API 定义:

GET api/v3/nodes/${node}/connections/${clientid}

请求示例:

GET api/v3/nodes/emqx@127.0.0.1/connections/mosquitto_mqtt

返回数据:

{
  "code": 0,
  "data": [
    {
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "conn_mod": "emqx_connection",
      "connected_at": "2019-04-29 11:05:01",
      "heap_size": 610,
      "ipaddress": "127.0.0.1",
      "is_bridge": false,
      "keepalive": 60,
      "mailbox_len": 0,
      "node": "emqx@127.0.0.1",
      "peercert": "nossl",
      "port": 64899,
      "proto_name": "MQIsdp",
      "proto_ver": 3,
      "recv_cnt": 14,
      "recv_msg": 0,
      "recv_oct": 71,
      "recv_pkt": 14,
      "reductions": 13534,
      "send_cnt": 14,
      "send_msg": 0,
      "send_oct": 33,
      "send_pend": 0,
      "send_pkt": 14,
      "username": "undefined",
      "zone": "external"
    }
  ]
}

断开指定连接

API 定义:

DELETE api/v3/connections/${clientid}

请求示例:

DELETE api/v3/connections/mosquitto_mqtt

返回数据:

{
  "code": 0
}

获取集群会话信息

API 定义:

GET api/v3/sessions/

请求示例:

GET api/v3/sessions/?_page=1&_limit=10000

返回数据:

{
  "code": 0,
  "data": [
    {
      "awaiting_rel_len": 0,
      "binding": "local",
      "clean_start": true,
      "client_id": "mqttjs_f79fbc5a4b",
      "created_at": "2019-04-29 11:28:04",
      "deliver_msg": 0,
      "enqueue_msg": 0,
      "expiry_interval": 0,
      "heap_size": 233,
      "inflight_len": 0,
      "mailbox_len": 0,
      "max_awaiting_rel": 100,
      "max_inflight": 32,
      "max_mqueue": 1000,
      "max_subscriptions": 0,
      "mqueue_dropped": 0,
      "mqueue_len": 0,
      "node": "emqx@127.0.0.1",
      "reductions": 211,
      "subscriptions_count": 0,
      "username": ""
    },
    {
      "awaiting_rel_len": 0,
      "binding": "local",
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "created_at": "2019-04-29 11:28:28",
      "deliver_msg": 0,
      "enqueue_msg": 0,
      "expiry_interval": 0,
      "heap_size": 376,
      "inflight_len": 0,
      "mailbox_len": 0,
      "max_awaiting_rel": 100,
      "max_inflight": 32,
      "max_mqueue": 1000,
      "max_subscriptions": 0,
      "mqueue_dropped": 0,
      "mqueue_len": 0,
      "node": "emqx@127.0.0.1",
      "reductions": 202,
      "subscriptions_count": 0,
      "username": "undefined"
    }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 2
  }
}

获取集群指定会话信息

API 定义:

GET api/v3/sessions/${clientid}

请求示例:

GET api/v3/sessions/mosquitto_mqtt

返回数据:

{
  "code": 0,
  "data": [
    {
      "awaiting_rel_len": 0,
      "binding": "local",
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "created_at": "2019-04-29 11:28:28",
      "deliver_msg": 0,
      "enqueue_msg": 0,
      "expiry_interval": 0,
      "heap_size": 376,
      "inflight_len": 0,
      "mailbox_len": 0,
      "max_awaiting_rel": 100,
      "max_inflight": 32,
      "max_mqueue": 1000,
      "max_subscriptions": 0,
      "mqueue_dropped": 0,
      "mqueue_len": 0,
      "node": "emqx@127.0.0.1",
      "reductions": 453,
      "subscriptions_count": 1,
      "username": "undefined"
    }
  ]
}

获取节点会话信息

API 定义:

GET api/v3/nodes/${node}/sessions/

请求示例:

GET api/v3/nodes/emqx@127.0.0.1/sessions/?_page=1&_limit=10000

返回数据:

{
  "code": 0,
  "data": [
    {
      "awaiting_rel_len": 0,
      "binding": "local",
      "clean_start": true,
      "client_id": "mqttjs_f79fbc5a4b",
      "created_at": "2019-04-29 11:28:04",
      "deliver_msg": 0,
      "enqueue_msg": 0,
      "expiry_interval": 0,
      "heap_size": 233,
      "inflight_len": 0,
      "mailbox_len": 0,
      "max_awaiting_rel": 100,
      "max_inflight": 32,
      "max_mqueue": 1000,
      "max_subscriptions": 0,
      "mqueue_dropped": 0,
      "mqueue_len": 0,
      "node": "emqx@127.0.0.1",
      "reductions": 211,
      "subscriptions_count": 0,
      "username": ""
    },
    {
      "awaiting_rel_len": 0,
      "binding": "local",
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "created_at": "2019-04-29 11:28:28",
      "deliver_msg": 0,
      "enqueue_msg": 0,
      "expiry_interval": 0,
      "heap_size": 376,
      "inflight_len": 0,
      "mailbox_len": 0,
      "max_awaiting_rel": 100,
      "max_inflight": 32,
      "max_mqueue": 1000,
      "max_subscriptions": 0,
      "mqueue_dropped": 0,
      "mqueue_len": 0,
      "node": "emqx@127.0.0.1",
      "reductions": 453,
      "subscriptions_count": 1,
      "username": "undefined"
    }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 2
  }
}

获取节点指定会话信息

API 定义:

GET api/v3/nodes/${node}/sessions/${clientid}

请求示例:

GET api/v3/nodes/emqx@127.0.0.1/sessions/mosquitto_mqtt

请求参数:

{
  "topic": "test_topic",
  "payload": "hello",
  "qos": 1,
  "retain": false,
  "client_id": "mqttjs_ab9069449e"
}

返回数据:

{
  "code": 0,
  "data": [
    {
      "awaiting_rel_len": 0,
      "binding": "local",
      "clean_start": true,
      "client_id": "mosquitto_mqtt",
      "created_at": "2018-09-12 10:42:57",
      "deliver_msg": 0,
      "enqueue_msg": 0,
      "expiry_interval": 7200,
      "heap_size": 376,
      "inflight_len": 0,
      "mailbox_len": 0,
      "max_awaiting_rel": 100,
      "max_inflight": 32,
      "max_mqueue": 1000,
      "max_subscriptions": 0,
      "mqueue_dropped": 0,
      "mqueue_len": 0,
      "node": "emqx@127.0.0.1",
      "reductions": 203,
      "subscriptions_count": 0,
      "username": "mosquitto_mqtt"
    }
  ]
}

订阅(Subscriptions)

获取集群订阅信息

API 定义:

GET api/v3/subscriptions/

请求示例:

GET api/v3/subscriptions/?_page=1&_limit=10000

返回数据:

{
  "code": 0,
  "data": [
    {
      "client_id": "mqttjs_f79fbc5a4b",
      "node": "emqx@127.0.0.1",
      "qos": 0,
      "topic": "testtopic/#"
    },
    {
      "client_id": "mosquitto_mqtt",
      "node": "emqx@127.0.0.1",
      "qos": 0,
      "topic": "t"
    }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 2
  }
}

获取集群指定连接订阅信息

API 定义:

GET api/v3/subscriptions/${clientid}

请求示例:

GET api/v3/subscriptions/mosquitto_mqtt

返回数据:

{
  "code": 0,
  "data": [
    {
      "client_id": "mosquitto_mqtt",
      "node": "emqx@127.0.0.1",
      "qos": 0,
      "topic": "t"
    }
  ]
}

获取节点订阅信息

API 定义:

GET api/v3/nodes/${node}/subscriptions/

请求示例:

GET api/v3/nodes/emqx@127.0.0.1/subscriptions/?_page=1&_limit=10000

返回数据:

{
  "code": 0,
  "data": [
    {
      "client_id": "mqttjs_f79fbc5a4b",
      "node": "emqx@127.0.0.1",
      "qos": 0,
      "topic": "testtopic/#"
    },
    {
      "client_id": "mosquitto_mqtt",
      "node": "emqx@127.0.0.1",
      "qos": 0,
      "topic": "t"
    }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 2
  }
}

获取节点指定连接订阅信息

API 定义:

GET api/v3/nodes/${node}/subscriptions/${clientid}

请求示例:

GET api/v3/nodes/emqx@127.0.0.1/subscriptions/mosquitto_mqtt

返回数据:

{
  "code": 0,
  "data": [
    {
      "client_id": "mosquitto_mqtt",
      "node": "emqx@127.0.0.1",
      "qos": 0,
      "topic": "t"
    }
  ]
}

路由(Routes)

API 定义:

请求示例:

GET api/v3/routes/

返回数据:

{
  "code": 0,
  "data": [
    {
      "node": "emqx@127.0.0.1",
      "topic": "testtopic/#"
    },
    {
      "node": "emqx@127.0.0.1",
      "topic": "t"
    }
  ],
  "meta": {
    "page": 1,
    "limit": 10000,
    "count": 2
  }
}

获取集群指定主题的路由信息

API 定义:

GET api/v3/routes/${topic}

请求示例:

GET api/v3/routes/t

返回数据:

{
  "code": 0,
  "data": [
    {
      "node": "emqx@127.0.0.1",
      "topic": "t"
    }
  ]
}

发布/订阅/取消订阅

发布消息

API 定义:

POST api/v3/mqtt/publish

{
  "topic": "test_topic",
  "payload": "hello",
  "qos": 1,
  "retain": false,
  "client_id": "mqttjs_ab9069449e"
}

请求示例:

POST api/v3/mqtt/publish

返回数据:

{
  "code": 0
}

创建订阅

API 定义:

POST api/v3/mqtt/subscribe

请求参数:

{
  "topic": "test_topic",
  "qos": 1,
  "client_id": "mqttjs_ab9069449e"
}

请求示例:

POST api/v3/mqtt/subscribe

返回数据:

{
  "code": 0
}

取消订阅

API 定义:

POST api/v3/mqtt/unsubscribe

请求参数:

{
  "topic": "test_topic",
  "client_id": "mqttjs_ab9069449e"
}

请求示例:

POST api/v3/mqtt/unsubscribe

返回数据:

{
  "code": 0
}

插件(Plugins)

获取所有节点插件列表

API 定义:

GET api/v3/plugins/

请求示例:

GET api/v3/plugins/

返回数据:

{
  "code": 0,
  "data": [
    {
      "node": "emqx@127.0.0.1",
      "plugins": [
        {
          "name": "emqx_auth_clientid",
          "version": "v3.1.0",
          "description": "EMQ X Authentication with ClientId/Password",
          "active": false
        },
        {
          "name": "emqx_auth_http",
          "version": "v3.1.0",
          "description": "EMQ X Authentication/ACL with HTTP API",
          "active": false
        },
        {
          "name": "emqx_auth_jwt",
          "version": "v3.1.0",
          "description": "EMQ X Authentication with JWT",
          "active": false
        },
        {
          "name": "emqx_auth_ldap",
          "version": "v3.1.0",
          "description": "EMQ X Authentication/ACL with LDAP",
          "active": false
        },
        {
          "name": "emqx_auth_mongo",
          "version": "v3.1.0",
          "description": "EMQ X Authentication/ACL with MongoDB",
          "active": false
        },
        {
          "name": "emqx_auth_mysql",
          "version": "v3.1.0",
          "description": "EMQ X Authentication/ACL with MySQL",
          "active": false
        },
        {
          "name": "emqx_auth_pgsql",
          "version": "v3.1.0",
          "description": "EMQ X Authentication/ACL with PostgreSQL",
          "active": false
        },
        {
          "name": "emqx_auth_redis",
          "version": "v3.1.0",
          "description": "EMQ X Authentication/ACL with Redis",
          "active": false
        },
        {
          "name": "emqx_auth_username",
          "version": "v3.1.0",
          "description": "EMQ X Authentication with Username and Password",
          "active": false
        },
        {
          "name": "emqx_coap",
          "version": "v3.1.0",
          "description": "EMQ X CoAP Gateway",
          "active": false
        },
        {
          "name": "emqx_dashboard",
          "version": "v3.1.0",
          "description": "EMQ X Web Dashboard",
          "active": true
        },
        {
          "name": "emqx_delayed_publish",
          "version": "v3.1.0",
          "description": "EMQ X Delayed Publish",
          "active": false
        },
        {
          "name": "emqx_lua_hook",
          "version": "v3.1.0",
          "description": "EMQ X Lua Hooks",
          "active": false
        },
        {
          "name": "emqx_lwm2m",
          "version": "v3.1.0",
          "description": "EMQ X LwM2M Gateway",
          "active": false
        },
        {
          "name": "emqx_management",
          "version": "v3.1.0",
          "description": "EMQ X Management API and CLI",
          "active": true
        },
        {
          "name": "emqx_plugin_template",
          "version": "v3.1.0",
          "description": "EMQ X Plugin Template",
          "active": false
        },
        {
          "name": "emqx_psk_file",
          "version": "v3.1.0",
          "description": "EMQX PSK Plugin from File",
          "active": false
        },
        {
          "name": "emqx_recon",
          "version": "v3.1.0",
          "description": "EMQ X Recon Plugin",
          "active": true
        },
        {
          "name": "emqx_reloader",
          "version": "v3.1.0",
          "description": "EMQ X Reloader Plugin",
          "active": false
        },
        {
          "name": "emqx_retainer",
          "version": "v3.1.0",
          "description": "EMQ X Retainer",
          "active": true
        },
        {
          "name": "emqx_rule_engine",
          "version": "v3.1.0",
          "description": "EMQ X Rule Engine",
          "active": true
        },
        {
          "name": "emqx_sn",
          "version": "v3.1.0",
          "description": "EMQ X MQTT SN Plugin",
          "active": false
        },
        {
          "name": "emqx_statsd",
          "version": "v3.1.0",
          "description": "Statsd for EMQ X",
          "active": false
        },
        {
          "name": "emqx_stomp",
          "version": "v3.1.0",
          "description": "EMQ X Stomp Protocol Plugin",
          "active": false
        },
        {
          "name": "emqx_web_hook",
          "version": "v3.1.0",
          "description": "EMQ X Webhook Plugin",
          "active": false
        }
      ]
    }
  ]
}