emqtt 试用(三)mqtt 知识 一、概念 二、发布订阅模式 三、客户端监听设置

emqtt 试用(三)mqtt 知识
一、概念
二、发布订阅模式
三、客户端监听设置

MQTT 协议客户端库: https://github.com/mqtt/mqtt.github.io/wiki/libraries

 例如,mosquitto_sub/pub 命令行发布订阅消息:

mosquitto_sub -t topic -q 2
mosquitto_pub -t topic -q 1 -m "Hello, MQTT!"

MQTT V3.1.1 版本协议规范: http://docs.oasis-open.org/mqtt/mqtt/v3.1.1/mqtt-v3.1.1.html

二、发布订阅模式

emqtt 试用(三)mqtt 知识
一、概念
二、发布订阅模式
三、客户端监听设置

三、客户端监听设置

emqtt 试用(三)mqtt 知识
一、概念
二、发布订阅模式
三、客户端监听设置

HTTP 发布接口

EMQ 消息服务器提供了一个 HTTP 发布接口,应用服务器或 Web 服务器可通过该接口发布 MQTT 消息:

HTTP POST http://host:8080/mqtt/publish

Web 服务器例如 PHP/Java/Python/NodeJS 或 Ruby on Rails,可通过 HTTP POST 请求发布 MQTT 消息:

curl -v --basic -u user:passwd -d "qos=1&retain=0&topic=/a/b/c&message=hello from http..." -k http://localhost:8080/mqtt/publish

HTTP 接口参数:

参数 说明
client MQTT 客户端 ID
qos QoS: 0 | 1 | 2
retain Retain: 0 | 1
topic 主题(Topic)
message 消息

注解

HTTP 发布接口采用 Basic 认证

注解

该接口在 v2.3-beta.2 版本变更为: ‘api/v2/mqtt/publish’, 详见文档: 管理监控API (REST API)

MQTT WebSocket 连接

EMQ 消息服务器支持 MQTT WebSocket 连接,Web 浏览器可直接通过 MQTT 协议连接服务器:

WebSocket URI: ws(s)://host:8083/mqtt
Sec-WebSocket-Protocol: ‘mqttv3.1’ or ‘mqttv3.1.1’

Dashboard 插件提供了一个 MQTT WebSocket 连接的测试页面:

http://127.0.0.1:18083/websocket.html

EMQ 通过内嵌的 HTTP 服务器,实现 MQTT/WebSocket,etc/emq.conf 设置:

## MQTT/WebSocket Listener
listener.ws.external = 8083
listener.ws.external.acceptors = 4
listener.ws.external.max_clients = 64