XMPP(更新中...)

什么是XMPP

• XMPP協(xié)議是由JSF開(kāi)源組織開(kāi)發(fā)的,不屬于任何機(jī)構(gòu),保證了開(kāi)放性
• XMPP是一種典型的C/S架構(gòu),基本的網(wǎng)絡(luò)形式是通過(guò)TCP/IP連接到服務(wù)器,通過(guò)socket建立連接,傳輸?shù)氖荴ML數(shù)據(jù)
• XMPP是基于XML建立的,具有良好的擴(kuò)展性
• XMPP與HTTP:XMPP與HTTP都是協(xié)議,HTTP協(xié)議是短連接,常用于網(wǎng)絡(luò)上不定時(shí)的數(shù)據(jù)請(qǐng)求,XMPP是一種長(zhǎng)連接,基于XML的即時(shí)通訊的協(xié)議
• XMPP本身是協(xié)議,JSF在socket原理的基礎(chǔ)上,加入XMPP協(xié)議,定義出了叫XMPP的framework,它實(shí)現(xiàn)了即時(shí)通訊基本的功能:注冊(cè),登錄,好友,收發(fā)消息等等;
• XMPP只實(shí)現(xiàn)了消息的收發(fā),并沒(méi)有定義附件(視頻,音頻,文件)的收發(fā),所以需要我們自己手動(dòng)封裝收發(fā)附件的方法

搭建即時(shí)通訊環(huán)境

• XMPP只提供了一套框架,所以服務(wù)器端需要我們自己集成
• 網(wǎng)上有很多詳細(xì)介紹即時(shí)通訊服務(wù)器的文章,這里不做過(guò)多的說(shuō)明
• 大概的順序:xampp下載 - openfire下載(java環(huán)境,如果沒(méi)有就先集成) -
  xampp(建立數(shù)據(jù)庫(kù)) - oeprfire搭建服務(wù)器, 到這里可以選擇用spark做測(cè)試,也可以自己寫(xiě)客戶(hù)端做測(cè)試

XMPP的基本用法

注冊(cè)和登錄

• 無(wú)論注冊(cè)還是登陸,都需要初始化一個(gè)消息通道類(lèi)(XMPPStream),一把情況下會(huì)抽出一個(gè)單利,來(lái)封裝這些功能,所以把初始化寫(xiě)在單利的初始化中

/**  保存登錄用戶(hù)名 */
@property (nonatomic,copy) NSString *loginUserName;
/**  登錄or注冊(cè) */(這里記錄是登陸還是注冊(cè),為了在連接成功的時(shí)候,判斷是驗(yàn)證密碼還是向服務(wù)器發(fā)送密碼)
@property (nonatomic,assign) ConnectType connectType;



/** 初始化 */
- (instancetype)init
{
    self = [super init];
    if (self) {
        //初始化消息通道
        self.stream = [[XMPPStream alloc] init];
        //設(shè)置域名
        self.stream.hostName = kHostName;
        //設(shè)置端口
        self.stream.hostPort = kHostPort;
        //添加代理
        [self.stream addDelegate:self delegateQueue:dispatch_get_main_queue()];
    }
    return self;
}
#pragma mark  連接的代理方法
//連接超時(shí)
- (void)xmppStreamConnectDidTimeout:(XMPPStream *)sender
{
    if (self.loginFail) {
        DDXMLElement *error = [DDXMLElement elementWithName:@"連接超時(shí)"];
        self.loginFail(error);
    }
}
//連接成功
- (void)xmppStreamDidConnect:(XMPPStream *)sender
{
    switch (self.connectType) {
            //登錄狀態(tài)
        case ConnectTypeLogin:
            //驗(yàn)證密碼
            [self.stream authenticateWithPassword:self.loginPassword error:nil];
            break;
            //注冊(cè)狀態(tài)
        case ConnectTypeRegist:
            //發(fā)送密碼
            [self.stream registerWithPassword:self.registPassword error:nil];
            break;
    }
}
//連接斷開(kāi)
- (void)xmppStreamDidDisconnect:(XMPPStream *)sender withError:(NSError *)error
{
    if (error) {
        NSError *err = nil;
        [self.stream connectWithTimeout:-1 error:&err];
    }
}

• 注冊(cè)

/**  保存注冊(cè)密碼 */
@property (nonatomic,copy) NSString *registPassword;
/**  注冊(cè)成功block */
@property (nonatomic,copy) void (^registSuccess)(id);
/**  注冊(cè)失敗的block */
@property (nonatomic,copy) void (^registFail)(DDXMLElement *);



