基于华为物联网IOT的应用开发—基于.net的SDK封装

作者：潇潇雨621715 | 来源：互联网 | 2023-09-16 18:18

最近，物联网的概念比较热门，一大批厂商抢着占领物联网的高低，包括有华为物联网、阿里云物联网、腾讯

最近，物联网的概念比较热门，一大批厂商抢着占领物联网的高低，包括有华为物联网、阿里云物联网、腾讯物联网、AWS物联网等等，无法一一列举，一般物联网包含设备侧开发、平台侧开发、应用侧开发，三个部分构成了线上线下的完整连接，和我们常规的微信应用、钉钉应用等不同，物联网的终端是由各种各样的设备组合而成，这些设备通过各种不同的协议（如CoAP，LWM2M、MQTT）连接到IOT的平台，而且这些设备是低能耗的设备，可以实时的发送数据上来，也可以接受来自IOT平台下发的各种操作指令。本篇随笔主要介绍基于华为物联网IOT的应用开发，实现对.net SDK的封装，方便后期进行应用集成使用。

1、物联网的相关介绍

物联网其实有点类似我们以前做的一些行业设备的接入，不过它相对比较通用化一些，可以连接各种各样的类型设备，而且更加安全、低能耗等，我们以前接入很多设备，可能需要走TCP/UDP协议，然后在后台服务器有一个对这些设备管理的一个Socket服务器，不过和物联网对比，这些都被彻底改造过了，以便适应更多的应用场景，更简化的开发，以及支持更强大的功能吧。

物联网目前可以针对一些传感器采集一些特定的参数，如光感、温度、湿度、压力、电压、电流等常规的信息，也可以扩展实现语音、图像、视频等方面的采集处理，如经典的智慧路灯应用场景。

下面是其中的一个应用的架构设计，主要就是针对这些设备管理，物联网还提供了很多完善的应用API接口，使得我们可以更加简化对设备的管理（不用架设Socket服务），更加方便的通过API获取相应的信息，节省更多的维护成本。

物联网平台支持海量设备连接上云，设备与云端可以实现稳定可靠地双向通信。

提供设备端SDK、驱动、软件包等帮助不同设备、网关轻松接入物联网云。

提供2G/ 3G /4G、NB-IoT、LoRa、WiFi等不同网络设备接入方案，解决企业异构网络设备接入管理痛点。

提供MQTT、CoAP、HTTP/S等多种协议的设备端SDK，既满足长连接的实时性需求，也满足短连接的低功耗需求。

开源多种平台设备端代码，提供跨平台移植指导，赋能企业基于多种平台做设备接入。

一般的物联网平台，都会包括产品管理、设备管理、设备组管理、规则引擎管理、消息推送和消息订阅、任务管理、设备升级等等，不同的物联网云平台有所不同。

物联网的几个相关的协议：

MQTT（Message Queue Telemetry Transport）

MQTT是一个物联网传输协议，被设计用于轻量级的发布/订阅式消息传输，旨在为低带宽和不稳定的网络环境中的物联网设备提供可靠的网络服务。

MQTTS指MQTT+SSL/TLS，在MQTTS中使用SSL/TLS协议进行加密传输。

CoAP（Constrained Application Protocol）

受约束的应用协议（CoAP）是一种软件协议，旨在使非常简单的电子设备能够在互联网上进行交互式通信。

CoAPS指CoAP over DTLS，在CoAPS中使用DTLS协议进行加密传输。

LWM2M（lightweight Machine to Machine）

LWM2M是由OMA（Open Mobile Alliance)定义的物联网协议，主要使用在资源受限(包括存储、功耗等)的NB-IoT终端

2、应用侧开发接口

应用侧的开发接口一般云平台都会提供不同平台的SDK，如阿里云开源提供Java SDK/C# SDK等；而华为则提供了Java、PHP等SDK，没有包含.net 的SDK。

阿里物联网云的应用侧API接口包括：

华为物联网云的应用侧API接口包括：

本篇主要介绍最基础的物联网SDK的包装，以方便后续的应用开发集成。本篇随笔也主要是基于华为应用侧API的封装，使用C#语言实现对.net SDK的全部封装处理。

针对上面的接口分类，我们定义不同的接口类来处理它们。

基本上所有API访问都先需要通过鉴权接口获取访问的token，鉴权接口定义如下所示。

而且华为的API接口，需要使用X509证书处理的，我们可以通过在官网下载对应的X509证书进行集成测试API。

为了实现对API进行的.net SDK封装，我们定义一些系统常见变量，方便在接口中使用。

根据鉴权返回的结果，我们定义一个对应的实体类来存储这些属性信息，如下所示。

///


    /// 鉴权结果
    ///


    public class AuthenticationResult : BaseJsonResult
    {
        /// 
        /// 申请权限范围，即accessToken所能访问物联网平台资源的范围，参数值固定为default。
        /// 

        public string scope { get; set; }
        /// 
        /// accessToken的类型，参数值固定为Bearer 。
        /// 

        public string tokenType { get; set; }
        /// 
        /// accessToken的有效时间，参数值固定为3600秒
        /// 

        public int expiresIn { get; set; }
        /// 
        /// 鉴权参数，访问物联网平台API接口的凭证。
        /// 

        public string accessToken { get; set; }
        /// 
        /// 鉴权参数，有效时间为1个月，用于“刷新Token”接口。
        /// 当accessToken即将过期时，可通过“刷新Token”接口来获取新的accessToken。
        /// 

        public string refreshToken { get; set; }
    }

///

/// 鉴权结果
///

public class AuthenticationResult : BaseJsonResult
{
///

/// 申请权限范围，即accessToken所能访问物联网平台资源的范围，参数值固定为default。
///

public string scope { get; set; }
///

/// accessToken的类型，参数值固定为Bearer 。
///

public string tokenType { get; set; }
///

/// accessToken的有效时间，参数值固定为3600秒
///

public int expiresIn { get; set; }
///

/// 鉴权参数，访问物联网平台API接口的凭证。
///

public string accessToken { get; set; }
///

/// 鉴权参数，有效时间为1个月，用于“刷新Token”接口。
/// 当accessToken即将过期时，可通过“刷新Token”接口来获取新的accessToken。
///

public string refreshToken { get; set; }
}

然后根据鉴权定义，我们实现对这个接口的封装处理。

