通过 Hub 服务将设备接入 Baetyl

声明

  • 本文测试所用设备系统为 Ubuntu 18.04
  • 模拟 MQTT Client 行为的客户端为 MQTT.fx 和 MQTTBox,其中 MQTT.fx 用于 TCP 和 SSL 连接方式的测试,MQTTBox 用于 WS(Websocket)连接方式的测试。Baetyl Hub 服务的完整的配置参考 Hub 服务配置

提示:Darwin 系统可以通过源码安装 Baetyl,可参考 源码安装 Baetyl

操作流程

  • 步骤一:安装 Baetyl,并导入示例配置包。参考 快速安装 Baetyl 进行操作;
  • 步骤二:依据测试需求修改导入的配置信息,执行 sudo systemctl start baetyl 以容器模式启动 Baetyl,然后执行 sudo systemctl status baetyl 来查看 Baetyl 是否正常运行。如果 Baetyl 已经启动,执行 sudo systemctl start baetyl 重启来加载新的配置。
  • 步骤三:依据选定的连接测试方式,对 MQTT Client 作相应配置;
    • 若采用 TCP 连接,则仅需配置用户名、密码(参见配置文件 principals 配置项 usernamepassword),并选定对应连接端口即可;
    • 若采用 SSL 证书认证,除选定所需的用户名外,还需选定 CA 证书以及由 CA 签发的客户端证书和私钥,依据对应的连接端口连接即可;
    • 若采用 WS 连接,与 TCP 连接配置一样,仅需配置用户名、密码、相应端口即可;
  • 步骤四:若上述步骤一切正常,操作无误,即可通过 Baetyl 日志或 MQTT Client 查看连接状态。

连接测试

依据 步骤一 导入示例配置包后,确认一下应用配置和 Hub 服务的配置。

Baetyl 应用配置信息

如果采用官方的安装方式,将 Baetyl 应用配置替换成如下配置:

  1. # /usr/local/var/db/baetyl/application.yml
  2. version: v0
  3. services:
  4. - name: localhub
  5. image: hub.baidubce.com/baetyl/baetyl-hub
  6. replica: 1
  7. ports:
  8. - 1883:1883
  9. - 8883:8883
  10. - 8080:8080
  11. mounts:
  12. - name: localhub-conf
  13. path: etc/baetyl
  14. readonly: true
  15. - name: localhub-cert
  16. path: var/db/baetyl/cert
  17. readonly: true
  18. - name: localhub-data
  19. path: var/db/baetyl/data
  20. - name: localhub-log
  21. path: var/log/baetyl
  22. volumes:
  23. - name: localhub-conf
  24. path: var/db/baetyl/localhub-conf
  25. - name: localhub-data
  26. path: var/db/baetyl/localhub-data
  27. - name: localhub-cert
  28. path: var/db/baetyl/localhub-cert-only-for-test
  29. - name: localhub-log
  30. path: var/db/baetyl/localhub-log

Baetyl Hub 服务的配置替换成如下配置:

  1. # /usr/local/var/db/baetyl/localhub-conf/service.yml
  2. listen:
  3. - tcp://0.0.0.0:1883
  4. - ssl://0.0.0.0:8883
  5. - ws://0.0.0.0:8080/mqtt
  6. certificate:
  7. ca: var/db/baetyl/cert/ca.pem
  8. cert: var/db/baetyl/cert/server.pem
  9. key: var/db/baetyl/cert/server.key
  10. principals:
  11. - username: two-way-tls
  12. permissions:
  13. - action: 'pub'
  14. permit: ['tls/#']
  15. - action: 'sub'
  16. permit: ['tls/#']
  17. - username: test
  18. password: hahaha
  19. permissions:
  20. - action: 'pub'
  21. permit: ['#']
  22. - action: 'sub'
  23. permit: ['#']
  24. subscriptions:
  25. - source:
  26. topic: 't'
  27. target:
  28. topic: 't/topic'
  29. logger:
  30. path: var/log/baetyl/service.log
  31. level: 'debug'

