MQTT

WeEvent服务支持MQTT Broker功能。任何支持MQTT协议的IoT设备及客户端都能连接到WeEvent,并进行消息发布及订阅。

协议介绍

  • MQTT是物联网IoT中的主流接入协议，协议具体内容参见http://mqtt.org/ 。
  • WeEvent支持MQTT 3.1.1

配置MQTT服务

在Broker服务中，修改配置文件./conf/weevent.properties，然后重新启动服务。

  1. #mqtt brokerserver
  2. mqtt.broker.port=8091
  3. mqtt.broker.keepalive=60
  4. mqtt.websocket.path=/weevent/mqtt
  5. mqtt.websocket.port=8092
  6. mqtt.user.login=
  7. mqtt.user.passcode=

参数说明：

  • mqtt.broker.port

客户端使用MQTT协议访问MQTT Broker。

  • mqtt.broker.keepalive

发送心跳时间。单位为秒。

  • mqtt.websocket.path

客户端使用WebSocket协议访问MQTT Broker链接。

  • mqtt.websocket.port

客户端使用WebSocket协议访问MQTT Broker。

  • mqtt.user.login

mqtt访问用户名，为空则不校验用户名。

  • mqtt.user.passcode

mqtt访问用户密码，为空则不校验用户密码。

注意事项

  • 区块链必须确保消息成功上链，暂不支持QoS-0和QoS-2消息级别。
  • 不支持断连后会话恢复功能。

样例演示

样例演示需依赖Mosquitto客户端，请根据链接(https://mosquitto.org/download/)进行下载安装。更多客户端参见MQTT第三方库。

  • IoT设备发布事件

发送消息前需创建topic (com.weevent.test)。详情请参照创建Topic

  1. $ mosquitto_pub -h localhost -p 8081 -q 1 -t "com.weevent.test" -m "{\"timestamp\":133345566,\"key\":\"temperature\",\"value\":10.0}"
  • IoT设备订阅事件
  1. $ mosquitto_sub -h localhost -p 8081 -q 1 -t "com.weevent.test"
  2. {"eventId":"317e7c4c-1-24","extensions":{},"topic":"com.weevent.test","content":[123,34,116,105,109,101,115,116,97,109,112,34,58,49,51,51,51,52,53,53,54,54,44,34,107,101,121,34,58,34,116,101,109,112,101,114,97,116,117,114,101,34,44,34,118,97,108,117,101,34,58,49,48,46,48,125]}