玩转MQTT-阿里云之MQTT使用（下）

摘要

为使物联网项目在正式使用时，能顺利切换到具有高并发高负载能力的服务平台，对阿里云提供的MQTT服务进行使用验证。

引言

之前写“MQTT之阿里云使用-玩转阿里云”这篇文章时，由于时间关系（写文章也是要花费大量时间的），打算将内容拆分为两部分，将写好的一部分先发了出去，打算稍后再补充后续完结内容。

不成想，文章发出后，居然被管理员从首页移除，严重打击了本人原本不那么强悍的内心，导致一直不太有兴趣完成后续部分。

近来翻看自己的文章，发表这篇烂尾的文章居然是自己文章中阅读访问量最高的一篇。虽然文章内容组织比较凌乱，表述也不够好，在这9102年即将过去之际，还是打算来一个续篇，为自己忙忙碌碌（碌碌无为）的2019做个收尾。

MQTT服务验证

书接上回，我们说到了阿里云RocketMQ、MQTT服务的开通（MQTT消息的持久化依托MQ服务）、介绍了MQ、MQTT实例的创建，顶级Topic资源的创建，GroupID前缀的创建以及RAM帐号资源的创建及帐号授权。

一系列准备工作之后，准备开始使用MQTT消息中间件服务。

访问鉴权

使用微消息队列 MQTT 的客户端收发消息时，服务端会根据 MQTT 客户端设置的 Username 和 Password 参数来进行鉴权。

阿里云支持两种鉴权模式

签名验证：永久授权，适用于客户端安全受信任的场景

临时 Token 权限验证：临时授权，适用于客户端不安全的场景

具体鉴权认证的相关资料在这里，大家可自行访问阅读。https://help.aliyun.com/document_detail/54225.html

签名校验

简单介绍一下阿里云MQTT访问中的签名鉴权模式下的访问要点

1、 MQTT连接参数中ClientId必须以GroupID为前缀，以@@@作为连接符，连接自定义的客户ID

2、 MQTT连接参数中Username由鉴权模式名称、AccessKey、InstanceId 三部分组成，以 “|” 分隔。

3、 MQTT连接参数中Password是用AccessKey对应的AccessKeySecret对ClientId使用 HMAC-SHA1 方法进行签名计算得到一个二进制数组，再对该二进制数组做 Base64 编码得到最终的 Password 签名字符串。

签名校验资料网址如下：https://help.aliyun.com/document_detail/48271.html

阿里云MQTT服务管理页面中，提供了一个在线的JS版本的签名校验验证计算页面，用于验证各位自行实现的校验算法是否正确。

MQTT连接测试

让我们调出Paho神器，来一场说连就连的测试

https://repo.eclipse.org/content/repositories/paho-releases/org/eclipse/paho/org.eclipse.paho.ui.app/1.0.2/

https://www.eclipse.org/paho/downloads.php

如上图，先创建MQTT连接，填入服务器地址及端口，填入客户机标识（ClientId）

在MQTT连接选项中，勾选开启登录，填写用户名、密码

点击连接，正常情况下，即可成功连接并登录到阿里云MQTT服务器。

笔者基于C#,使用开源MQTTnet的Nuget包，也实现了一个简单的MQTT客户端。我们用这个客户端进行连接测试，效果如下图。

消息消费

MQTT是基于二进制消息的发布/订阅编程模式的消息协议。

要使用MQTT进行通讯，就需要有发布者和消费者。发布者通过发布主题消息传递信息，接收者通过订阅对应的主题接收和消费信息。

订阅主题

MQTT客户端与MQTT服务器建立连接之后，我们即可以进行消息订阅和消息发布。

发布主题

我们使用上文中建立的顶级主题创建一个带有通配符的订阅主题。

注意，MQTT允许使用通配符订阅主题，但是并不允许使用通配符广播。

我们创建一个顶级主题下带有城市和发布者编号的主题，发布一条消息，Payload中携带一个json格式的状态信息和坐标信息。

点击发布，可以看到上图中，接收框中，成功接收到订阅主题下的消息。（操作中发布了二条消息）。

使用Paho测试消息发布/订阅，效果相同。

一个发布者发布的消息，可以被多个订阅者接收。

巴特西