什么是MQTT
MQTT（消息队列遥测传输），基于发布/订阅的消息协议。
MQTT工作在TCP/IP协议族上，是为硬件性能低下的远程设备及网络糟糕的情况下设计的发布/订阅型的消息协议。
在移动消息，物联网，车联网，智能设备等领域有着广泛的应用
MQTT特点
- 使用发布/订阅消息模式，提供一对多的消息发布，解除应用程序的耦合。
- 使用TCP/IP提供网络连接
- 有三种消息发布服务质量
1.至多一次：消息发送可能会丢失或者重复，这一级别情况下，丢失一次数据无所谓，不久后会第二次发送。
2.至少一次：确保消息到达，但是可能会出现消息重复。
3.只有一次：确保消息达到一次。 - 小型传输，开销很小（固定长度的头部是2字节），协议交换最小化，降低网络流量
- 使用 Last Will 和 Testament 特性通知有关各方客户端异常中断的机制
Last Will 定义客户端出现网络异常导致连接中断的情况下，服务器需要做的一些措施。
Last Will（遗嘱），就是有客户端预先定义好的主题和对应消息，附加在头部信息，在连接异常的情况下由服务器主动发布此消息。
MQTTClient使用
MQTTClient是比较优秀的github 针对MQTT封装的开源项目
传送门 MQTT-Client-Framework
初始化 Session
MQTTSession *mqttSession = [[MQTTSession alloc] init];
// 设置签名， 签名唯一性 //MQTT_NAME 为自己配制的字符串
// NSString *clientID = [NSString stringWithFormat:@"iOS-%@", MQTT_NAME];
mqttSession.clientId = @"上面的 clientID"; // clientID
// 订阅主题
MQTTCFSocketTransport *transport = [[MQTTCFSocketTransport alloc] init];
transport.host = @"ip 地址";
transport.port = 8080; //端口号
// 给 session 对象设置基本信息
mqttSession.transport = transport;
// 设置代理 回调信息
mqttSession.delegate = self;
// 设置用户名称
mqttSession.userName = @"用户名称";
// 设置用户密码
mqttSession.password = @"用户密码";
// 设置会话链接超时时间
[mqttSession connectAndWaitTimeout: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];
// 进行下一步操作
}
给主题发送消息
//发送消息
[mqttSession publishData:[NSData data] onTopic:@"所订阅的主题" retain:NO qos:MQTTQosLevelAtMostOnce publishHandler:^(NSError *error) {
if (error) {
// 发送失败则 重新登录 mqtt 进行重发
// [self getMQTTServerAnew];
}else {
//主题发送成功
NSLog(@"主题 %@ 发送成功", @"所订阅的主题");
}
}];
End
如有疑问或者错误处，欢迎探讨和指正。
