- 微信
- 复制链接
  
  复制链接到剪贴板

设备如何使用go sdk轻松连接华为云iot平台-4008云顶国际网站

发表于 2022/04/28 15:51:05 2022/04/28

【摘要】本文介绍使用huaweicloud-iot-device-sdk-go 连接华为云iot平台，实现简单的华为云文档介绍的四个功能：设备连接鉴权、设备命令、设备消息和设备属性。huaweicloud-iot-device-sdk-go提供设备接入华为云iot物联网平台的go版本的sdk，提供设备和平台之间通讯能力，以及设备服务、网关服务、ota等高级服务。iot设备开发者使用sdk可以大大简化...

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

gihub项目地址：

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

modules

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

创建设备并初始化

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并且按照注册的顺序回调

// 添加用于处理平台下发命令的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
})

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

device connect huawei iot platform success
first 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.servicepropertyentry
content = 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.deviceservice
devices = append(devices, subdevice1, subdevice2, subdevice3)
device.batchreportsubdevicesproperties(iot.devicesservice{
    devices: devices,
})

平台设置设备属性

使用addpropertiessethandler(handler devicepropertiessethandler) 注册平台设置设备属性handler，当接收到平台的命令时sdk回调。

// 注册平台设置属性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
})

平台查询设备属性

使用setpropertyqueryhandler(handler devicepropertyqueryhandler)注册平台查询设备属性handler，当接收到平台的查询请求时sdk回调。

// 注册平台查询设备属性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",
    }
})

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

使用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"`
}

更多学习内容，请前往

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

点赞
收藏
关注作者

0/1000

抱歉，系统识别当前为高风险访问，暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称，即可参与社区互动！

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

设备如何使用go sdk轻松连接华为云iot平台-4008云顶国际网站

modules

gopath

创建设备并初始化

完整样例

完整样例

设备消息上报

平台消息下发

完整样例

设备属性上报

网关批量设备属性上报

平台设置设备属性

平台查询设备属性

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

完整样例

全部回复

设置昵称

关于作者

推荐阅读

相关产品