容器模式需要端口映射,允许外部通过端口来访问容器,对应的配置项为应用配置中的 ports 字段。

如上所述,Hub 服务启动时会同时开启 1883、8883 以及 8080 端口,分别用作 TCP、SSL、WS(Websocket)等几种方式进行连接,下文将以 MQTTBox 和 MQTT.fx 作为 MQTT Client,测试他们分别在上述这几种连接方式下与 Baetyl 的连接情况,具体如下。

Baetyl 启动

依据 步骤二,执行 sudo systemctl start baetyl 以容器模式启动 Baetyl,如果 Baetyl 已经启动,执行 sudo systemctl restart baetyl 来重启。然后执行 sudo systemctl status baetyl 来查看 baetyl 是否正常运行。正常启动的情况如下图所示。

../_images/systemctl-status.pngBaetyl 状态

提示:Darwin 系统通过源码安装 Baetyl,可执行 sudo baetyl start 以容器模式启动 Baetyl。

查看 Baetyl 主程序的日志,执行 sudo tail -f /usr/local/var/log/baetyl/baetyl.log 显示如下:

../_images/master-start-log.pngBaetyl 启动

可以看到,Baetyl 正常启动后,Hub 服务镜像已被加载。另外,亦可以通过命令 docker ps 查看系统当前正在运行的容器。

../_images/docker-ps.png查看系统当前正在运行的容器

TCP 连接测试

启动 MQTT.fx 客户端,进入 Edit Connection Profiles 页面,填写 Profile Name,依据 Baetyl Hub 服务启动的地址及端口,填写 Broker Address 和 Broker Port ,再结合 principals 配置项中的连接信息配置 User Credentials 中的 User Name 和 Password ,然后点击 Apply 按钮,即可完成 TCP 连接模式下 MQTT.fx 的连接配置,具体如下图示。

../_images/mqttbox-tcp-connect-config.pngTCP 连接测试配置

然后关掉配置页面,选择刚才的 Profile Name 进行Connect,若连接配置信息与 Baetyl Hub 服务 principals 配置项中允许连接的权限信息匹配,即可看到连接成功的标志,具体如下图示。

../_images/mqttbox-tcp-connect-success.pngTCP 连接成功

SSL 连接测试

启动 MQTT.fx 客户端,进入 Edit Connection Profiles 页面,与 TCP 连接配置类似,填写相应的 Profile Name、Broker Address 和 Broker Port, 对于 SSL 连接方式,需填写 User Credentials 中的 User Name,同时配置 SSL 相关的设置,配置如图所示,然后点击 Apply 按钮,即可完成 SSL 连接模式下 MQTT.fx 的连接配置。

../_images/mqttbox-ssl-connect-config1.pngSSL 连接测试配置

../_images/mqttbox-ssl-connect-config2.pngSSL 连接测试配置

然后关掉配置页面,选择刚才的 Profile Name 进行 Connect,若连接配置信息与 Baetyl Hub 服务 principals 配置项中允许连接的权限信息匹配,即可看到连接成功的标志,具体如下图示。

../_images/mqttbox-ssl-connect-success.pngSSL 连接成功

WS(Websocket)连接测试

启动 MQTTBox 客户端,进入 Client 创建页面,选择连接使用的协议为 ws,依据 Baetyl Hub 服务启动的地址及端口,再结合 principals 配置项中用户名、密码进行配置,然后点击 Save 按钮,即可完成 WS 连接模式下 MQTTBox 的连接配置,具体如下图示。

../_images/mqttbox-ws-connect-config.pngWS(Websocket)连接测试配置

只要上述操作正确、无误,即可在 MQTTBox 看到与 Baetyl Hub 成功建立连接的标志,具体如下图示。

../_images/mqttbox-ws-connect-success.pngWS(Websocket)连接成功

综上,我们通过 MQTT.fx 和 MQTTBox 顺利完成了与 Baetyl Hub 服务的连接测试,除此之外,我们还可以通过 Paho-MQTT 自己编写测试脚本与 Baetyl Hub 连接,具体参见相关资源下载