因为公司业务需要，需要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来导入框架
这个是github上面地址，兄弟们以后直接在这里下载即可
https://github.com/knightSaber/MQTTServer
