写点什么

设备如何使用 go sdk 轻松连接华为云 IoT 平台

  • 2022 年 4 月 29 日
  • 本文字数:6206 字

    阅读完需:约 20 分钟

本文分享自华为云社区《​​​​​​​​​​​​​​设备如何使用 go sdk 轻松连接华为云 IoT 平台》,作者:华为云 IoT 专家团 。


本文介绍使用huaweicloud-iot-device-sdk-go 连接华为云 IoT 平台,实现简单的华为云文档介绍的四个功能:设备连接鉴权、设备命令、设备消息和设备属性。huaweicloud-iot-device-sdk-go 提供设备接入华为云 IoT 物联网平台的 Go 版本的 SDK,提供设备和平台之间通讯能力,以及设备服务、网关服务、OTA 等高级服务。IoT 设备开发者使用 SDK 可以大大简化开发复杂度,快速的接入平台。

Gihub 项目地址:huaweicloud-iot-device-sdk-go

安装和构建

安装和构建的过程取决于使用 go 的 modules(推荐) 还是还是GOPATH

Modules

如果你使用 modules 只需要导入包"github.com/ctlove0523/huaweicloud-iot-device-sdk-go"即可使用。当你使用 go build 命令构建项目时,依赖的包会自动被下载。注意使用 go build 命令构建时会自动下载最新版本,最新版本还没有达到 release 的标准可能存在一些尚未修复的 bug。如果想使用稳定的发布版本可以从release 获取最新稳定的版本号,并在 go.mod 文件中指定版本号。

module example
go 1.15
require github.com/ctlove0523/huaweicloud-iot-device-sdk-go v0.0.1-alpha
复制代码

GOPATH

如果你使用 GOPATH,下面的一条命令即可实现安装

go get github.com/ctlove0523/huaweicloud-iot-device-sdk-go
复制代码

使用 API

创建设备并初始化

1、首先,在华为云 IoT 平台创建一个设备,设备的信息如下:

设备 ID:5fdb75cccbfe2f02ce81d4bf_go-mqtt


设备密钥:123456789

2、使用 SDK 创建一个 Device 对象,并初始化 Device。

// 创建一个设备并初始化device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883")device.Init()
复制代码

完整样例

import (    "fmt"    "github.com/ctlove0523/huaweicloud-iot-device-sdk-go"    "time")
func main() { // 创建一个设备并初始化 device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883") device.Init() if device.IsConnected() { fmt.Println("device connect huawei iot platform success") } else { fmt.Println("device connect huawei iot platform failed") }}
复制代码

iot-mqtts.cn-north-4.myhuaweicloud.com 为华为 IoT 平台(基础班)在华为云北京四的访问端点,如果你购买了标准版或企业版,请将 iot-mqtts.cn-north-4.myhuaweicloud.com 更换为对应的 MQTT 协议接入端点。

设备处理平台下发的命令

1、首先,在华为云 IoT 平台创建一个设备,设备的信息如下:

设备 ID:5fdb75cccbfe2f02ce81d4bf_go-mqtt


设备密钥:123456789

2、使用 SDK 创建一个 Device 对象,并初始化 Device。

// 创建一个设备并初始化device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883")device.Init()if device.IsConnected() {    fmt.Println("device connect huawei iot platform success")} else {    fmt.Println("device connect huawei iot platform failed")}
复制代码

3、注册命令处理 handler,支持注册多个 handler 并且按照注册的顺序回调

// 添加用于处理平台下发命令的callbackdevice.AddCommandHandler(func(command iot.Command) bool {    fmt.Println("First command handler begin to process command.")    return true})
device.AddCommandHandler(func(command iot.Command) bool { fmt.Println("Second command handler begin to process command.") return true})
复制代码

4、通过应用侧 API 向设备下发一个命令,可以看到程序输出如下:

device connect huawei iot platform successFirst command handler begin to process command.Second command handler begin to process command.
复制代码

完整样例

import (    "fmt"    "github.com/ctlove0523/huaweicloud-iot-device-sdk-go"    "time")
// 处理平台下发的同步命令func main() { // 创建一个设备并初始化 device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883") device.Init() if device.IsConnected() { fmt.Println("device connect huawei iot platform success") } else { fmt.Println("device connect huawei iot platform failed") }
// 添加用于处理平台下发命令的callback device.AddCommandHandler(func(command iot.Command) bool { fmt.Println("First command handler begin to process command.") return true })
device.AddCommandHandler(func(command iot.Command) bool { fmt.Println("Second command handler begin to process command.") return true }) time.Sleep(1 * time.Minute)}
复制代码

设备支持的命令定义在产品中

设备消息

