ICode9
精准搜索请尝试： 精确搜索
首页
编程语言>
数据库
系统相关
互联网
其他分享
Python
Java
JavaScript
android
PHP
首页 > 其他分享> 文章详细

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

2022-04-29 14:32:55  阅读：183  来源： 互联网

标签：iot fmt IoT 5fdb75cccbfe2f02ce81d4bf device go sdk 设备


摘要：本文介绍使用huaweicloud-iot-device-sdk-go 连接华为云IoT平台，实现简单的华为云文档介绍的四个功能：设备连接鉴权、设备命令、设备消息和设备属性。

本文分享自华为云社区《​​​​​​​​​​​​​​设备如何使用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并且按照注册的顺序回调

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

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

 

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

标签：iot,fmt,IoT,5fdb75cccbfe2f02ce81d4bf,device,go,sdk,设备
来源： https://www.cnblogs.com/huaweiyun/p/16206516.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

关于我们 | 联系我们 | 留言反馈

专注分享技术，共同学习，共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有