引言

最近一直在学习仓颉语言，由于我对物联网比较感兴趣，自然想到写一个MQTT的程序，好在找到了mqtt4cj库，今天分享一下学习心得。

mqtt4cj库的使用

mqtt4cj库使用仓颉语言编写的MQTT协议处理库。主要特性包括：

🚀 支持 tcp/tls/ws/wss 方式连接消息服务端
🚀 支持 mqttv3 协议连接消息服务端
🚀 支持 mqtt 主题订阅发布

mqtt4cj是基于仓颉编程语言Canary Version SDK的，不能用现有的公开的仓颉SDK（0.5x版本）编译。该版本点分式版本号为Cangjie 0.60.5。这个版本增强了自定义注解能力，主要是支持声明的范围扩大，基于混合泛型恢复了反射能力，同时将扩展库移到stdx，后续通过stdx库提供能力。

申请仓颉编程语言内测

要使用Canary Version SDK，需要先访问下面的地址申请内侧版本：GitCode - 全球开发者的开源社区,开源代码托管平台

申请后等几天会收到邮件，表示内测通过了，就可以访问内测版本SDK和STDX。

下载STDX

访问STDX的网站：GitCode - 全球开发者的开源社区,开源代码托管平台，在其中的发行版那里下载并解压软件。

然后设置CANGJIE_STDX_PATH变量指向STDX的目录。

测试程序

我编写了一个简单的MQTT测试程序，用于访问华为云的IoTDA，并发布一条状态信息。

package iotdatest
import mqtt4cj.mqttv3.*main(): Int64 {let mqttClient: MqttClient = MqttClient("tcp://bde4cbe7aa.st1.iotda-device.cn-north-4.myhuaweicloud.com:1883", "<yourclientid>", MemoryPersistence())let mqttopt : MqttConnectOptions = MqttConnectOptions()mqttopt.setPassword("<yourpassword>".toRuneArray())mqttopt.setUserName("<yourusername>")let connectToken = mqttClient.connect(mqttopt)let data: String = """{"services": [{"service_id": "Ledlight","properties": {"LED": "ON"}}]}"""mqttClient.publish("$oc/devices/<deviceid>/sys/properties/report", data.toArray(), 0, false)sleep(Duration.second * 20)mqttClient.disconnect()mqttClient.close()return 0
}

在控制台可以看到设备在线，并收到消息。