///


    /// IOT鉴权接口实现
    ///


    public class AuthenticationApi : IAuthenticationApi
    {
        /// 
        /// 用户鉴权
        /// 应用服务器首次访问物联网平台的开放API时，需调用此接口完成接入认证；
        /// 应用服务器在物联网平台的认证过期后，需调用此接口重新进行认证，才能继续访问物联网平台的开放API。
        /// 

        public AuthenticationResult Authentication()
        {
            string postData = string.Format("appId={0}&secret={1}", Constants.AppId, Constants.Secret);
            var url = Constants.AppBaseUrl + "/iocm/app/sec/v1.1.0/login";//名称大小写不能错
            HttpHelper helper = new HttpHelper();
            helper.COntentType= "application/x-www-form-urlencoded";
            helper.ClientCertificates = new X509CertificateCollection() { new X509Certificate2(Constants.CertFilePath, Constants.CertPassword) };
            string cOntent= helper.GetHtml(url, postData, true);
            var result = JsonConvert.DeserializeObject(content);
            return result;
        }

///


    /// IOT鉴权接口实现
    ///


    public class AuthenticationApi : IAuthenticationApi
    {
        /// 
        /// 用户鉴权
        /// 应用服务器首次访问物联网平台的开放API时，需调用此接口完成接入认证；
        /// 应用服务器在物联网平台的认证过期后，需调用此接口重新进行认证，才能继续访问物联网平台的开放API。
        /// 

        public AuthenticationResult Authentication()
        {
            string postData = string.Format("appId={0}&secret={1}", Constants.AppId, Constants.Secret);
            var url = Constants.AppBaseUrl + "/iocm/app/sec/v1.1.0/login";//名称大小写不能错
            HttpHelper helper = new HttpHelper();
            helper.COntentType= "application/x-www-form-urlencoded";
            helper.ClientCertificates = new X509CertificateCollection() { new X509Certificate2(Constants.CertFilePath, Constants.CertPassword) };
            string cOntent= helper.GetHtml(url, postData, true);
            var result = JsonConvert.DeserializeObject(content);
            return result;
        }

对于Token的刷新操作，封装也是类似操作

///


        /// 刷新token。
        /// 应用服务器通过鉴权接口获取到的accessToken是有有效时间的，在accessToken快过期时，
        /// 应用服务器通过调用此接口，获取新的accessToken。
        ///

///

/// 刷新token，用来获取一个新的accessToken。refreshToken在调用鉴权接口或刷新token接口时获得。 /// /// public AuthenticationResult RefreshToken(string refreshToken) { string postData = new { appId = Constants.AppId, secret = Constants.Secret, refreshToken = refreshToken }.ToJson(); var url = Constants.AppBaseUrl + "/iocm/app/sec/v1.1.0/refreshToken";//名称大小写不能错 var result = WeJsonHelper.ConvertJson(url, postData); return result; }

///

/// 刷新token。
/// 应用服务器通过鉴权接口获取到的accessToken是有有效时间的，在accessToken快过期时，
/// 应用服务器通过调用此接口，获取新的accessToken。
///

///

/// 刷新token，用来获取一个新的accessToken。refreshToken在调用鉴权接口或刷新token接口时获得。
///
///
public AuthenticationResult RefreshToken(string refreshToken)
{
string postData = new
{
appId = Constants.AppId,
secret = Constants.Secret,
refreshToken = refreshToken
}.ToJson();
var url = Constants.AppBaseUrl + “/iocm/app/sec/v1.1.0/refreshToken”;//名称大小写不能错
var result = WeJsonHelper.ConvertJson(url, postData);
return result;
}

上面有些是为了方便操作，定义了一些公用类库，以减少代码的重复。

一般除了鉴权外的所有的API，它们处理方式都类似的，都是以 application/json 格式进行交互，使用POST、PUT、GET、Delete操作方式实现对数据的处理。

而且它们都需要有固定的请求头信息，我们以设备注册为例进行介绍。

一般我们可以通过一个函数封装，对接口的头部请求信息进行设置，如下所示。

///


        /// 通用获取头部信息
        ///

///

接口访问口令 /// protected NameValueCollection GetHeader(string accessToken) { var header = new NameValueCollection(); header.Add(Constants.HEADER_APP_KEY, Constants.AppId); header.Add(Constants.HEADER_APP_AUTH, string.Format("Bearer {0}", accessToken)); return header; }

///

/// 通用获取头部信息
///

///

接口访问口令
///
protected NameValueCollection GetHeader(string accessToken)
{
var header = new NameValueCollection();
header.Add(Constants.HEADER_APP_KEY, Constants.AppId);
header.Add(Constants.HEADER_APP_AUTH, string.Format(“Bearer {0}”, accessToken));
return header;
}

然后在定义请求的JSON和返回的JSON对应的实体类对象，封装对应的API接口即可。

例如，我们注册设备的接口封装如下所示。

///


    /// 设备管理接口实现
    ///


    public class DeviceApi : BaseCommon, IDeviceApi
    {
        /// 
        /// 注册设备（验证码方式）。
        /// 在设备接入物联网平台前，应用服务器需要调用此接口在物联网平台注册设备，并设置设备的唯一标识（如IMEI）。
        /// 在设备接入物联网平台时携带设备唯一标识，完成设备的接入认证。
        /// 

        /// 
        ///

/// public RegDeviceResult RegisterDevice(string accessToken, RegDeviceJson info) { var header = GetHeader(accessToken); string postData = info.ToJson(); var url = Constants.AppBaseUrl + "/iocm/app/reg/v1.1.0/deviceCredentials";//名称大小写不能错 url += string.Format("?appId={0}", Constants.AppId); var result = WeJsonHelper.ConvertJson(url, postData, header); return result; } ......

///

/// 设备管理接口实现
///

public class DeviceApi : BaseCommon, IDeviceApi
{
///

/// 注册设备（验证码方式）。
/// 在设备接入物联网平台前，应用服务器需要调用此接口在物联网平台注册设备，并设置设备的唯一标识（如IMEI）。
/// 在设备接入物联网平台时携带设备唯一标识，完成设备的接入认证。
///

///

///
public RegDeviceResult RegisterDevice(string accessToken, RegDeviceJson info)
{
var header = GetHeader(accessToken);
string postData = info.ToJson();
var url = Constants.AppBaseUrl + “/iocm/app/reg/v1.1.0/deviceCredentials”;//名称大小写不能错
url += string.Format(“?appId={0}”, Constants.AppId);
var result = WeJsonHelper.ConvertJson(url, postData, header);
return result;
}
……

这里请求的信息是 RegDeviceJson ，返回信息的类是RegDeviceResult 。我们依照API定义，实现对应的处理即可。

为了方便处理，我们可以把这些对应设备的实体类定义在一个文件里面，如DeviceJson.cs里面，如下所示，这样非常方便我们管理。

其他业务范畴的Api也是如此封装，不在一一赘述。

我们测试的时候，可以建立一个单独的Winform项目进行接口功能的测试，也可以自己编写单元测试代码进行测试，根据自己熟练程度选择吧。

例如鉴权接口测试代码如下所示，我们可以看看输出进行判断是否正常工作。

private void btnLogin_Click(object sender, EventArgs e) { var result = basicApi.Authentication(); Console.WriteLine(result != null ? "accessToken:" + result.ToJson() : "获取结果出错"); if (result != null) { var refreshResult = basicApi.RefreshToken(result.refreshToken); Console.WriteLine(refreshResult != null ? "accessToken:" + refreshResult.ToJson() : "获取结果出错"); this.accessToken = refreshResult.accessToken;//记录待用 } }

private void btnLogin_Click(object sender, EventArgs e)
{
var result = basicApi.Authentication();
Console.WriteLine(result != null ? “accessToken:” + result.ToJson() : “获取结果出错”);
if (result != null)
{
var refreshResult = basicApi.RefreshToken(result.refreshToken);
Console.WriteLine(refreshResult != null ? “accessToken:” + refreshResult.ToJson() : “获取结果出错”);
this.accessToken = refreshResult.accessToken;//记录待用
}
}

设备注册的功能测试如下所示。

private void btnRegDevice_Click(object sender, EventArgs e) { if (string.IsNullOrEmpty(accessToken)) { MessageUtil.ShowTips("请先鉴权获取AccessToken"); return; } var deviceApi = new DeviceApi(); var regDeviceInfo = new RegDeviceJson() { endUserId = "64bf5869-b271-4007-8db8-fab185e19c10", nodeId = "64bf5869-b271-4007-8db8-fab185e19c10", psk = "12345678", timeout = 0, verifyCode = "", deviceInfo = new DeviceJson() { deviceType = "Smoke", manufacturerId = "49ac78c99f3e453598c155870efe8bfc", manufacturerName = "iqidi", //与manufacturerId、manufacturerName、deviceType、model和protocolType系列参数二选一 //productId = "5d9bf49b6a018f02d04cae28", model = "1001", name = "NBSimulator", imsi = "fafafasfasf", mac = "testetst", isSecurity = true.ToString().ToUpper(), protocolType = "LWM2M", } }; var regResult = deviceApi.RegisterDevice(accessToken, regDeviceInfo); Console.WriteLine(regResult != null ? regResult.ToJson() : "no regResult"); }

private void btnRegDevice_Click(object sender, EventArgs e)
{
if (string.IsNullOrEmpty(accessToken))
{
MessageUtil.ShowTips(“请先鉴权获取AccessToken”);
return;
}
var deviceApi = new DeviceApi();
var regDeviceInfo = new RegDeviceJson()
{
endUserId = “64bf5869-b271-4007-8db8-fab185e19c10”,
nodeId = “64bf5869-b271-4007-8db8-fab185e19c10”,
psk = “12345678”,
timeout = 0,
verifyCode = “”,
deviceInfo = new DeviceJson()
{
deviceType = “Smoke”,
manufacturerId = “49ac78c99f3e453598c155870efe8bfc”,
manufacturerName = “iqidi”,
//与manufacturerId、manufacturerName、deviceType、model和protocolType系列参数二选一
//productId = “5d9bf49b6a018f02d04cae28”,
model = “1001”,
name = “NBSimulator”,
imsi = “fafafasfasf”,
mac = “testetst”,
isSecurity = true.ToString().ToUpper(),
protocolType = “LWM2M”,
}
};
var regResult = deviceApi.RegisterDevice(accessToken, regDeviceInfo);
Console.WriteLine(regResult != null ? regResult.ToJson() : “no regResult”);
}