创建用户名和密码
终端设备连接MQTT队列需要先创建用户密码。
1、 天翼云官网点击控制中心,选择产品分布式消息服务MQTT。
2、 登录分布式消息服务MQTT控制台,点击右上角地域选择对应资源池。
3、 进入实例列表,点击【管理】按钮进入管理菜单。
4、 进入认证授权菜单,点击【新增】按钮,在弹出框输入认证用户名、用户密码、确认密码等信息。
主题授权
对用户名进行主题授权,客户端方可正常收发。
1、 选择需要授权的用户,点击【授权】按钮。
2、 在弹出框填写已创建的主题名称,主题权限包含3种:pub、sub、pubsub,支持通配符,#代表所有主题。
绑定公网IP
公网接入若未绑定弹性公网ip需先进行购买弹性ip并进行绑定。
弹性IP是可以独立申请的公网 IP 地址,包括公网IP地址与公网出口带宽服务。可以与分布式消息服务MQTT动态绑定和解绑,实现云资源的互联网访问。针对需要公网访问分布式消息服务MQTT实例的需求,用户可开通弹性IP后,在MQTT实例页面进行绑定。
1、 进入实例列表,点击【管理】按钮进入管理菜单。
2、 在实例详情查看公网IP,点击【绑定】按钮,选择已购买的弹性IP。
- 弹性ip带宽大小计算规则可参照:带宽= 报文大小TPS120%,建议按120%购买,应对突发流程。如规格,报文大小1KB,TPS 2W/s,则带宽=2000010008=160Mb/s,建议200Mb/s。
终端接入
终端设备使用MQTT客户端通过终端连接地址接入。
1、 选择MQTT客户端库:选择适合终端设备的MQTT客户端库。不同的终端设备和操作系统可能需要不同的MQTT客户端库。例如,对于嵌入式设备,可以选择支持该设备平台的MQTT客户端库,如Paho MQTT库。
2、 配置MQTT客户端:在终端设备上,需要配置MQTT客户端以连接到指定的MQTT Broker。配置包括设置连接地址、端口、客户端ID、用户名和密码等信息。这些配置信息将用于建立与MQTT Broker的连接。
3、 建立连接:使用配置信息,MQTT客户端尝试连接到指定的MQTT Broker。一旦连接成功,终端设备就可以开始发布(Publish)和订阅(Subscribe)MQTT主题。
云端接入
云端应用使用KAFKA客户端通过服务端连接地址接入,支持SSL连接。