1.10.1.3.8 设备网关 SDK

优质

小牛编辑

132浏览

2023-12-01

设备网关 SDK

概述
集成方式
初始化
使用说明

前期准备
子设备跟网关建立/删除 topo 关系
子设备上线/下线
子设备上行请求
子设备订阅/取消订阅 topic
监听云端下推子设备数据

设备网关 SDK

更新时间：2018-03-23 17:14:21

概述

设备网关 SDK，提供子设备的管理功能，如子设备添加拓扑，删除拓扑，上线，下线以及数据上下行等

依赖 SDK	概述
长连接通道	提供了 App 生命周期内的，适用于 IoT 业务场景的长连接通道

集成方式

如何集成 SDK，查看这里>

初始化

设备网关 SDK 的初始化依赖长连接通道的初始化，请参见：长连接通道 SDK - 初始化
在长连接通道初始化成功后，再初始化设备网关 SDK。

#import <AlinkAppExpress/AlinkAppExpress.h>
#import <AlinkMobileGateway/AlinkMobileGateway.h>

NSString * traceId = [[LKAppExpress sharedInstance] getClientId];
NSArray * array = [traceId componentsSeparatedByString:@"&"];
NSString * deviceName = [array objectAtIndex:0];
NSString * productKey = [array objectAtIndex:1];
LKMgwConnectConfig * mgwConfig = [LKMgwConnectConfig new];
mgwConfig.productKey =  productKey;//网关三元组之productKey
mgwConfig.deviceName =  deviceName;//网关三元组之deviceName
//[LKMgwEnvSet setRunEnv:LKMgwEnvRelease];//设置开发环境,默认是release
[[LKIoTMobileGateway sharedGateway]startConnect:mgwConfig connectListener:self];

使用说明

前期准备

蓝牙连接已经建立
子设备接入网关
以下流程都是基于子设备跟 APP 已经建立好蓝牙连接通路的前提下。
开发者需要实现以下 protocol，传给网关使用，网关可以因之获取子设备的相关信息。

/**
 子设备的连接通道，如Ble通道，由应用层实现后传入。
 */
@protocol LKIoTSubdeviceConn <NSObject>

/**
 打开子设备连接通道
 @param completionHandler 结果通知
 */

- (void)open:(void (^)(NSError *error))completionHandler;

/**
 关闭子设备连接通道
 @param completionHandler 结果通知
 */

- (void)close:(void (^)(NSError *error))completionHandler;

/**
 判断跟子设备之间的连接是否准备就绪，如果没有就绪，SDK会调用open接口打开
 */

- (BOOL)isReady;

/**
 获取子设备的信息，
 字典key包括：
    "clientId"
   "productKey"
   "deviceName"
   "sign",
   "signMethod"
 对于三元组设备 子设备签名规则同网关相同
 clientId客户端标识，可以取mac，也可以是随机字串，由设备端确定.
 对于蓝牙设备，signMethod指定为sha256
 假定：clientId=123, deviceName=test, productKey=123,deviceSecret=secret. signMethod:"sha256",
 则sign计算规则如下
 sign = sha256(clientId123deviceNametestdeviceSecretsecretproductKey123)
 */

- (NSDictionary *)getSubDeviceInfo;

@end

创建子设备虚拟线路
子设备虚拟线路：网关给每个子设备分配，用于子设备的相关操作。
代码示例

[[LKIoTMobileGateway sharedGateway]setupGatewayLine:_bleSubConn                              complete:^(LKIoTGatewayLine * _Nullable line, NSError * _Nullable err) {
                    _subdeviceLine = line;
                }];
/**
_bleSubConn 为实现了protocol LKIoTSubdeviceConn的类的对象。
子设备虚拟线路会在 complete block中返回，即LKIoTGatewayLine对象。

*/

子设备跟网关建立/删除 topo 关系

所谓 topo 关系，即在 IoT 云端的上下级丛属关系。子设备要通过网关实现数据上下云必须首先跟
网关建立 topo 关系。topo 关系建立后一直存在，直到删除 topo 关系接口或者子设备
跟另外的网关建立了 topo 关系。
在建立 topo 关系的流程中，IoT 云端会校验子设备生成的 sign 值来认证子设备身份。
sign 生成规则参见上边 protocol 里的注释。

建立 topo 示例

[_subdeviceLine addTopo:^(BOOL success, NSError *err, id dataObj) {
        NSLog(@"add topo success : %@", success?@"YES":@"NO"); 
}];
/** 
_subdeviceLine 为上节中建立的虚拟线路

*/

删除 topo 示例

[_subdeviceLine deleteTopo:^(BOOL success, NSError *err, id dataObj) {
        NSLog(@"deleteTopo success : %@", success?@"YES":@"NO"); 
    }];
/** 
_subdeviceLine 为上节中建立的虚拟线路

*/

子设备上线/下线

所谓上线即子设备复用网关跟 IoT云端已经建立好的长连接通路。子设备只有上线成功，才能复用网关
的长连接通路。上线的前提条件是：子设备跟网关已经建立了 topo 关系。
上线成功后，子设备的数据可以上行到云，而云也可下推数据到子设备。

上线示例：

[_subdeviceLine online:^(BOOL success, NSError *err, id dataObj) {
    NSLog(@"sub on line success : %@", success?@"YES":@"NO");
}];
/** 
_subdeviceLine 为上节中建立的虚拟线路

*/

下线示例：

[_subdeviceLine offline:^(BOOL success, NSError *err, id dataObj) {
    NSLog(@"sub on line success : %@", success?@"YES":@"NO");
}];
/** 
_subdeviceLine 为上节中建立的虚拟线路

*/

