美文网首页xmppframeWork
XMPPFramework心跳包类、断线重连类

XMPPFramework心跳包类、断线重连类

作者: 路漫漫其修远兮Wzt | 来源:发表于2017-02-15 16:25 被阅读1594次

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前后台切换的时候做重连。这些只是个人想法。

相关文章

  • XMPPFramework心跳包类、断线重连类

    1.XMPPStream: xmpp基础服务类;2.XMPPAutoPing 和 XMPPPing两个类: 心跳监...

  • 小程序WebSocket实践(心跳检测、断线重连)

    我把小程序WebSocket的一些功能封装成一个类,里面包括建立连接、监听消息、发送消息、心跳检测、断线重连等等常...

  • netty 心跳包和断线重连机制

    为什么需要心跳包??? 心跳包主要是用来做TCP长连接保活的。有时 socket 虽然是连接的但中间网络可能有问题...

  • 非同源策略请求/WebSocket

    WebSocket使用及优化(心跳机制与断线重连)https://juejin.cn/post/694505737...

  • 长连接、心跳和断线重连

    一、概述 目前IM软件有一个基本的功能就是长在线,即只要有网络就保持登录,然而,网络状态是无法预测的,所以...

  • 状态同步的断线重连

    最近陆陆续续在给游戏做断线重连相关的工作,大厅服的断线重连问题不是很大,难点主要在于战斗中的断线重连。断线重连要解...

  • 断线重连问题综述

    断线重连主要涉及到几个问题: 判定断线 怎么重连 重连后如何还原游戏环境 判定断线有两种方式,(1)是超时判定断线...

  • 断线重连

    今天看了下之前游戏登录相关逻辑,重新整理下断线重连的一些做法。 首先,介绍下断线的几种常见情况:情况一:客户端网络...

  • 断线重连

    using System; using System.Collections; using System.Coll...

  • 【Netty】心跳机制与断线重连

    欢迎关注公众号:【爱编码】如果有需要后台回复2019赠送1T的学习资料哦!! 心跳是啥 在 TCP 长连接中, 客...

网友评论

    本文标题:XMPPFramework心跳包类、断线重连类

    本文链接:https://www.haomeiwen.com/subject/ywmqwttx.html