Stomp 协议网关
Stomp 协议网关为 EMQX 提供了 Stomp 协议的接入能力。
创建模块
打开 EMQX Dashboard,点击左侧的 “模块” 选项卡,选择添加:
点击 “选择”,然后选择 “Stomp 接入网关”:
配置相关基础参数:
添加监听端口:
配置监听参数:
点击 “确定” 完成监听器的配置,然后点击 “添加” 完成模块的创建:
配置参数
配置项 | 说明 |
---|---|
最大报文头部数量 | Stomp frame headers 的最大数量 |
最大报文头部长度 | Stomp frame headers 的最大长度 |
报文体最大长度 | Stomp frame body 的最大长度 |
允许匿名登录 | 是否允许匿名登录 |
默认用户名 | 指定 Stomp 模块登录使用的 Username |
默认密码 | 指定 Stomp 模块登录使用的 Password |
验证结果:
STOMP客户端示例:
具体使用教程:https://jasonrbriggs.github.io/stomp.py/quickstart.html
cd teststomp/bin ## 查看stomp可使用选项 ./stomp --help Usage: stomp [options] Options: --version Show the version number and exit -h, --help Show this help message and exit -H <host>, --host=<port> Hostname or IP address to connect to. [default: localhost] -P <port>, --port=<port> Port providing stomp protocol connections. [default: 61613] -U <user>, --user=<user> Username for the connection -W <password>, --password=<password> Password for the connection -F <filename>, --file=<filename> File containing commands to be executed, instead of prompting from the command prompt. -S <protocol version>, --protocol=<protocol version> Set the STOMP protocol version (1.0, 1.1, 1.2) [default: 1.1] -L <queue>, --listen=<queue> Listen for messages on a queue/destination -V, --verbose Verbose logging "on" or "off" (if on, full headers from stomp server responses are printed) --heartbeats=<heartbeats> Heartbeats to request when connecting with protocol >= 1.1 (two comma separated integers required) [default: 0,0] --ssl Enable SSL connection --ssl-key-file=<key-file> ssl key file --ssl-cert-file=<cert-file> ssl cert file --ssl-ca-file=<ca-file> ssl ca certs file ## 连接EMQX ./stomp -H 192.168.1.19 -P 6161 ## 订阅stomp/test主题 > subscribe stomp/test
## 通过stomp协议连接到EMQX的客户端向stomp/demo主题发送一条消息 > send stomp/demo hello EMQX!
通过MQTTX连接一个客户端到EMQX并订阅stomp/demo主题: