
グループで整理し、複数を開いたまま、接続状態がひと目でわかります。
接続ガイドProduction
factory-line-1@broker.emqx.io:8883
edge-gateway@192.168.1.20:1883
cloud-bridge@cloud.emqx.com:8883
Testing
local-dev@127.0.0.1:1883
+ New Subscription
sensors/room1/tempQoS 1
sensors/room1/humQoS 1
sensors/+/stateQoS 1
zsh · CLI
TCP、TLS、WebSocket に対応。双方向 TLS も。
別ウィンドウで 2 つのブローカーを並べて確認。
一度保存すれば --load-options で読み込めます。
送信は右、受信は左。サブスクリプションごとに色分け。
トピックフィルターごとに色を設定。
トピックやペイロードで検索し、その場でハイライト。
一定間隔で自動パブリッシュ。データを流し続けます。
接続・パブリッシュ・エラーをすべてログに記録。
形式はその場で切り替え。GZIP は展開してからデコード。
eyJ0ZW1wIjoyMy41LCJodW0iOjYxfQ=={
"temp": 23.5,
"hum": 61
}Plaintext、JSON、Base64、Hex、CBOR、MsgPack で送信・表示。
自分のスキーマでエンコード・デコード。
トピックツリー、グラフ、メッセージレート、差分をリアルタイムで。
{"temp":23.5}24 msgs{"hum":61}24 msgs{"temp":24.1}24 msgs{"speed":2}10 msgsJavaScript でメッセージを加工。アプリでも CLI でも。
カスタムスクリプト
送信時・受信時にペイロードを変換。
組み込みシナリオ
mqttx simulate に Tesla 車両などの IoT データを用意。
function handlePayload(value) {
const data = JSON.parse(value)
data.temp = +(data.temp * 1.8 + 32).toFixed(1)
data.unit = 'F'
return JSON.stringify(data, null, 2)
}
execute(handlePayload)入力
{"temp": 23.5, "hum": 61}出力
{"temp": 74.3, "hum": 61, "unit": "F"}どのシェルからでもパブリッシュ、サブスクライブ、ベンチマーク、シミュレーション。
mqttx sub -t 'sensors/#' -h broker.emqx.iomqttx sub
mqttx sub -t 'sensors/#' -h broker.emqx.io -v✔ Connected
{"hum":62}{"temp":23.7}{"temp":24.0}{"hum":63}{"temp":24.1}mqttx pub
mqttx pub -t 'sensors/room1/temp' -m '{"temp":24.1}' -h broker.emqx.io✔ Message published
やりたいことを言葉で伝えるだけ。Agent が MQTTX で実行し、各ステップが見えます。
broker.emqx.io に接続し、demo/# を購読してテストメッセージを発行して
MQTTX Agent が broker.emqx.io で demo/test に発行しようとしています
{ "temp": 23.5, "unit": "C" }MQTTX Web をオンラインで、または Docker でセルフホスト。
JSON、CSV、Excel、XML、YAML。
ライト、ダーク、ナイト。
英語、簡体字中国語、日本語、トルコ語、ハンガリー語、韓国語。