iOS开发-即时通信XMPP

1. 即时通信

　1> 概述

　　即时通讯（Instant Messaging）是目前Internet上最为流行的通讯方式，各种各样的即时通讯软件也层出不穷,服务提供商也提供了越来越丰富的通讯服务功能。

　　即时通讯有多种实现方式，例如：XMPP、环信、融云等。

　2> XMPP(可扩展消息处理现场协议) 

　　XMPP(XML Messages Presence Protocol(可扩展消息处理现场协议))是基于可扩展标记语言（XML）的协议，可用于即时通信（IM）。

　3> XMPP的优点

• 开放

　　XMPP协议是由JSF开源社区组织开发的，不属于任何的机构和个人，从根本上保证了其开放性。

• 标准

　　互联网工程工作组将XMPP于2002年正式列为认可的实时通讯及Presence技术。

• 分布式的网络架构

　　XMPP 协议虽然是基于Client/Server 架构，但是XMPP协议本身并没有这样的限制。网络的架构和电子邮件十分相似，但没有结合任何特定的网络架构，适用范围非常广泛。

• XMPP 协议具有良好的扩展性

　　基于XML 建立起来的应用具有良好的语义完整性和扩展性。

• XMPP 具有很好的弹性

　　XMPP 除了可用在即时通信的应用程序，还能用在网络管理、内容供稿、协同工具、档案共享、游戏、远端系统监控等。

• 安全性

　　XMPP在Client-to-Server通信和Server-to-Server通信中都使用TLS (Transport Layer Security)协议作为通信通道的加密方法，保证通信的安全。

　　XMPP环境的搭建的步骤详见XMPP环境的搭建

2. 工程中添加XMPP

　　将XMPP协议第三方文件拖入工程，下载地址：https://github.com/AlonerOwl/XMPPFramework

3. 登录、注册

　1> 界面搭建

　　界面采用Storyboard，效果图如下：

　2> 初始化XMPP通道

        //初始化通道
        self.xmppStream = [[XMPPStream alloc] init];
        //openfire服务器IP地址
        self.xmppStream.hostName = kHostName;
        //openfire服务器端口 默认5222
        self.xmppStream.hostPort = kHostPort;
        //添加代理
        [self.xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()
         ];

　3> 连接服务器代码所需方法

　4> 登录代码所需方法

　5> 注册代码所需方法

　

　6> 全部代码(方法的使用详见代码注释)

• 封装的XMPP控制器代码：

　　　XMPPManager.h

#import <Foundation/Foundation.h>

#import "XMPPFramework.h"

@interface XMPPManager : NSObject

/// 声明XMPP通道属性
@property (nonatomic, strong) XMPPStream *xmppStream;

+ (XMPPManager *)shareXMPPManager;

// 登录方法
- (void)loginWithUsername:(NSString *)username
                 password:(NSString *)password;
// 注册方法
- (void)registerWithUsername:(NSString *)username
                    password:(NSString *)password;

@end

　　XMPPManager.m

#import "XMPPManager.h"

static XMPPManager *xmppManager = nil;

// 枚举记录状态
typedef NS_ENUM(NSUInteger, ConnectToServerPurpose) {
    ConnectToServerPurposeLogin,
    ConnectToServerPurposeRegister
};

// 遵循协议
@interface XMPPManager () <XMPPStreamDelegate>

/// 用户名
@property (nonatomic, copy) NSString *username;

/// 密码
@property (nonatomic, copy) NSString *password;

/// 记录当前的状态，判断是登录还是注册
@property (nonatomic) ConnectToServerPurpose connectToServer;

@end

@implementation XMPPManager

+ (XMPPManager *)shareXMPPManager
{
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        xmppManager = [XMPPManager new];
    });
    return xmppManager;
}

#pragma mark - 1.创建通道
- (instancetype)init
{
    self = [super init];
    if (self) {
        //初始化对象
        self.xmppStream = [XMPPStream new];
        
        // 设置服务器
        [self settingUpServer];
    }
    return self;
}

// 设置服务器
- (void)settingUpServer
{
    // 设置opfire服务器
    self.xmppStream.hostName = kHostName;
    // 设置服务器端口号
    self.xmppStream.hostPort = kHostPort;
    // 添加代理
    [self.xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()];
}

#pragma mark - 登录的方法
- (void)loginWithUsername:(NSString *)username
                 password:(NSString *)password
{
    self.username = username;
    self.password = password;
    
    // 记录登录状态
    self.connectToServer = ConnectToServerPurposeLogin;
    
    // 连接服务器
    [self linkServer];
}

#pragma mark - 注册的方法
- (void)registerWithUsername:(NSString *)username
                    password:(NSString *)password
{
    self.username = username;
    self.password = password;

    // 记录注册状态
    self.connectToServer = ConnectToServerPurposeRegister;
    
    // 连接服务器
    [self linkServer];
}

