导航:首页 > 配服务器 > 阿里云服务器部署mqtt

阿里云服务器部署mqtt

发布时间:2023-01-02 20:15:19

1. 如何在阿里云上部署MQTT需要购买什么样的阿里服务

在阿里云的后台终端安装MQTT

2. 阿里云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

3. 阿里云物联网平台搭建(5)基础平台服务的调用

之前一直想要使用mqtt协议模拟tcp协议的实时返回监控参数的功能,经过几个月的摸索和试验,终于将同步服务的开发摸透,仅仅看飞燕平台的技术文档是看不懂的,核心文档链接如下:

1、什么是rrpc,同步服务如何使用rrpc实现实时返回的效果

https://help.aliyun.com/document_detail/90568.html?spm=5176.11065259.1996646101.searchclickresult.17d42700JKyg9e&aly_as=odhFNfAc

阿里将同步服务使用rrpc

2、服务的数据格式

https://help.aliyun.com/document_detail/89301.html?spm=5176.11065259.1996646101.searchclickresult.17d42700JKyg9e&aly_as=KNMEpUOP

看完文档还有不懂的同学们,我给你准备了总结:

1.RRPC有专用的topic,服务端的实现,在物的模型服务中有invoke的请求方式和返回结果。

设备端根据文档1中的订阅topic与上报topic。上报的数据格式根据文档2上报。

例子:

1.按照物的服务调用方法请求

2.设备端订阅到服务的下发,将msgid从topic上面截取下来此处为1214836938775870464

3.将msgid填充到上报topic结尾,数据格式注意param改为data,加上code,其余数据对照功能定义中的物模型

4.在调试窗口中找到服务调用菜单

显示上报成功,注意服务的解析与属性事件不一样,通过通用打印只能打印出result ok,要进一步解析data出来再打印。

4. 想问一下,如何用MQTT协议搭建一个物联网空调的阿里云服务器,谢谢

MQTT推荐使用EMQ,来自国人开发的产品

5. 在云服务器上搭建了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的报文。

6. java 实现串口接收到数据,立马将接收到的数据通过mqtt上传到阿里云。

也不是特别麻烦,你先要清楚串口和服务器用的什么协议,假设串口用232,服务器采用TCP,那么你需要做的是建立一个客户端的发送模块,和一个串口的操作模块(结合必须要用到多线程,以队列或者委托来做数据交换);在测试之前一定要保证串口和客户端发送接收是ok的才能做结合功能。
因为你串口已经做好了,那你需要的是将采集到的数据(字符串)保存到数组中,然后创建一个指向数组的指针p,然后在客户端模块里,将发送的数据写成&p。建议先将数据转16进制发,应该没毛病。

7. NE35E MQTT协议对接阿里云

MQTT通信协议的基本介绍参考文章 NT35 MQTT通信 ,本篇给出阿里云的基本操作,NT35E通过订阅阿里云的主题&发布信息与阿里云平台相互通信。

登录阿里云 → 工作台 → 物联网平台 → 进入控制台→ 公共实例

阿里云默认通信协议为MQTT,不需要特殊选择,用户按照如下步骤创建自己的产品:

创建产品 → 添加设备 

在"查看"标签中,包含了MQTT连接的基本三元组信息,也就是后面设备要填充的基本参数

      用户每定义一类产品都会自动生成对应的Topic列表,当然我们也可以"自定义Topic"便于自己测试。

       指令解析参考《Lierda NT35E&NT26E-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>[,<proct_key>,<device_name>,<device_secret>]

填充阿里云平台中设备的三元组信息

AT+LMQTTCFG="aliauth",0,"a1JszCpjS61","NT35E_06011",""

这部分是模组进行TCP链路连接(需抓包确认)

AT+LMQTTOPEN=<tcpconnectID>,<host_name>,<port>

host_name对应阿里云 "设备信息"→"MQTT连接参数" 中的 "mqttHostUrl"

