iOS开发之使用MQTT协议实现远程通讯

2018/05/11 18:08
阅读数 38

一、协议简介:

1、MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,有可能成为物联网的重要组成部分。该协议支持所有平台,几乎可以把所有联网物品和外部连接起来,被用来当做传感器和致动器。

 

二、协议特点:

1、MQTT是为大量计算能力有限,且工作在低带宽、不可靠的网络的远程传感器和嵌入式控制设备通讯而设计的协议,它具有以下主要的几项特性:

1》、使用发布/订阅消息模式,提供一对多的消息发布,解除应用程序耦合;

2》、对负载内容屏蔽的消息传输;

3》、使用 TCP/IP 提供网络连接;

4》、有三种消息QoS发布服务质量;

A、“至多一次”,消息发布完全依赖底层 TCP/IP 网络。会发生消息丢失或重复。这一级别可用于如下情况,环境传感器数据,丢失一次读记录无所谓,因为不久后还会有第二次发送。

B、“至少一次”,确保消息到达,但消息重复可能会发生。

C、“只有一次”,确保消息到达一次。这一级别可用于如下情况,在计费系统中,消息重复或丢失会导致不正确的结果。

5、小型传输,使用很小(固定长度的头部是2字节),协议交换最小化,以降低网络流量;

6、使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制。

 

三、协议应用场景:

1、移动消息、物联网、车联网、智能硬件甚至能源勘探等

2、设计模式支持:1个字节报头、2个字节心跳、消息QoS

 

四、使用MQTT协议集成iOS客户端步骤:

1、github上搜索资料MQTT并下载,会出现两个(建议使用第二个):

A、MQTTKit:停止更新  下载地址:https://github.com/mobile-web-messaging/MQTTKit

B、MQTTClient:经常更新  下载地址:https://github.com/novastone-media/MQTT-Client-Framework

 

2、导入MQTT和SocketRocket两个框架到工程,如果遇到编译报错"_utf8_nextCharSafeBody", referenced from:,记得添加系统依赖库libicucore.tbd

 

3、创建传输类型

 MQTTCFSocketTransport* transport=[[MQTTCFSocketTransport alloc]init];

 transport.host=@"192.168.1.1";

 transport.port=[@"8080" intValue];

 

4、创建会话任务并设置代理

  MQTTSession* session=[[MQTTSession alloc]init];

  session.delegate=self;

  session.transport=transport;

  session.userName=@"peter";

  session.password=@"123456";

 

5、订阅主题

    BOOL isSucess =   [session connectAndWaitTimeout:30];//连接会话, 设置超时时间

    if(isSucess){

       [session subscribeToTopic:nil atLevel:MQTTQosLevelAtMostOnce subscribeHandler:^(NSError *error, NSArray<NSNumber *> *gQoss) {

        

        if (error) {

            NSLog(@"连接失败:%@",error.localizedDescription);

        }else{

            NSLog(@"连接成功:%@",gQoss);

        }

      

       }];

        

    }

 

5、KVO监听状态

[self.session addObserver:self forKeyPath:@"ststus" options:NSKeyValueObservingOptionOld context:nil];

 

-(void)observeValueForKeyPath:(NSString *)keyPath ofObject:(id)object change:(NSDictionary<NSKeyValueChangeKey,id> *)change context:(void *)context{

    

    //正在断开连接

    if (self.session.status==MQTTSessionStatusDisconnecting) {

        [self.session connect];//重新连接

    }

    

}

 

6、发送数据

- (void)sending:(MQTTSession *)session type:(MQTTCommandType)type qos:(MQTTQosLevel)qos retained:(BOOL)retained duped:(BOOL)duped mid:(UInt16)mid data:(NSData *)data{

    

    [session publishAndWaitData:data

                        onTopic:@"topic"

                         retain:NO

                            qos:MQTTQosLevelAtLeastOnce];

 

}

 

7、接收数据

-(void)newMessage:(MQTTSession *)session data:(NSData *)data onTopic:(NSString *)topic qos:(MQTTQosLevel)qos retained:(BOOL)retained mid:(unsigned int)mid{

    

    NSDictionary* dict=[NSJSONSerialization JSONObjectWithData:data options:NSJSONReadingMutableContainers error:nil];

    self.dataDict=dict;//保存全局属性

    

    if ([topic rangeOfString:@"device_control"].location!=NSNotFound) {

           //控制设备

        

    }

  

}

 

8、断开服务连接

- (void)connectionClosed:(MQTTSession *)session{

    

    [session disconnect];//断开

    [session close];//关闭

    

}

 

9、取消订阅服务 

- (void)unsubAckReceived:(MQTTSession *)session msgID:(UInt16)msgID{

    

    [session unsubscribeTopic:@"topic" unsubscribeHandler:^(NSError *error) {

        

    }];

    

}

 

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部