#pragma mark - 连接服务器
- (void)linkServer
{
    // 要连接服务器，要有用户身份认证
    // 身份证
    // 参数1：用户名
    // 参数2：域名
    // 参数3：资源
    XMPPJID *jid = [XMPPJID jidWithUser:self.username domain:kDomin resource:kResource];
    
    self.xmppStream.myJID = jid;
    
    // 如果当前聊天工具处于连接状态或已经连接，此时，你需要去切断连接【此逻辑不唯一】
    if ([self.xmppStream isConnected] || [self.xmppStream isConnecting]) {
        // 断开连接
        [self disConnectToServer];
    }
    
    // 设置连接超时
    NSError *error = nil;
    [self.xmppStream connectWithTimeout:30 error:&error];
    if (error) {
        NSLog(@"连接超时");
    }
    
}

#pragma mark - 断开连接（自己写的）
- (void)disConnectToServer
{
    // 当前用户不可用（下线了）
    XMPPPresence *presence = [XMPPPresence presenceWithType:@"unavailable"];
    // 告诉通道用户不可用（下线了）
    [self.xmppStream sendElement:presence];
    // 使用通道失去连接
    [self.xmppStream disconnect];
}

#pragma mark - XMPPStreamDelegate协议方法

#pragma mark 连接超时
- (void)xmppStreamConnectDidTimeout:(XMPPStream *)sender
{
    NSLog(@"连接超时");
}

#pragma mark 连接成功
- (void)xmppStreamDidConnect:(XMPPStream *)sender
{
    NSLog(@"连接成功");
    
    // 认证密码
//    [self.xmppStream authenticateWithPassword:self.password error:nil];
    
    // 区分登录和注册进行密码验证
    switch (self.connectToServer) {
        case ConnectToServerPurposeLogin:
            // 登录认证
            [self.xmppStream authenticateWithPassword:self.password error:nil];
            break;
            
        case ConnectToServerPurposeRegister:
            // 注册的认证
            [self.xmppStream registerWithPassword:self.password error:nil];
            break;
            
        default:
            break;
    }
}

#pragma mark 断开连接
- (void)xmppStreamDidDisconnect:(XMPPStream *)sender withError:(NSError *)error
{
    // 1. 自己动手断开
    // 2. 被动断开
    if (error) {
        NSLog(@"断开连接，error == %@", error);
    }
}

#pragma mark 认证失败
- (void)xmppStream:(XMPPStream *)sender didNotAuthenticate:(DDXMLElement *)error
{
    NSLog(@"认证失败：error = %@", error);
}

#pragma mark 认证成功
- (void)xmppStreamDidAuthenticate:(XMPPStream *)sender
{
    // 当前用户可用（上线了）
    XMPPPresence *presence = [XMPPPresence presenceWithType:@"available"];
    // 告诉通道用户可用（上线了）
    [self.xmppStream sendElement:presence];
    
    NSLog(@"认证成功");
}

@end

• 登录界面

　　LoginViewController.m

#import "LoginViewController.h"

#import "XMPPManager.h"

@interface LoginViewController ()

/// 用户输入框
@property (weak, nonatomic) IBOutlet UITextField *usernameTextField;

/// 密码输入框
@property (weak, nonatomic) IBOutlet UITextField *passwordTextField;

@end

@implementation LoginViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view.
}

- (void)didReceiveMemoryWarning {
    [super didReceiveMemoryWarning];
    // Dispose of any resources that can be recreated.
}

- (IBAction)loginAction:(UIButton *)sender
{
    [[XMPPManager shareXMPPManager] loginWithUsername:self.usernameTextField.text password:self.passwordTextField.text];
}

@end

• 注册界面

　　　RegisterViewController.m

#import "RegisterViewController.h"

#import "XMPPManager.h"

@interface RegisterViewController () <XMPPStreamDelegate>

@property (weak, nonatomic) IBOutlet UITextField *registerUNTextField;
@property (weak, nonatomic) IBOutlet UITextField *registerPWTextField;

@end

@implementation RegisterViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view.
    
    // 添加代理
    [[XMPPManager shareXMPPManager].xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()];
}

- (void)didReceiveMemoryWarning {
    [super didReceiveMemoryWarning];
    // Dispose of any resources that can be recreated.
}

// 按钮点击事件
- (IBAction)registerAction:(id)sender
{
    [[XMPPManager shareXMPPManager] registerWithUsername:self.registerUNTextField.text password:self.registerPWTextField.text];
}

#pragma mark - XMPPStreamDelegate实现协议方法
// 注册成功后，dismiss到登录界面
- (void)xmppStreamDidRegister:(XMPPStream *)sender
{
    NSLog(@"注册成功");
    [self dismissViewControllerAnimated:YES completion:nil];
}

// 注册失败
- (void)xmppStream:(XMPPStream *)sender didNotRegister:(DDXMLElement *)error
{
    NSLog(@"注册失败：%@", error);
}

@end