AT+LMQTTOPEN=0,"a1JszCpjS61.iot-as-mqtt.cn-shanghai.aliyuncs.com",1883

模组作为客户端,通过MQTT协议连接到服务器(需抓包确认)

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个设备生产,如果每个设备都复制不同的三元组,很难实现工厂批量化生产,此时可以通过 一型一密 的通信方式解决该问题。

一型一密模组端实现方式后续更新。

8. 玩转 ESP32 + Arino (十六) 通过mqtt协议连接阿里云

需要用到的库:

引入"PubSubClient.h"后

打开"PubSubClient.h"

修改如下内容:

关于MQTT协议, 请参考文章: https://zhuanlan.hu.com/p/89057819

请参考我之前整理的文档:
【腾讯文档】MQTT连接阿里云示例(1) https://docs.qq.com/sheet/DWXBaUE9nWmZVaGJX

如果使用了AliyunMqttArino, 就不需要关系协议的报文和加密方式了

首先创建一个mqtt客户端

返回值: 连接结果

返回: 状态码

mqttClient.publish(主题, 内容)

首先, 创建产品:

其次, 为产品添加设备

第三, 查看设备关键信息:

创建完后,我们发现系统已经自动创建了一些功能定义

找到产品的功能页面, 点击"编辑草稿"

最后发布新的物模型

非常简单的修改, 只修改了要发送json里的param
注意同步修改param和json的内存占用大小

9. 阿里云微消息队列(MQTT)的基本使用

最近应系统功能需求,采购了一款云喇叭的物联网设备,就是插着4G卡那种,可以播放各种语音,仔细阅读了开发文档之后发现使用的是MQTT的协议,记录一下在对接中遇到的各种问题

MQTT是一个轻量的发布订阅模式消息传输协议,专门针对低带宽和不稳定网络环境的物联网应用设计。
MQTT特点:

阿里云的MQTT有两个版本,这里只说没有RocketMQ依赖的3.1.1及以上版本。

这里会自动生成用户名密码

10. 如何使用 NB-Iot + Arino 通过MQTT协议上传数据至阿里云平台

有很多通信模块只有TCP功能,没有MQTT功能,比如WIFI,W5500等模块,还有一些NBIOT模块,但是又想连接阿里云物联网平台,官方提供了操作系统,需要自己移植,很麻烦,比较难看得懂。就在想有没有一些简单一定的方法。
心想MQTT是基于TCP的,能否使用TCP转MQTT?因此就想使用TCP协议然后转MQTT协议连接阿里云物联网平台,经过试验证明是可以的。

首先我们先分析一下如何登陆接入Onenet平台。

先从它数据格式开始分析。首先我们要从后台取出三个信息,我们以这个为例。

我们把产品ID,设备名称,设备秘钥,简称三要素 (具体是什么看你自己的设备)

其实阿里云物联网平台的MQTT协议用的就是标准的,不过它加入了自己的认证方式。

MQTT协议需要上传四个参数,报活时间,clientID,用户名,密码。

那么阿里云的就在clientID,用户名,密码做了手脚。

clientID比较长,按照一定的格式

用户名:设备名和秘钥组成

密码:使用了加密串进行了加密,有sha1或者MD5加密方式

下面我们来介绍一下

MQTT接入都是发十六进制的数据。

么我们发送的时候就是这样子的一串数据

0x74 0x00 0x04 0x4d 0x51 0x54 0x54 0x04 0xC0 0078 0033 0x61 0x62 0x63 0x7c 0x73 0x65 0x63 0x75 0x72 0x65 0x6d 0x6f 0x64 0x65 0x3d 0x33 0x2c 0x73 0x69 0x67

0x6e 0x6d 0x65 0x74 0x68 0x6f 0x64 0x3d 0x68 0x6d 0x61 0x63 0x73 0x68 0x61 0x31 0x2c 0x74 0x69 0x6d 0x65 0x73 0x74 0x61 0x6d 0x70 0x3d 0x31 0x32 0x30 0x7c 0009