子设备上行请求

子设备上报设备属性
这是一个 RPC 流程，设备上报属性到云后，云会下发一个业务回执，即上云请求的 reply。
上报属性示例：

NSString * subPk = [_subdeviceLine subDeviceProductKey];
NSString * subDn = [_subdeviceLine subDeviceDeviceName];
NSString * completeTopic = [NSString stringWithFormat:@"/sys/%@/%@/thing/event/property/post", subPk, subDn];

NSString * completeTopicReply = [completeTopic stringByAppendingString:@"_reply"];

    __block __weak typeof(self) this = self;
    _uploadReplylistener = [BreezeLineDownstreamListener new];
    _uploadReplylistener.msgTopic = completeTopicReply;
    _uploadReplylistener.msgId = [NSString stringWithFormat:@"%lld",(long long)[[NSDate date]timeIntervalSince1970]];//请保证msgId的唯一性,
    _uploadReplylistener.replyHandler = ^(NSDictionary *data) {
        __strong typeof(self) strongSelf = this;
        int code = ([data valueForKey:@"code"] != nil ? [[data valueForKey:@"code"] intValue] : -1);
        if (code == 200) {
            [strongSelf insertMsgWithColor:@"blue" main:@"设备属性上报成功" detail:nil];
        } else {
            [strongSelf insertMsgWithColor:@"blue" main: @"设备属性上报失败 : %@" detail:[NSString stringWithFormat:@"错误码 : %d", code]];
        }
        _uploadReplylistener = nil;
    };
    //listener必须自己保证生命周期，因为addDownStreamListener只是weak引用。
    //如果在reply回来时listner已经被析构了，则事件不会上抛了
    [_subdeviceLine addDownStreamListener:YES listener:_uploadReplylistener];

    [_subdeviceLine subscribe:completeTopicReply complete:^(BOOL success, NSError *err) {

        NSDictionary * uploadDic = @{@"id" : _uploadReplylistener.msgId,
                                     @"version":@"1.0",
                                     @"params" : @{@"propertyIdentifier22":@"higuketestproper"},
                                     @"method":@"thing.event.property.post"};
        NSData * uploadDat = [NSJSONSerialization dataWithJSONObject:uploadDic options:NSJSONWritingPrettyPrinted error:nil];

        [_subdeviceLine uploadData:completeTopic data:uploadDat complete:^(BOOL success, NSError *err, id dataObj) {
            NSLog(@"sub upload success : %@", success?@"YES":@"NO");
        }];
    }];
/** 
_subdeviceLine 为上节中建立的虚拟线路，如果网络错误或者业务原因，不一定会有reply，
开发者应考虑reply超时的情况。

*/
//其中BreezeLineDownstreamListener定义如下

typedef void (^ iotReplyHandler)(NSDictionary  *  data);
@interface BreezeLineDownstreamListener : NSObject <LKMgwLineDownListener>
@property(nonatomic, copy) NSString * msgId;
@property(nonatomic, copy) NSString * msgTopic;
@property(nonatomic, strong) iotReplyHandler replyHandler;
@end

@implementation BreezeLineDownstreamListener

- (void)onDownstream:(NSString * _Nonnull)topic data:(id  _Nullable)data {

    NSLog(@"onDownstream topic : %@", topic);
    NSLog(@"onDownstream data : %@", data);
    NSDictionary * replyDict = nil;
    if ([data isKindOfClass:[NSString class]]) {
        NSData * replyData = [data dataUsingEncoding:NSUTF8StringEncoding];
        replyDict = [NSJSONSerialization JSONObjectWithData:replyData options:NSJSONReadingMutableLeaves error:nil];

    } else if ([data isKindOfClass:[NSDictionary class]]) {
        replyDict = data;
    }
    if (replyDict == nil) {
        return;
    }
    NSString * msgId = [replyDict valueForKey:@"id"];
    if ([_msgId isEqualToString:msgId]) {
        if (_replyHandler != nil) {
            _replyHandler(replyDict);
        }
    }
}

子设备数据上云
跟上一节的区别是，数据上云没有业务回执，即云端不会下推 reply。开发者需要根据
具体的业务场景决定使用哪个接口。
代码示例

[_subdeviceLine uploadData:completeTopic data:uploadDat complete:^(BOOL success, NSError *err, id dataObj) {
            NSLog(@"sub upload success : %@", success?@"YES":@"NO");
        }];

子设备订阅/取消订阅 topic

子设备订阅 topic

NSString * subPk = [_subdeviceLine subDeviceProductKey];
NSString * subDn = [_subdeviceLine subDeviceDeviceName];
NSString * completeTopic = [NSString stringWithFormat:@"/sys/%@/%@/thing/service/property/set", subPk, subDn];
//[_subdeviceLine addDownStreamListener:YES listener:self];记得添加listener，否则无法收
//到云端下推信息
[_subdeviceLine subscribe:completeTopic complete:^(BOOL success, NSError * _Nonnull err) {       
}];

子设备取消订阅 topic

NSString * subPk = [_subdeviceLine subDeviceProductKey];
NSString * subDn = [_subdeviceLine subDeviceDeviceName];
NSString * completeTopic = [NSString stringWithFormat:@"/sys/%@/%@/thing/service/property/set", subPk, subDn];
[_subdeviceLine unsubscribe:completeTopic complete:^(BOOL success, NSError * _Nonnull err) {       
}];

监听云端下推子设备数据

代码示例

[_subdeviceLine addDownStreamListener:YES listener:self];
 //其中self 实现了protocol LKMgwLineDownListener