1、首先,在华为云 IoT 平台创建一个设备,设备的信息如下:

设备 ID:5fdb75cccbfe2f02ce81d4bf_go-mqtt

设备密钥:123456789

2、使用 SDK 创建一个 Device 对象,并初始化 Device。

device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883")    device.Init()
复制代码

设备消息上报

message := iot.Message{    ObjectDeviceId: uuid.NewV4().String(),    Name:           "Fist send message to platform",    Id:             uuid.NewV4().String(),    Content:        "Hello Huawei IoT Platform",}device.SendMessage(message)
复制代码

平台消息下发

接收平台下发的消息,只需注册消息处理 handler,支持注册多个 handler 并按照注册顺序回调。

// 注册平台下发消息的callback,当收到平台下发的消息时,调用此callback.// 支持注册多个callback,并且按照注册顺序调用device.AddMessageHandler(func(message iot.Message) bool {    fmt.Println("first handler called" + iot.Interface2JsonString(message))    return true})
device.AddMessageHandler(func(message iot.Message) bool { fmt.Println("second handler called" + iot.Interface2JsonString(message)) return true})
复制代码

完整样例

import (    "fmt"    iot "github.com/ctlove0523/huaweicloud-iot-device-sdk-go"    uuid "github.com/satori/go.uuid"    "time")
func main() { // 创建一个设备并初始化 device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883") device.Init()
// 注册平台下发消息的callback,当收到平台下发的消息时,调用此callback. // 支持注册多个callback,并且按照注册顺序调用 device.AddMessageHandler(func(message iot.Message) bool { fmt.Println("first handler called" + iot.Interface2JsonString(message)) return true })
device.AddMessageHandler(func(message iot.Message) bool { fmt.Println("second handler called" + iot.Interface2JsonString(message)) return true })
//向平台发送消息 message := iot.Message{ ObjectDeviceId: uuid.NewV4().String(), Name: "Fist send message to platform", Id: uuid.NewV4().String(), Content: "Hello Huawei IoT Platform", } device.SendMessage(message) time.Sleep(2 * time.Minute)
}
复制代码

设备属性

1、首先,在华为云 IoT 平台创建一个设备,并在该设备下创建 3 个子设备,设备及子设备的信息如下:

设备 ID:5fdb75cccbfe2f02ce81d4bf_go-mqtt

设备密钥:123456789

子设备 ID:5fdb75cccbfe2f02ce81d4bf_sub-device-1

子设备 ID:5fdb75cccbfe2f02ce81d4bf_sub-device-2

子设备 ID:5fdb75cccbfe2f02ce81d4bf_sub-device-3

2、使用 SDK 创建一个 Device 对象,并初始化 Device。

// 创建设备并初始化device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883")device.Init()fmt.Printf("device connected: %v\n", device.IsConnected())
复制代码

设备属性上报

使用ReportProperties(properties ServiceProperty) bool 上报设备属性

// 设备上报属性props := iot.ServicePropertyEntry{    ServiceId: "value",    EventTime: iot.DataCollectionTime(),    Properties: DemoProperties{        Value:   "chen tong",        MsgType: "23",    },}
var content []iot.ServicePropertyEntrycontent = append(content, props)services := iot.ServiceProperty{ Services: content,}device.ReportProperties(services)
复制代码

网关批量设备属性上报

使用BatchReportSubDevicesProperties(service DevicesService) 实现网关批量设备属性上报

// 批量上报子设备属性subDevice1 := iot.DeviceService{    DeviceId: "5fdb75cccbfe2f02ce81d4bf_sub-device-1",    Services: content,}subDevice2 := iot.DeviceService{    DeviceId: "5fdb75cccbfe2f02ce81d4bf_sub-device-2",    Services: content,}
subDevice3 := iot.DeviceService{ DeviceId: "5fdb75cccbfe2f02ce81d4bf_sub-device-3", Services: content,}
var devices []iot.DeviceServicedevices = append(devices, subDevice1, subDevice2, subDevice3)
device.BatchReportSubDevicesProperties(iot.DevicesService{ Devices: devices,})
复制代码

平台设置设备属性

使用AddPropertiesSetHandler(handler DevicePropertiesSetHandler) 注册平台设置设备属性 handler,当接收到平台的命令时 SDK 回调。

// 注册平台设置属性callback,当应用通过API设置设备属性时,会调用此callback,支持注册多个callbackdevice.AddPropertiesSetHandler(func(propertiesSetRequest iot.DevicePropertyDownRequest) bool {    fmt.Println("I get property set command")    fmt.Printf("request is %s", iot.Interface2JsonString(propertiesSetRequest))    return true})
复制代码

平台查询设备属性

