iOS MQTT

因为公司业务需要，需要app能够实时监听服务器传过来信息来更新UI界面，这和传统app向服务器来发送请求不同，所以在后台的建议下采用了MQTT。而MQTTKit是我找到比较轻量级，比较清新的框架，但是这个框架存在一些问题。这篇文章就是来解决这些问题的。

废话不多说，直接进入主题。

94F63320-B2C2-4D19-AD83-C62CE9D1AEA3.png

app端只需要修改这个文件，MQTTKitComeOn，下面那个只是demo可以让你看到效果，但是我们app端只需要MQTTKitComeOn就可以完成连接操作。

如果想看到效果的话，可以用手机模拟开一个客户端MQTTKitComeOn，用模拟器开一个MQTTServer。

我们客户端这边需要做的是，根据设备的唯一标示UUID来创建MQTTClient，并且通过MQTTClient来连接 服务器主机（注意：这里是主机）。

NSString *clientID = [UIDevice currentDevice].identifierForVendor.UUIDString;self.client = [[MQTTClient alloc] initWithClientId:clientID];

这里我们需要四个参数来完成连接，name，password，topic（主题），port（端口）。（这个也是你们后台需要的）

ps：name   password   port是用户在登录后 服务器返回来的

但是在进入MQTTKit内部代码之后发现，MQTTKit压根就没有提供这个接口，而是直接将这几个参数封装在.m里面并且写死了。

所以这时候，我将这四个参数修改了接口。下面这两个都需要修改成下面这样子

MQTTKit.h- (void)connectToHost:(NSString *)host andName:(NSString *)name andPassword:(NSString *)password andPort:(int)port completionHandler:(void (^)(MQTTConnectionReturnCode code))completionHandler;- (void) connectWithCompletionHandler:(NSString *)name andPassword:(NSString *)password andPort:(int)port andCallBack:(void (^)(MQTTConnectionReturnCode code))completionHandler;

MQTTKit.m- (void)connectToHost:(NSString *)host andName:(NSString *)name andPassword:(NSString *)password andPort:(int)port    completionHandler:(void (^)(MQTTConnectionReturnCode code))completionHandler {    self.host = host;//    [self connectWithCompletionHandler:completionHandler];    [self connectWithCompletionHandler:name andPassword:password andPort:port andCallBack:completionHandler];}- (void)connectWithCompletionHandler:(NSString *)name andPassword:(NSString *)password andPort:(int)port andCallBack:(void (^)(MQTTConnectionReturnCode))completionHandler{    self.connectionCompletionHandler = completionHandler;    const char *cstrHost = [self.host cStringUsingEncoding:NSASCIIStringEncoding];    const char *cstrUsername = NULL, *cstrPassword = NULL;    self.username = name;    //    self.password = password;    if (self.username){        cstrUsername = [self.username cStringUsingEncoding:NSUTF8StringEncoding];    }    if (self.password){        cstrPassword = [self.password cStringUsingEncoding:NSUTF8StringEncoding];    }    mosquitto_username_pw_set(mosq, cstrUsername, cstrPassword);    //    printf('name is:%s\n,password is:%s\n',cstrUsername,cstrPassword);    mosquitto_reconnect_delay_set(mosq, self.reconnectDelay, self.reconnectDelayMax, self.reconnectExponentialBackoff);    mosquitto_connect(mosq, cstrHost, port, self.keepAlive);    dispatch_async(self.queue, ^{        LogDebug(@'start mosquitto loop on %@', self.queue);        mosquitto_loop_forever(mosq, -1, 1);        LogDebug(@'end mosquitto loop on %@', self.queue);    });}

代码按照上面修改后，我们来到正式调用的地方来看看怎么使用

#pragma mark -开启mqtt服务- (void)MQTTClientStart{    //这里只是封装了一个单利MQTTClient    MQTTClient * mqttManager = [WXMQTTManager sharedMQTTClientManasger];    //userCachePath是归档地址    WXUser * user = [NSKeyedUnarchiver unarchiveObjectWithFile:userCachePath];    //相关数据都存在的话    if (user && [user.mqtt_password length] > 0 && [user.mqtt_username length] > 0 && [user.mqtt_topic length]> 0) {        dispatch_async(dispatch_get_global_queue(0, 0), ^{            [mqttManager connectToHost:WX_SERVER_HOST andName:user.mqtt_username andPassword:user.mqtt_password andPort:WX_SERVER_PORT completionHandler:^(MQTTConnectionReturnCode code) {                if (code == ConnectionAccepted)//连接成功                {                    // 订阅                    [mqttManager subscribe:user.mqtt_topic withCompletionHandler:^(NSArray *grantedQos) {                        NSLog(@'return:%@',grantedQos);                    }];                }else{                       DDLogInfo(@'出错了 code-->%ld',code);                }            }];            //监听接收数据               [mqttManager setMessageHandler:^(MQTTMessage* message)             {                 dispatch_async(dispatch_get_main_queue(), ^{                     //接收到消息，更新界面时需要切换回主线程                     //             tempShowMessage.text= message.payloadString;                               DDLogInfo(@'%@',message.payloadString);                                      });             }];                    });    }}

• 连接操作需要放在子线程中，不然会阻塞主线程
• 因为对第三方框架进行了修改，不要再使用pods来导入框架

著作权归作者所有