过程中XMPP架构的一个扩展对于ejabberd快速重新连接和Push模式

Question

我使用的是为ejabberd由一个XMPPFramework扩展名为ProcessOne有困难。

我想使用ProcessOne扩展对于快速重新连接和Push模式

// Process One Fast Reconnect & Push Standby Mode // 

xmppProcessOne = [[XMPPProcessOne alloc] initWithDispatchQueue:dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_BACKGROUND, 0)]; 
[xmppProcessOne addDelegate:self delegateQueue:dispatch_get_main_queue()]; 
xmppProcessOne.pushConfiguration = [self setPushconfiguration]; 
[xmppProcessOne activate:_xmppStream]; 

按ejabberd文档，我有流功能确认后发送重新绑定包。 中有正在实施XMPPRebindAuthentication的这个扩展可用的方法。我无法理解如何调用此方法。

Answer 1

我不认为代码以支持扩展的会话重新绑定/ ProcessOne在XMPPFramework是完整的，可以作为是。

这里有一个补丁，我建议在XMPPFramework应该工作：https://github.com/processone/XMPPFramework/commit/67a20c28b28ca49667ca11012bb2a11373023057

至少我可以从那里使用下面的例子让客户重新绑定工作：

• AppDelegate.h

// 
// AppDelegate.h 
// 
// Created by Mickaël Rémond on 07/03/16. 
// 

#import <UIKit/UIKit.h> 

#import <XMPPFramework/XMPPRoster.h> 
#import <XMPPFramework/XMPPRosterCoreDataStorage.h> 
#import <XMPPFramework/XMPPProcessOne.h> 

@interface AppDelegate : UIResponder <UIApplicationDelegate, XMPPRosterDelegate, XMPPStreamDelegate> 

@property (strong, nonatomic) UIWindow *window; 

/* XMPP related properties */ 
@property (nonatomic, strong) XMPPStream *xmppStream; 
@property (nonatomic, strong) XMPPRoster *xmppRoster; 
@property (nonatomic, strong) XMPPProcessOne *xmppProcessOne; 
@property (nonatomic, strong) XMPPRosterCoreDataStorage *xmppRosterStorage; 

@end 

• AppDelegate.m

// 
// AppDelegate.m 
// 
// Created by Mickaël Rémond on 07/03/16. 
// 

#import "AppDelegate.h" 

#import "DDLog.h" 
#import "DDTTYLogger.h" 
#import "XMPPLogging.h" 

@interface AppDelegate() 
- (void)setupStream; 
- (BOOL)connect; 
@end 

@implementation AppDelegate 

static NSString * const kMyJid = @"[email protected]"; 
static NSString * const kMyPass = @"passw0rd"; 

- (BOOL)application:(UIApplication *)application didFinishLaunchingWithOptions:(NSDictionary *)launchOptions { 
    // Log all XMPP traffic for debugging 
    [DDLog addLogger:[DDTTYLogger sharedInstance] withLogLevel:XMPP_LOG_FLAG_SEND_RECV]; 
    [self setupStream]; 

    return YES; 
} 

- (void)applicationWillResignActive:(UIApplication *)application { 
} 

- (void)applicationDidEnterBackground:(UIApplication *)application { 
} 

- (void)applicationWillEnterForeground:(UIApplication *)application { 
} 

- (void)applicationDidBecomeActive:(UIApplication *)application { 
    [self connect]; 
} 

- (void)applicationWillTerminate:(UIApplication *)application { 
} 

#pragma mark == Setup XMPP parameters == 
- (void)setupStream { 
    _xmppStream = [XMPPStream new]; 
    _xmppRosterStorage = [XMPPRosterCoreDataStorage new]; 
    _xmppRoster = [[XMPPRoster alloc] initWithRosterStorage:_xmppRosterStorage]; 

    [_xmppRoster activate:_xmppStream]; 

    [_xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()]; 
    [_xmppStream addDelegate:self.xmppProcessOne delegateQueue:dispatch_get_main_queue()]; 
    [_xmppRoster addDelegate:self delegateQueue:dispatch_get_main_queue()]; 
    [_xmppStream setMyJID:[XMPPJID jidWithString:kMyJid]]; 

    _xmppProcessOne = [[XMPPProcessOne alloc] initWithDispatchQueue:dispatch_get_main_queue()]; 
    // TODO: Method to generate default push configuration 
    NSXMLElement *pushConfiguration = [XMPPProcessOne pushConfigurationContainer]; 
    [pushConfiguration addChild:[XMPPProcessOne keepaliveWithMax:30]];  // Seconds 
    [pushConfiguration addChild:[XMPPProcessOne sessionWithDuration:300]]; // Seconds 
    _xmppProcessOne.pushConfiguration = pushConfiguration; 

    [_xmppProcessOne addDelegate:self delegateQueue:dispatch_get_main_queue()]; 
    [_xmppProcessOne activate:self.xmppStream]; 
} 

#pragma mark == XMPP DELEGATES == 
- (void)xmppStreamDidConnect:(XMPPStream *)sender { 
    if ([self.xmppStream supportsRebind] && self.xmppProcessOne.savedSessionJID != nil) { 
     NSError *error = nil; 
     _xmppRoster.autoFetchRoster = NO; 
     if (![[self xmppStream] rebindSession:self.xmppProcessOne.savedSessionID forJID:self.xmppProcessOne.savedSessionJID withError:&error]) { 
      NSLog(@"Could not send session rebind successfully: %@", error); 
     } 
    } else { 
     NSError *error = nil; 
     _xmppRoster.autoFetchRoster = YES; 
     if (![[self xmppStream] authenticateWithPassword:kMyPass error:&error]) { 
      NSLog(@"Could not send standard password auth info: %@", error); 
     } 
    } 
} 

// Rebind failed, try standard auth 
- (void)xmppStream:(XMPPStream *)sender runFallbackAuthentication:(NSXMLElement *)error { 
    NSLog(@"Rebind failed: %@", error); 
    NSError *error2 = nil; 
    _xmppRoster.autoFetchRoster = YES; 
    if (![[self xmppStream] authenticateWithPassword:kMyPass error:&error2]) { 
     NSLog(@"did not authenticate %@", error2); 
    } 
} 

- (void)xmppStream:(XMPPStream *)sender didNotAuthenticate:(NSXMLElement *)error { 
    NSLog(@"Authentication failed: %@", error); 
} 

- (void)xmppStreamDidAuthenticate:(XMPPStream *)sender { 
    NSLog(@"Authentication successfull"); 
    [[self xmppStream] sendElement:[XMPPPresence presence]]; 
} 

/* Initiate TCP connection to XMPP server */ 
- (BOOL)connect { 
    if (!self.xmppStream.isConnected) { 
     if (![self.xmppStream isDisconnected]) { 
      return YES; 
     } 

     NSError *error = nil; 
     if (![self.xmppStream connectWithTimeout:XMPPStreamTimeoutNone error:&error]) { 
      NSLog(@"Error connecting to XMPP server"); 
     } else { 
      NSLog(@"Successfully connected"); 
     } 

     return YES; 
    } else { 
     return YES; 
    } 
} 

@end