阿里云mqtt服务（阿里云mqtt服务器 租用）
本文目录一览：
- 1、阿里云微消息队列（MQTT）的基本使用
- 2、阿里云mqtt收费标准
- 3、NE35E MQTT协议对接阿里云
- 4、在云服务器上搭建了mqtt，为什么手机连接不上mqtt，要怎么做才能连接上？求求大神帮忙
- 5、玩转 ESP32 + Arduino (十六) 通过mqtt协议连接阿里云
阿里云微消息队列（MQTT）的基本使用
最近应系统功能需求，采购了一款云喇叭的物联网设备，就是插着4G卡那种，可以播放各种语音，仔细阅读了开发文档之改粗后发现使用的是MQTT的协议，记录一下在对接中遇到的各种凯核问题
MQTT是一个轻量的发布订阅模式消息传输协议，专门针对低带宽和不稳核孙镇定网络环境的物联网应用设计。
MQTT特点：
阿里云的MQTT有两个版本，这里只说没有RocketMQ依赖的3.1.1及以上版本。
这里会自动生成用户名密码
阿里云mqtt收费标准
以下是阿里云mqtt收费标准：
其笑明中铂金版实例、标带升团准版实例、轻量版实例是包年包月（预付费）。是一种预付费模式，即先付费再使用。一般适用于业务量较大且长期运行的场景，通过包年包月付费方式您可以提前预留蠢橘资源，同时享受更大的价格优化，帮您最大程度节省成本。
还有就是按量付费实例是按量付费（后付费）。即是一种后付费模式，即先使用再付费。一般适用于业务流量波峰波谷差异明显或临时测试的场景，可以有效避免资源浪费。
微消息队列mqtt版费用组成：
按量付费包括：同时在线连接数；消息收发量；订阅关系数
包年包月包括：连接数上限；消息TPS上限；订阅关系数上限
计价倍率介绍：
MQTT协议QoS=0且cleanSession=true 1
MQTT协议QoS=0且cleanSession=false 1
MQTT协议QoS=1且cleanSession=true 2
MQTT协议QoS=1且cleanSession=false 5
MQTT协议QoS=2且cleanSession=true 5
NE35E MQTT协议对接阿里云
MQTT通信协议的基本介绍参考文章 NT35 MQTT通信 ，本篇给出阿里云的基本操作，NT35E通过订阅阿里云的主题发布信息与阿里云平台相互通信。
登录阿里云 → 工作台 → 物联网平台 → 进入控制台→ 公共实例
阿里云默认通信协议为MQTT，不需要特殊选择，用户按照如下步骤创建自己的产品：
创建产品 → 添加设备
在"查看"标签中，包含了MQTT连接的基本三元组信息，也就是后面设备要填充的基本参数
用户每定义一类产品都会自动生成对应的Topic列表，当然我们也可以"自定义液局历Topic"便于自己测试。
指令解析参考《Lierda NT35ENT26E-CN AT命令手册》，这里给出使用到的AT指令对应参数说明以便于理解。
AT+LMQTTCFG=cloud,闹搜tcpconnectID[,cloud _ type,data_type ]
tcpconnectID 。MQTT Socket 标识符。范围：0~4。
cloud_type整型。2 alibaba，其他参数指定其他平台
data_type整型。阿里云平台 1 json数据
AT+LMQTTCFG="cloud",0,2,1 对应就是对接阿里云平台，发送json格式的数据
AT+LMQTTCFG=aliauth,tcpconnectID[,product_key,device_name,device_secret]
填充阿里云平台中设备的三元组信息
AT+LMQTTCFG="aliauth",0,"a1JszCpjS61","NT35E_06011","390358fc595040aa73221e8393aba86c"
这部分是模组进行TCP链路连接(需抓包确认)
AT+LMQTTOPEN=tcpconnectID,host_name,port
host_name对应阿里云 "设备信息"→"MQTT连接参数"腊蔽 中的 "mqttHostUrl"
AT+LMQTTOPEN=0,"a1JszCpjS61.iot-as-mqtt.cn-shanghai.aliyuncs.com",1883
AT+LMQTTCONN=tcpconnectID[,clientID[,username[,password]]]
clientID字符串型。客户端标识符。用户可以随便定义。 username,password 不需要填写
AT+LMQTTCONN=0,"NT35E"
AT+LMQTTSUBUNSUB=tcpconnectID,subflag,msgID,topic1[,qos1[,topic2[,qos2]d…]]
subflag整型。消息类型 0 订阅 1 取消订阅
msgID整型。数据包消息标识符。范围：0~65535。
topic带双引号的字符串型。客户端订阅或者退订的主题。长度范围：0~256 字节。
qos整型。客户端发送订阅消息(SUBSCRIBE)的 QoS 等级，此时为必选参数。2 正好一次，该主题下的消息确保接收端仅接收到一次
AT+LMQTTSUBUNSUB=0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",2
这里注意topic对应参数的替换，里面的deviceName需要替换。
订阅主题之后，服务器下发的数据模组就可以正常接收了。模组下发位置
发布消息在对应的设备目录下，如果有设备"订阅"对应的消息，平台"发布"相应的数据设备就可以接收到了。
AT+LMQTTPUB=tcpconnectID,msgID,qos,retain,topic,msglen,msg
msgID整型。 0~65535。任意定义，但qos=0 时，该参数值只能为0。
qos整型。 0 最多一次 1 至少一次 2 正好一次
retain整型 。服务器是否保存该消息。0 不保存 1 保存
topic带双引号的字符串型。 客户端发布消息的主题。长度范围：0~256 字节
msglen整型 。指定的消息数据长度。范围：0~1460。
msg字符串型。 需要发布的消息数据。
AT+LMQTTPUB=0,0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",10,"1122334455"
注意刚刚自己创建的主题属性是" 发布和订阅 "，所以模组发送该主题的信息，阿里云也是可以收到的
注意这里模组发送数据的时候，也推送了自己发送的数据，因为刚刚订阅了这个主题，所以模组订阅(收)到了对应的数据
前面我们通过NT35E与平台进行信息交互，那么为什么是这样填写对应的参数呢，每个参数对应的说明在阿里云上是什么样的呢，用户可以查看阿里云的帮助文档进行确认。
上面我们使用三元组的方式( 一机一密 )实现NT35E与阿里云平台通信，但实际生产过程中该方式不好实现，比如工厂有1000个设备生产，如果每个设备都复制不同的三元组，很难实现工厂批量化生产，此时可以通过 一型一密 的通信方式解决该问题。
一型一密模组端实现方式后续更新。
在云服务器上搭建了mqtt，为什么手机连接不上mqtt，要怎么做才能连接上？求求大神帮忙
MQTT协议是广泛应用的物联网协议，使用测试MQTT协议需要MQTT的代理。有两种方法使用MQTT服务，一是租用现成的MQTT服务器，如阿里云，百度云，华为云等公用的云平台提供桐尺和的MQTT服务，使用公用的MQTT服务器的好处是省事，但如果仅仅用于测试学习还需要注册帐号，灵活性差些，有的平台还需要付费。另一方法困誉是自己使用开源的MQTT组件来搭建。
MQTT服务器非常多，如apache的ActiveMQ，局盯emtqqd，HiveMQ，Emitter，Mosquitto，Moquette等等。
这里介绍的是用轻量级的mosquitto开源项目来搭建一个属于自己的MQTT服务器。
第一步：需要安装一台linux主机，这不多介绍，可以使用真机安装也可以使用虚拟机安装。如果仅仅是自己测试使用都可以。
第二步：下载mosquitto需要的依赖
sudo apt-get install libssl-devsudo apt-get install uuid-devsudo apt-get install cmake
第三步：下载mosquitto并解压，现在mosquitto官网最新的版本是1.5.1
tar xzvf mosquitto-1.5.1.tar.gz
第四步：编译
cd mosquitto-1.5.1/
make
make install
第五步：启动mosquitto
./mosquitto -v
1535473957: mosquitto version 1.5.1 starting
1535473957: Using default config.
1535473957: Opening ipv4 listen socket on port 1883.
1535473957: Opening ipv6 listen socket on port 1883.
这时候mosquitto就会以默认的参数启动。如果需要带配置文件可以修改配置文件mosquitto.conf，
启动时候加上参数 -c，
./mosquitto -c mosquitto.conf
可以看到，mosquitto监听的端口为1883.
这时候我们的MQTT服务器就搭建好了。可找一个mqtt客户端来测试一下。
先发布一个主题“home/garden/fountain/2”
内容是“hello world”
这时候在mosquitto会打印出下面的log
535474247: New connection from 192.168.1.105 on port 1883.
1535474247: New client connected from 192.168.1.105 as MQTT_FX_Client (c1, k60).
1535474247: No will message specified.
1535474247: Sending CONNACK to MQTT_FX_Client (0, 0)
1535474307: Received PINGREQ from MQTT_FX_Client
1535474307: Sending PINGRESP to MQTT_FX_Client
1535474339: Received PUBLISH from MQTT_FX_Client (d0, q0, r0, m0, 'home/garden/fountain/2', ... (12 bytes))
1535474367: Received PINGREQ from MQTT_FX_Client
1535474367: Sending PINGRESP to MQTT_FX_Client
订阅主题“home/garden/fountain/2”
可以看到收到了自己发布的消息。
用wireshark抓包
可以看到抓到了一个MQTT的publish的报文。
玩转 ESP32 + Arduino (十六) 通过mqtt协议连接阿里云
需要用到的库:
引入"PubSubClient.h"后
打开"PubSubClient.h"
修改如下内亩启容:
关于MQTT协议, 请参考文章:
请参考我之前整理的文档:
【腾讯文档】MQTT连信闷接阿里云示例(1)
如果使用了AliyunMqttArduino, 就不需要关系协议的报文和加密方式了
首先创建一个mqtt客户端
返回值: 连接结果
返回: 状态码
mqttClient.publish(主题, 内容)
首先, 创建产品:
其次, 为产品添加设备
第三, 查看设备关键信息:
创建完后,我们发现系统已经自动创建了一些功能定义
找到产品的功能页面, 点击"编辑草稿"
最后发布新的物模型
非常迅坦如简单的修改, 只修改了要发送json里的param
注意同步修改param和json的内存占用大小
发表评论
暂时没有评论，来抢沙发吧~