本文分享自华为云社区《设备如何使用 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物联网社区
如果您也对物联网感兴趣，欢迎评论区交流或私聊~
点击关注，第一时间了解华为云新鲜技术~
评论