iOS SDK提供了与云端Mqtt长连接的基础能力接口,用户可以直接使用这些接口完成自定义Topic相关的功能。提供的基础能力包括:发布、订阅、取消订阅、订阅下行。可以通过这部分接口实现云端数据的上下行。
上行接口请求
注意 介绍的接口都需要在Mqtt长连接通道建立成功的情况下才可以调用。
调用上行请求接口,SDK封装了上行发布相关接口。使用方法示例如下:
NSString * topic = self.textFieldPubTopic.text;
NSString * content = self.textViewPubContent.text;
NSInteger iQos = [self.textFieldQos.text integerValue];//qos = 0 or 1
[[LinkKitEntry sharedKit] publish:topic
data:[content dataUsingEncoding:NSUTF8StringEncoding]
qos:(int)iQos
resultBlock:^(BOOL succeeded, NSError * _Nullable error) {
LinkkitLogDebug(@"kit publish error : %@", error);
dispatch_async(dispatch_get_main_queue(), ^{
[self ims_showHUDWithMessage:[NSString stringWithFormat:@"Linkkit 上行数据 : %@",
succeeded ? @"成功" : @"失败"]];
});
}];
说明: 1、关于QoS取值,目前阿里云IoT平台只支持QoS取值为[0,1],对于QoS=2目前不支持。 2、IoT云端对于数据上下行有限流设计,请参见 使用限制。
订阅/取消订阅
若设备希望从某个topic接收数据,需要先对该topic进行订阅;如果不再希望接收到来自某个topic的数据,可以取消对该topic的订阅。
订阅示例代码:
- (IBAction)onClickSubscribe:(id)sender {
NSString * topic = self.textFieldSubTopic.text;
[[LinkKitEntry sharedKit] subscribe:topic
resultBlock:^(BOOL succeeded, NSError * _Nullable error) {
LinkkitLogDebug(@"kit subscribe error : %@", error);
dispatch_async(dispatch_get_main_queue(), ^{
[self ims_showHUDWithMessage:[NSString stringWithFormat:@"Linkkit 订阅topic : %@,",
succeeded ? @"成功" : @"失败"]];
});
}];
}
取消订阅示例代码:
- (IBAction)onClickUnsubscribe:(id)sender {
NSString * topic = self.textFieldSubTopic.text;
[[LinkKitEntry sharedKit] unsubscribe:topic
resultBlock:^(BOOL succeeded, NSError * _Nullable error) {
LinkkitLogDebug(@"kit unsubscribe error : %@", error);
dispatch_async(dispatch_get_main_queue(), ^{
[self ims_showHUDWithMessage:[NSString stringWithFormat:@"Linkkit 取消订阅topic : %@,",
succeeded ? @"成功" : @"失败"]];
});
}];
}
下行数据监听
订阅Topic成功后,还需要注册 listener来监听,SDK才会把此Topic的数据上抛。 在 "认证与连接" 章节中,已经描述了如何注册listener来侦听下推数据,同时提供了示例代码,请参阅。