0x35 0x36 0x37 0x38 0x26 0x31 0x32 0x33 0x34 0028 0x32 0x32 0x32 0x37 0x35 0x30 0x44 0x45 0x44 0x46 0x45 0x34 0x46 0x37 0x37 0x34 0x30 0x30 0x32 0x45 0x45 0x38 0x37 0x45 0x45 0x44 0x32 0x39 0x43 0x46 0x44 0x30 0x36 0x33 0x38 0x43 0x35 0x46 0x36 0x36

十六进制解释

数据长度:0x74

协议数据长度 0x00 0x04

协议类型: 0x4d 0x51 0x54 0x54

协议数据: 0x04 0xC0

keepAlive数据:0078

ClientID长度:0033

ClientID: 0x61 0x62 0x63 0x7c 0x73 0x65 0x63 0x75 0x72 0x65 0x6d 0x6f 0x64 0x65 0x3d 0x33 0x2c 0x73 0x69 0x67 0x6e 0x6d 0x65 0x74 0x68 0x6f 0x64 0x3d 0x68 0x6d 0x61 0x63 0x73 0x68 0x61 0x31 0x2c 0x74 0x69 0x6d 0x65 0x73 0x74 0x61 0x6d 0x70 0x3d 0x31 0x32 0x30 0x7c

用户名:0009

用户名: 0x35 0x36 0x37 0x38 0x26 0x31 0x32 0x33 0x34

密码长度:0028

密码: 0x32 0x32 0x32 0x37 0x35 0x30 0x44 0x45 0x44 0x46 0x45 0x34 0x46 0x37 0x37 0x34 0x30 0x30 0x32 0x45 0x45 0x38 0x37 0x45 0x45 0x44 0x32 0x39 0x43 0x46 0x44 0x30 0x36 0x33 0x38 0x43 0x35 0x46 0x36 0x36复制代码上面的就是连接服务器的连接包

下面呢,我们来做个发布包(上传数据到服务器)

0x30 0x1D 0009 2f7379732f706f7374 0x7b 0x70 0x61 0x72 0x61 0x6d 0x73 0x3a 0x7b 0x74 0x65 0x6d 0x70 0x3a 0x31 0x30 0x7d 0x7d

十六进制数据解释

数据头:0x30

数据长度:0x1D

TopicName数据长度:0009

TopicName数据内容:2f7379732f706f7374

主体json数据: 0x7b 0x70 0x61 0x72 0x61 0x6d 0x73 0x3a 0x7b 0x74 0x65 0x6d 0x70 0x3a 0x31 0x30 0x7d 0x7d复制代码以上就是连接阿里云的数据包格式及发布数据的格式,由于时间问题没有做订阅的数据包分析,下一次更新订阅的内容。

阅读全文

与阿里云服务器部署mqtt相关的资料

热点内容
最早提出分数运算法的着作 浏览:922
安卓邮箱怎么保存照片 浏览:269
hdfspythonapi 浏览:851
qt如何搭建web服务器 浏览:58
程序员红包算法 浏览:792
亚马逊安全的更换云服务器 浏览:728
服务器线程数怎么设置 浏览:605
考研词汇红宝书2019pdf 浏览:981
如何利用安卓手机wifi修改密码 浏览:373
辞海分册pdf 浏览:935
安卓系统页面怎么调 浏览:775
压缩文件的用法 浏览:34
如何用浏览器访问服务器地址 浏览:207
soft编译器 浏览:113
三轴车床的编程指令 浏览:71
天生敏感pdf 浏览:565
西瓜星球服务器怎么刷钻石 浏览:838
php生成chm 浏览:658
解释程序和编译程序产生目标吗 浏览:609
dos命令rem 浏览:371