设备如何使用go sdk轻松连接华为云iot平台-凯发k8国际娱乐官网入口

发表于 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"`
}


更多学习内容,请前往

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

【凯发k8国际娱乐官网入口的版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区),文章链接,文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件至:进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容。
  • 点赞
  • 收藏
  • 关注作者

评论(0

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

全部回复

上滑加载中

设置昵称

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

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

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