在 XMPP 框架中处理一个扩展，用于快速重新连接和推送模式

Question

我在使用一个名为ProcessOne的XMPPFramework扩展时遇到困难，该扩展是为ejabberd制作的。

我正在尝试使用ProcessOne扩展进行快速重新连接和推送模式

// 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

我认为在

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 = @"[e-mail]";
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