macOS开发之集成MQTT

首先小伙伴们看过MQTT在github上面的简介的话就知道，iOS和macOS两端都是支持的，使用方式也是一样的，因为我最近在编写MacOS客户端所以标题就这样写了

什么是MQTT

MQTT（消息队列遥测传输），基于发布/订阅的消息协议。
MQTT工作在TCP/IP协议族上，是为硬件性能低下的远程设备及网络糟糕的情况下设计的发布/订阅型的消息协议。
在移动消息，物联网，车联网，智能设备等领域有着广泛的应用

MQTT特点

1. 使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序的耦合。
2. 使用TCP/IP提供网络连接
3. 有三种消息发布服务质量
   • MQTTQosLevelAtMostOnce至多一次：消息发送可能会丢失或者重复，这一级别情况下，丢失一次数据无所谓，不久后会第二次发送
   • MQTTQosLevelAtLeastOnce至少一次：确保消息到达，但是可能会出现消息重复。
   • MQTTQosLevelExactlyOnce只有一次：确保消息达到一次。
4. 小型传输，开销很小（固定长度的头部是2字节），协议交换最小化，降低网络流量
5. 使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制
   Last Will 定义客户端出现网络异常导致连接中断的情况下，服务器需要做的一些措施。
   Last Will（遗嘱），就是有客户端预先定义好的主题和对应消息，附加在头部信息，在连接异常的情况下由服务器主动发布此消息。

MQTTClient使用

MQTTClient是比较优秀的github 针对MQTT封装的开源项目
传送门 MQTT-Client-Framework

1. 导入头文件#import <MQTTClient/MQTTClient.h>
2. 初始化 Session：初始化时间需要几秒，不建议放在UI线程，个人建议异步操作

//需要强引用
    _session = [[MQTTSession alloc] init];
    _session.clientId = self.mqttSettings[@"groupId"];
    MQTTCFSocketTransport *transPort = [[MQTTCFSocketTransport alloc] init];
    transPort.host = self.mqttSettings[@"host"];
    transPort.port = [self.mqttSettings[@"port"] intValue];
    _session.transport = transPort;
    _session.delegate = self;
    _session.userName = [NSString stringWithFormat:@"Signature|%@|%@",self.mqttSettings[@"accessKey"],self.mqttSettings[@"instanceId"]];
    _session.password = [self macSignWithText:_session.clientId secretKey:self.mqttSettings[@"secretKey"]];
    _session.keepAliveInterval = 60;//心跳间隔
    [_session connectAndWaitTimeout:3];

• self.mqttSettings属性是NSDictionary类型哈，里面的相关参数如下图所示
  

3. SessionMangerDelegate 回调 在连接成功后订阅主题

#pragma mark - MQTTSession Delegate
/**
 订阅主题回调
 */
- (void)connected:(MQTTSession *)session {
    
    // MQTT连接成功，进行订阅主题 设置主题 服务质量
    [session subscribeToTopic:@"主题名称" atLevel:MQTTQosLevelAtMostOnce];
    
}
/**
 订阅主题失败
 */
- (void)connectionError:(MQTTSession *)session error:(NSError *)error {
    

}
/**
 连接状态回调
 */
- (void)handleEvent:(MQTTSession *)session event:(MQTTSessionEvent)eventCode error:(NSError *)error {
    
    NSDictionary *events = @{
                             @(MQTTSessionEventConnected): @"连接成功",
                             @(MQTTSessionEventConnectionRefused): @"连接被拒绝",
                             @(MQTTSessionEventConnectionClosed): @"连接关闭",
                             @(MQTTSessionEventConnectionError): @"连接错误",
                             @(MQTTSessionEventProtocolError): @"协议不被接受/协议错误",
                             @(MQTTSessionEventConnectionClosedByBroker): @"其余错误"
                             };
    
}

/**
 收到消息
 */
- (void)newMessage:(MQTTSession *)session data:(NSData *)data onTopic:(NSString *)topic qos:(MQTTQosLevel)qos retained:(BOOL)retained mid:(unsigned int)mid {
    
    NSDictionary *dic = [NSJSONSerialization JSONObjectWithData:data options:kNilOptions error:nil];
    
    // 进行下一步操作
    
}

4. 发送消息

 //发送消息
    [mqttSession publishData:[NSData data] onTopic:@"所订阅的主题" retain:NO qos:MQTTQosLevelAtMostOnce publishHandler:^(NSError *error) {
        
        if (error) {

            // 发送失败则 重新登录 mqtt 进行重发
         //   [self getMQTTServerAnew];
            
        }else {
            //主题发送成功
            NSLog(@"主题 %@ 发送成功", @"所订阅的主题");
        }
        
    }];

有什么疑问小伙伴们可以在留言区留言