XMPPFramework心跳包类、断线重连类

1.XMPPStream: xmpp基础服务类;
2.XMPPAutoPing 和 XMPPPing两个类: 心跳监听类;
3.XMPPReconnect: 如果失去连接,自动重连
参考资料: http://www.jianshu.com/p/d9de0267c52a
http://www.jb51.net/article/96760.htm

部分代码:
1.初始化XMPP

// 单例方法,略...
// 重新init方法,在里面调用setupStream方法,略...

/** Setup the XMPP stream */
- (void)setupStream {
    //1.初始XMPP基础服务类
    _xmppStream = [[XMPPStream alloc] init];
    [_xmppStream addDelegate:self delegateQueue: dispatch_get_main_queue()];
    //(1)设置服务器地址
    [self.xmppStream setHostName:SERVER];
    //(2)设置端口号
    [self.xmppStream setHostPort:5222];
    //(3)设置当前用户信息
    NSString * userName = [NSString stringWithFormat:@"%@@%@",name, SERVER_NAME];
    //(4)创建JID -- 并且进行XMPP资源绑定
    XMPPJID * myJID = [XMPPJID jidWithString:userName resource:XMPPJIDRESOURCE];
    [self.xmppStream setMyJID:myJID];
    
    //2.
    //(1)初始化花名册
    self.xmppRosterStorage = [XMPPRosterCoreDataStorage sharedInstance];
    self.xmppRoster = [[XMPPRoster alloc] initWithRosterStorage:self.xmppRosterStorage];
    //(2)添加好友模块
    [self.xmppRoster activate:self.xmppStream];
    //同时给_xmppRosterMemoryStorage 和 _xmppRoster都添加了代理
    [self.xmppRoster addDelegate:self delegateQueue:dispatch_get_main_queue()];
    //(3)关掉自动接收好友请求,默认开启自动同意
    [self.xmppRoster setAutoAcceptKnownPresenceSubscriptionRequests:NO];
    [self.xmppRoster setAutoFetchRoster:YES];
    //3.连接服务
    [self.xmppStream connectWithTimeout:XMPPStreamTimeoutNone error:nil];
    //4.心跳包监听、断线自动重连
    //(1)心跳监听类
    _xmppAutoPing = [[XMPPAutoPing alloc] init];
    _xmppAutoPing.pingInterval = 20.f; // 心跳包间隔
    [_xmppAutoPing activate:_xmppStream];
    [_xmppAutoPing addDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
    //(2)断线自动重连类
    _xmppReconnect = [[XMPPReconnect alloc] init];
    _xmppReconnect.autoReconnect = YES;
    _xmppReconnect.reconnectDelay = 0.f;// 一旦失去连接,立马开始自动重连,不延迟
    _xmppReconnect.reconnectTimerInterval = 3.f;// 每隔3秒自动重连一次
    [_xmppReconnect activate:_xmppStream];
    [_xmppReconnect addDelegate:self delegateQueue:dispatch_get_global_queue(0, 0)];
}

2.关于ping,我这边的做法是:客户端每隔20s发送ping包,当客户端发送的两次ping包给服务器后都没收到服务器返回的pong包,就手动断开连接(会立刻进入重连)。

#pragma mark - XMPPAutoPingDelegate
- (void)xmppAutoPingDidReceivePong:(XMPPAutoPing *)sender{
    // 如果至少有1次超时了,再收到ping包,则清除超时次数
    if (pingTimeoutCount > 0) {
        pingTimeoutCount = 0;
    }
}
- (void)xmppAutoPingDidTimeout:(XMPPAutoPing *)sender {
    // 收到两次超时,就disconnect吧
    pingTimeoutCount++;
    if (pingTimeoutCount >= 2) {
        [self.xmppStream disconnect];
    }
}

3.初始化重连类后,把重连类代理回调写上,一旦XMPP断开连接就会走回调方法。

#pragma mark - XMPPReconnectDelegate
- (void)xmppReconnect:(XMPPReconnect *)sender didDetectAccidentalDisconnect:(SCNetworkConnectionFlags)connectionFlags {
    QCLog(@"xmpp意外断开连接。");
}
- (BOOL)xmppReconnect:(XMPPReconnect *)sender shouldAttemptAutoReconnect:(SCNetworkConnectionFlags)connectionFlags {
    reconnectCount++;
    self.isReconnecting = YES;
    QCLog(@"xmpp自动重连...第%@次", @(reconnectCount));
    
    if (reconnectCount < 5) {
    }
    else if (reconnectCount >= 5 && reconnectCount <= 10) {
        [self.xmppReconnect resSetupReconnectTimerWithTimerInterval:9.f];
    }
    else if (reconnectCount > 10 && reconnectCount <= 15) {
        [self.xmppReconnect resSetupReconnectTimerWithTimerInterval:15.f];
    }
    else {
        [self reconnectImmediately];
    }
    return YES;
}
- (void)reconnectImmediately {
    self.xmppReconnect.reconnectTimerInterval = 3.f;
    reconnectCount = 0;
    
    [self.xmppReconnect stop];
    [self.xmppReconnect manualStart];
}

这里需要解释一下,当失去连接的时候,会立马启动重连,前5次每隔3秒重连一下,后5次每隔9秒重连一下,再后面5次就15秒重连一次,如果这15次都失败了,则再按照这个规则做重连。我没有做多少次重连失败就抛弃,这样会对服务器造成一定的压力,可以自行考虑利弊。仔细想想,这么多次都失败了,估计也连不上了吧,应该没必要再去重连了。可以做成如果10次连接都失败了,那就不再重连。等到用户主动触发某操作的时候再启动重连,或者App前后台切换的时候做重连。这些只是个人想法。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 135,833评论 19 139
  • 前言 本文会用实例的方式,将iOS各种IM的方案都简单的实现一遍。并且提供一些选型、实现细节以及优化的建议。 注:...
    涂耀辉阅读 94,922评论 219 1,748
  • 国家电网公司企业标准(Q/GDW)- 面向对象的用电信息数据交换协议 - 报批稿:20170802 前言: 排版 ...
    庭说阅读 13,924评论 6 13
  • 七年时光眨眼即逝,诚然现在的我已不是那时的我,思想有了多少变化,我自己都不清楚。甚至越活越疑惑,越来越多不...
    郭倩Elva阅读 1,823评论 1 2
  • 二战题材的影片,其实我是拒绝去看的。那段经历是中华民族的伤痛,更是世界人民的悲哀。那段历史太过沉重,一切都被蒙上了...
    晶然阅读 5,188评论 0 2

友情链接更多精彩内容