使用SetPropertyQueryHandler(handler DevicePropertyQueryHandler)注册平台查询设备属性 handler,当接收到平台的查询请求时 SDK 回调。

// 注册平台查询设备属性callback,当平台查询设备属性时此callback被调用,仅支持设置一个callbackdevice.SetPropertyQueryHandler(func(query iot.DevicePropertyQueryRequest) iot.ServicePropertyEntry {    return iot.ServicePropertyEntry{        ServiceId: "value",        Properties: DemoProperties{            Value:   "QUERY RESPONSE",            MsgType: "query property",        },        EventTime: "2020-12-19 02:23:24",    }})
复制代码

设备侧获取平台的设备影子数据

使用QueryDeviceShadow(query DevicePropertyQueryRequest, handler DevicePropertyQueryResponseHandler) 可以查询平台的设备影子数据,当接收到平台的响应后 SDK 自动回调DevicePropertyQueryResponseHandler

// 设备查询设备影子数据device.QueryDeviceShadow(iot.DevicePropertyQueryRequest{    ServiceId: "value",}, func(response iot.DevicePropertyQueryResponse) {    fmt.Printf("query device shadow success.\n,device shadow data is %s\n", iot.Interface2JsonString(response))})
复制代码

完整样例

import (    "fmt"    iot "github.com/ctlove0523/huaweicloud-iot-device-sdk-go"    "time")
func main() { // 创建设备并初始化 device := iot.CreateIotDevice("5fdb75cccbfe2f02ce81d4bf_go-mqtt", "123456789", "tcp://iot-mqtts.cn-north-4.myhuaweicloud.com:1883") device.Init() fmt.Printf("device connected: %v\n", device.IsConnected())
// 注册平台设置属性callback,当应用通过API设置设备属性时,会调用此callback,支持注册多个callback device.AddPropertiesSetHandler(func(propertiesSetRequest iot.DevicePropertyDownRequest) bool { fmt.Println("I get property set command") fmt.Printf("request is %s", iot.Interface2JsonString(propertiesSetRequest)) return true })
// 注册平台查询设备属性callback,当平台查询设备属性时此callback被调用,仅支持设置一个callback device.SetPropertyQueryHandler(func(query iot.DevicePropertyQueryRequest) iot.ServicePropertyEntry { return iot.ServicePropertyEntry{ ServiceId: "value", Properties: DemoProperties{ Value: "QUERY RESPONSE", MsgType: "query property", }, EventTime: "2020-12-19 02:23:24", } })
// 设备上报属性 props := iot.ServicePropertyEntry{ ServiceId: "value", EventTime: iot.DataCollectionTime(), Properties: DemoProperties{ Value: "chen tong", MsgType: "23", }, }
var content []iot.ServicePropertyEntry content = append(content, props) services := iot.ServiceProperty{ Services: content, } device.ReportProperties(services)
// 设备查询设备影子数据 device.QueryDeviceShadow(iot.DevicePropertyQueryRequest{ ServiceId: "value", }, func(response iot.DevicePropertyQueryResponse) { fmt.Printf("query device shadow success.\n,device shadow data is %s\n", iot.Interface2JsonString(response)) })
// 批量上报子设备属性 subDevice1 := iot.DeviceService{ DeviceId: "5fdb75cccbfe2f02ce81d4bf_sub-device-1", Services: content, } subDevice2 := iot.DeviceService{ DeviceId: "5fdb75cccbfe2f02ce81d4bf_sub-device-2", Services: content, }
subDevice3 := iot.DeviceService{ DeviceId: "5fdb75cccbfe2f02ce81d4bf_sub-device-3", Services: content, }
var devices []iot.DeviceService devices = append(devices, subDevice1, subDevice2, subDevice3)
device.BatchReportSubDevicesProperties(iot.DevicesService{ Devices: devices, }) time.Sleep(1 * time.Minute)}
type DemoProperties struct { Value string `json:"value"` MsgType string `json:"msgType"`}
复制代码



更多学习内容,请前往IoT物联网社区 

如果您也对物联网感兴趣,欢迎评论区交流或私聊~


点击关注,第一时间了解华为云新鲜技术~​

发布于: 刚刚阅读数: 2
用户头像

提供全面深入的云计算技术干货 2020.07.14 加入

华为云开发者社区,提供全面深入的云计算前景分析、丰富的技术干货、程序样例,分享华为云前沿资讯动态,方便开发者快速成长与发展,欢迎提问、互动,多方位了解云计算! 传送门:https://bbs.huaweicloud.com/

评论

发布
暂无评论
设备如何使用go sdk轻松连接华为云IoT平台_华为云_华为云开发者社区_InfoQ写作社区