/** 注冊(cè) */
- (void)registWithUserName:(NSString *)userName password:(NSString *)password success:(void(^)(id data))success fail:(void(^)(DDXMLElement *error))fail
{
    //標(biāo)記狀態(tài)為注冊(cè)
    self.connectType = ConnectTypeRegist;
    //連接服務(wù)器
    self.stream.myJID = [XMPPJID jidWithUser:userName domain:kDomin resource:kResource];
    //判斷是否在連接狀態(tài)(這里防止循環(huán)注冊(cè)問(wèn)題,即已經(jīng)連接成功了,就應(yīng)該斷開(kāi)再去注冊(cè))
    if ([self.stream isConnected] || [self.stream isConnecting]) {
        //斷開(kāi)連接
        [self.stream disconnect];
    }
    [self.stream connectWithTimeout:-1 error:nil];
    //保存?zhèn)魅氲闹?由于要在代理方法中才能發(fā)送密碼,接收到是否注冊(cè)成功,所以定義屬性保存各個(gè)值)
    self.registPassword = password;
    self.registSuccess = success;
    self.registFail = fail;
}
#pragma mark 注冊(cè)的代理方法
//注冊(cè)成功
- (void)xmppStreamDidRegister:(XMPPStream *)sender
{
    if (self.registSuccess) {
        self.registSuccess(@"注冊(cè)成功");
    }
}
//注冊(cè)失敗
- (void)xmppStream:(XMPPStream *)sender didNotRegister:(DDXMLElement *)error
{
    if (self.registFail) {
        self.registFail(error);
    }
}

• 登錄(原理跟注冊(cè)相似)

/**  保存登錄密碼 */
@property (nonatomic,copy) NSString *loginPassword;
/**  登錄成功block */
@property (nonatomic,copy) void (^loginSuccess)(id);
/**  登錄失敗的block */
@property (nonatomic,copy) void (^loginFail)(DDXMLElement *);



/** 登錄 */
- (void)loginWithUserName:(NSString *)userName password:(NSString *)password success:(void(^)(id data))success fail:(void(^)(DDXMLElement *error))fail
{
    //標(biāo)記狀態(tài)是登錄
    self.connectType = ConnectTypeLogin;
    //設(shè)置1.用戶(hù)名 2.域名 3.信息來(lái)源(ios或者Android)
    self.stream.myJID = [XMPPJID jidWithUser:userName domain:kDomin resource:kResource];
    //判斷是否在連接狀態(tài)
    if ([self.stream isConnected] || [self.stream isConnecting]) {
        //斷開(kāi)連接
        [self.stream disconnect];
    }
    //連接服務(wù)器
    [self.stream connectWithTimeout:-1 error:nil];
    //保存?zhèn)魅氲闹?    self.loginUserName = userName;
    self.loginPassword = password;
    self.loginSuccess = success;
    self.loginFail = fail;
}
#pragma mark 登錄的代理方法
//認(rèn)證成功
- (void)xmppStreamDidAuthenticate:(XMPPStream *)sender
{
    //存入本地(是否是登錄狀態(tài),用戶(hù)名,密碼)(如果登陸成功,這里做了個(gè)自動(dòng)登錄,自動(dòng)登錄實(shí)際就是查看本地是否有登錄記錄,有就在appdelegate中直接調(diào)用登錄的方法)
    KDefaultSetValue(KIsLogin, @"login");
    KDefaultSetValue(@"userName", self.loginUserName);
    KDefaultSetValue(@"password", self.loginPassword);
    if (self.loginSuccess) {
        self.loginSuccess(@"登錄成功");
    }
}
//認(rèn)證失敗
- (void)xmppStream:(XMPPStream *)sender didNotAuthenticate:(DDXMLElement *)error
{
    if (self.loginFail) {
        self.loginFail(error);
    }
}

• 注銷(xiāo):
  • 要斷開(kāi)與服務(wù)器的連接
  • 要把本地存儲(chǔ)的登錄信息移除

/** 注銷(xiāo) */
- (void)logout
{
    //斷開(kāi)連接
    [self.stream disconnect];
    //清除本地緩存
    [[NSUserDefaults standardUserDefaults] removeObjectForKey:@"userName"];
    [[NSUserDefaults standardUserDefaults] removeObjectForKey:@"password"];
    [[NSUserDefaults standardUserDefaults] removeObjectForKey:KIsLogin];
}