基于华为物联网IOT的应用开发 --- 基于.net 的SDK封装
最近，物联网的概念比较热门，一大批厂商抢着占领物联网的高低，包括有华为物联网、阿里云物联网、腾讯物联网、AWS物联网等等，没法一一列举，通常物联网包含设备侧开发、平台侧开发、应用侧开发，三个部分构成了线上线下的完整链接，和咱们常规的微信应用、钉钉应用等不一样，物联网的终端是由各类各样的设备组合而成，这些设备经过各类不一样的协议（如CoAP，LWM2M、MQTT）链接到IOT的平台，并且这些设备是低能耗的设备，能够实时的发送数据上来，也能够接受来自IOT平台下发的各类操做指令。本篇随笔主要介绍基于华为物联网IOT的应用开发，实现对.net SDK的封装，方便后期进行应用集成使用。node
一、物联网的相关介绍
物联网其实有点相似咱们之前作的一些行业设备的接入，不过它相对比较通用化一些，能够链接各类各样的类型设备，并且更加安全、低能耗等，咱们之前接入不少设备，可能须要走TCP/UDP协议，而后在后台服务器有一个对这些设备管理的一个Socket服务器，不过和物联网对比，这些都被完全改造过了，以便适应更多的 应用场景，更简化的开发，以及支持更强大的功能吧。json
物联网目前能够针对一些传感器采集一些特定的参数，如光感、温度、湿度、压力、电压、电流等常规的信息，也能够扩展实现语音、图像、视频等方面的采集处理，如经典的智慧路灯应用场景。安全
下面是其中的一个应用的架构设计，主要就是针对这些设备管理，物联网还提供了不少完善的应用API接口，使得咱们能够更加简化对设备的管理（不用架设Socket服务），更加方便的经过API获取相应的信息，节省更多的维护成本。服务器
物联网平台支持海量设备链接上云，设备与云端能够实现稳定可靠地双向通讯。微信
- 提供设备端SDK、驱动、软件包等帮助不一样设备、网关轻松接入物联网云。
- 提供2G/ 3G /4G、NB-IoT、LoRa、WiFi等不一样网络设备接入方案，解决企业异构网络设备接入管理痛点。
- 提供MQTT、CoAP、HTTP/S等多种协议的设备端SDK，既知足长链接的实时性需求，也知足短链接的低功耗需求。
- 开源多种平台设备端代码，提供跨平台移植指导，赋能企业基于多种平台作设备接入。
通常的物联网平台，都会包括产品管理、设备管理、设备组管理、规则引擎管理、消息推送和消息订阅、任务管理、设备升级等等，不一样的物联网云平台有所不一样。网络
物联网的几个相关的协议：架构
MQTT（Message Queue Telemetry Transport）app
MQTT是一个物联网传输协议，被设计用于轻量级的发布/订阅式消息传输，旨在为低带宽和不稳定的网络环境中的物联网设备提供可靠的网络服务。svg
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终端
二、应用侧开发接口
应用侧的开发接口通常云平台都会提供不一样平台的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封装，咱们定义一些系统常见变量，方便在接口中使用。
根据鉴权返回的结果，咱们定义一个对应的实体类来存储这些属性信息，以下所示。
/// <summary> /// 鉴权结果 /// </summary> public class AuthenticationResult : BaseJsonResult { /// <summary> /// 申请权限范围，即accessToken所能访问物联网平台资源的范围，参数值固定为default。 /// </summary> public string scope { get; set; } /// <summary> /// accessToken的类型，参数值固定为Bearer 。 /// </summary> public string tokenType { get; set; } /// <summary> /// accessToken的有效时间，参数值固定为3600秒 /// </summary> public int expiresIn { get; set; } /// <summary> /// 鉴权参数，访问物联网平台API接口的凭证。 /// </summary> public string accessToken { get; set; } /// <summary> /// 鉴权参数，有效时间为1个月，用于“刷新Token”接口。 /// 当accessToken即将过时时，可经过“刷新Token”接口来获取新的accessToken。 /// </summary> public string refreshToken { get; set; } }
而后根据鉴权定义，咱们实现对这个接口的封装处理。
/// <summary> /// IOT鉴权接口实现 /// </summary> public class AuthenticationApi : IAuthenticationApi { /// <summary> /// 用户鉴权 /// 应用服务器首次访问物联网平台的开放API时，需调用此接口完成接入认证； /// 应用服务器在物联网平台的认证过时后，需调用此接口从新进行认证，才能继续访问物联网平台的开放API。 /// </summary> 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<AuthenticationResult>(content); return result; }
对于Token的刷新操做，封装也是相似操做
/// <summary> /// 刷新token。 /// 应用服务器经过鉴权接口获取到的accessToken是有有效时间的，在accessToken快过时时， /// 应用服务器经过调用此接口，获取新的accessToken。 /// </summary> /// <param name="refreshToken"> /// 刷新token，用来获取一个新的accessToken。refreshToken在调用鉴权接口或刷新token接口时得到。 /// </param> /// <returns></returns> 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<AuthenticationResult>.ConvertJson(url, postData); return result; }
上面有些是为了方便操做，定义了一些公用类库，以减小代码的重复。
通常除了鉴权外的全部的API，它们处理方式都相似的，都是以 application/json 格式进行交互，使用POST、PUT、GET、Delete操做方式实现对数据的处理。
并且它们都须要有固定的请求头信息，咱们以设备注册为例进行介绍。
通常咱们能够经过一个函数封装，对接口的头部请求信息进行设置，以下所示。
/// <summary> /// 通用获取头部信息 /// </summary> /// <param name="accessToken">接口访问口令</param> /// <returns></returns> 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接口便可。
例如，咱们注册设备的接口封装以下所示。
/// <summary> /// 设备管理接口实现 /// </summary> public class DeviceApi : BaseCommon, IDeviceApi { /// <summary> /// 注册设备（验证码方式）。 /// 在设备接入物联网平台前，应用服务器须要调用此接口在物联网平台注册设备，并设置设备的惟一标识（如IMEI）。 /// 在设备接入物联网平台时携带设备惟一标识，完成设备的接入认证。 /// </summary> /// <param name="accessToken"></param> /// <param name="info"></param> /// <returns></returns> 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<RegDeviceResult>.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 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"); }
另外对于事件的通知，咱们通常是在应用端被动的进行相应的处理，所以须要对它们的消息进行转换和处理。
针对以上的消息通知，咱们须要定义对应的消息类型，而后进行判断处理。
咱们另起一个项目，而后定义对应给的事件接收处理，以下所示是一个统一的入口处理。
有了一个总入口，咱们把对应通知的信息转换为对应的实体后，就能够进行记录或者响应的处理了。
在后面咱们接着开发应用功能的时候，这些对应的接口API就能够集成整合在咱们的系统中了。
以上就是对于华为物联网IOT平台应用侧的API封装处理的思路， 供你们参考交流。