XMPP搭建本地服務(wù)器、實(shí)現(xiàn)即時(shí)通訊（二）

前面部分呢，我們實(shí)現(xiàn)了一個(gè)XMPP本地服務(wù)器的搭建http://www.itdecent.cn/p/86eeb47d1792 但是我們最終的目的并不是這些，我們是要實(shí)現(xiàn)即時(shí)通訊的功能，今天我們就在代碼里面實(shí)現(xiàn)即時(shí)通訊的基本功能。

一、項(xiàng)目環(huán)境配置

  • 首先我們在工程中導(dǎo)入XMPPFramework


    導(dǎo)入 XMPPFramework

  • 添加本地依賴庫：libxml2.tbd和libresolv.tbd


    添加本地庫

  • 然后Build Settings->Header searches Pathes添加字段：/usr/include/libxml2


    添加字段

  • Commend+B編譯正常的話就OK了

二、建立與服務(wù)器的鏈接

  • 我們在建立與服務(wù)器鏈接之前需要自己創(chuàng)建：登陸頁面，注冊頁面，好友列表頁面和聊天頁面，這些在此不再累述，想必大家用可視化，分分鐘搞定。至于各個(gè)頁面之間的關(guān)聯(lián)，更是小kiss
  • 我們需要建立一個(gè)XMPP的任務(wù)管理類對象 而且這個(gè)對象只需要一個(gè) 我們可以用單例：
.h
@interface XMPPManager : NSObject<XMPPStreamDelegate>

+(XMPPManager *)sharedXMPPManager;//創(chuàng)建管理者對象單例

@property(nonatomic,strong)XMPPStream *stream;//信息管道
@property(nonatomic,strong)XMPPRoster *xmppRoster;//進(jìn)行添加好友 刪除好友 獲取還有列表等功能
@property(nonatomic,strong)XMPPMessageArchiving *xmppMessageArchivering;

@property(nonatomic,strong)NSManagedObjectContext *messageManagerContext;//聊天信息托管對象 上下文

//登陸
-(void)loginWithUser:(NSString *)user password:(NSString *)password;

//注冊
-(void)registWithUser:(NSString *)user password:(NSString *)password;
@end

.m
#import "XMPPManager.h"
//判斷想服務(wù)器建立連接是登陸還是注冊
typedef enum : NSUInteger {
    ConnectToServerPurposeLogin,//登陸
    ConnectToServerPurposeRegist,//注冊
} MyStatus;

@interface XMPPManager ()
@property(nonatomic,strong)NSString *password;//登錄密碼
@property(nonatomic,strong)NSString *registPassword;//注冊密碼
@property(nonatomic,assign)MyStatus connectToServerPurse;
@end
@implementation XMPPManager

+(XMPPManager *)sharedXMPPManager{
    static XMPPManager *manager = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        manager = [[XMPPManager alloc]init];
    });
    return manager;
}

- (instancetype)init
{
    self = [super init];
    if (self) {
        self.stream = [[XMPPStream alloc]init];
        self.stream.hostName = kHostName;//服務(wù)器的地址
        self.stream.hostPort = kHostPort;//端口號(hào)標(biāo)識(shí)唯一的服務(wù)
        [self.stream addDelegate:self delegateQueue:dispatch_get_main_queue()];//讓當(dāng)前對象成為stream的代理
        
        
        //進(jìn)行好友存儲(chǔ)
        XMPPRosterCoreDataStorage *storage= [XMPPRosterCoreDataStorage sharedInstance];
        self.xmppRoster = [[XMPPRoster alloc]initWithRosterStorage:storage dispatchQueue:dispatch_get_main_queue()];
        [self.xmppRoster activate:self.stream];//激活
        
        
        //進(jìn)行聊天信息存儲(chǔ)
        XMPPMessageArchivingCoreDataStorage *archiveringStorage = [XMPPMessageArchivingCoreDataStorage sharedInstance];
        self.xmppMessageArchivering = [[XMPPMessageArchiving alloc]initWithMessageArchivingStorage:archiveringStorage dispatchQueue:dispatch_get_main_queue()];
        [self.xmppMessageArchivering activate:self.stream];//激活
        
        self.messageManagerContext = archiveringStorage.mainThreadManagedObjectContext;
    }
    return self;
}

//與服務(wù)器建立鏈接
-(void)connectToServerWithUser:(NSString *)user{
    //要是正在鏈接的話那么就先斷開連接
    if ([self.stream isConnected]) {
        [self disconnectServer];
    }
    XMPPJID *jid = [XMPPJID jidWithUser:user domain:kDomin resource:kResource];
    self.stream.myJID = jid;
    NSError *error = nil;
    [self.stream connectWithTimeout:30.0f error:&error];
    if (nil != error) {
        NSLog(@"%s__%d__鏈接出錯(cuò)：%@",__FUNCTION__,__LINE__,error);
    }
}
//與服務(wù)器斷開鏈接
-(void)disconnectServer{
    [self.stream disconnect];
}
//登陸
-(void)loginWithUser:(NSString *)user password:(NSString *)password{
    
    self.connectToServerPurse = ConnectToServerPurposeLogin;
    self.password = password;//將傳進(jìn)來的password傳給self.password
    [self connectToServerWithUser:user];
}
//注冊
-(void)registWithUser:(NSString *)user password:(NSString *)password{
    self.connectToServerPurse = ConnectToServerPurposeRegist;
    self.registPassword = password;
    [self connectToServerWithUser:user];
}

#pragma mark--XMPPStreamDelegate
//我們一旦想服務(wù)器發(fā)送請求之后又兩種結(jié)果 成功和失敗 我們需要實(shí)現(xiàn)XMPP協(xié)議的兩個(gè)方法
//與服務(wù)器鏈接成功
-(void)xmppStreamDidConnect:(XMPPStream *)sender{
    
    NSLog(@"%s__%d__",__FUNCTION__,__LINE__);
    
#pragma mark ------判斷與服務(wù)器建立連接是登陸還是注冊
    switch (self.connectToServerPurse) {
        case ConnectToServerPurposeLogin:
        {
            //建立連接成功之后需要向服務(wù)器驗(yàn)證自己的身份
            NSError *error = nil;
            [self.stream authenticateWithPassword:self.password error:&error];
            if (nil != error) {
                NSLog(@"%s__%d__驗(yàn)證出錯(cuò)：%@",__FUNCTION__,__LINE__,error);
            }
            break;
        }
        case ConnectToServerPurposeRegist:
        {
            NSError *err = nil;
            [self.stream registerWithPassword:self.registPassword error:&err];
            if (nil != err) {
                NSLog(@"%s__%d__注冊出錯(cuò)：%@",__FUNCTION__,__LINE__,err);
            }
            break;
        }
        default:
            break;
    }
}
//與服務(wù)器鏈接失敗
-(void)xmppStreamConnectDidTimeout:(XMPPStream *)sender{
    NSLog(@"%s__%d__",__FUNCTION__,__LINE__);
}
@end

登陸

  • 我們在登陸頁面點(diǎn)擊登陸按鈕的時(shí)候調(diào)用XMPPManager的-(void)loginWithUser:(NSString *)user password:(NSString *)password;進(jìn)行登陸，但是我們在進(jìn)行登陸的時(shí)候是需要服務(wù)器的驗(yàn)證的所有這些都直接在代碼理顯示了，如下：
#import <Foundation/Foundation.h>
#import "XMPPFramework.h"

#import "LoginViewController.h"
#import "XMPPManager.h"
@interface LoginViewController ()<XMPPStreamDelegate>
@property (weak, nonatomic) IBOutlet UITextField *userName;
@property (weak, nonatomic) IBOutlet UITextField *userPassword;
@end

@implementation LoginViewController
- (IBAction)loginButton:(id)sender {
    //獲取用戶名和密碼
    NSString *userName = self.userName.text;
    NSString *userPassword = self.userPassword.text;
    
    [[XMPPManager sharedXMPPManager]loginWithUser:userName password:userPassword];
}

- (void)viewDidLoad {
    [super viewDidLoad];
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];
    // Do any additional setup after loading the view.
}

#pragma mark--XMPPStreamDelegate  進(jìn)行身份驗(yàn)證
//驗(yàn)證成功
-(void)xmppStreamDidAuthenticate:(XMPPStream *)sender{
    
    NSLog(@"%s__%d__驗(yàn)證成功",__FUNCTION__,__LINE__);
    
    [[NSUserDefaults standardUserDefaults]setObject:self.userName.text forKey:@"userName"];
    [[NSUserDefaults standardUserDefaults]setObject:self.userPassword.text forKey:@"userPassword"];
    [[NSUserDefaults standardUserDefaults]synchronize];//立即存儲(chǔ)
    
    [self dismissViewControllerAnimated:YES completion:nil];
}
//驗(yàn)證失敗
-(void)xmppStream:(XMPPStream *)sender didNotAuthenticate:(DDXMLElement *)error{
    NSLog(@"%s__%d__驗(yàn)證出錯(cuò)：%@",__FUNCTION__,__LINE__,error);
}
- (void)didReceiveMemoryWarning {
    [super didReceiveMemoryWarning];
}

@end
  • 此時(shí)我們也需要在AppDelegate里面作如下處理,當(dāng)我們再次打開應(yīng)用程序的時(shí)候要是已經(jīng)驗(yàn)證成功就顯示好友列表頁面，否則的話就顯示登陸注冊頁面，由于清一色的代碼 給大家來張圖緩解一下緊張的氣氛吧。
此時(shí)的頁面
#import "AppDelegate.h"
@interface AppDelegate ()
@end
@implementation AppDelegate

- (BOOL)application:(UIApplication *)application didFinishLaunchingWithOptions:(NSDictionary *)launchOptions {
    if (nil == [[NSUserDefaults standardUserDefaults]objectForKey:@"userName"]) {
        UIStoryboard *story = [UIStoryboard storyboardWithName:@"LoginAndPregist" bundle:nil];
        UINavigationController *nv = [story instantiateInitialViewController];
        [self.window makeKeyAndVisible];
        [self.window.rootViewController presentViewController:nv animated:YES completion:^{
        }];
    }else{
        NSString *userName = [[NSUserDefaults standardUserDefaults]objectForKey:@"userName"];
        NSString *password = [[NSUserDefaults standardUserDefaults]objectForKey:@"userPassword"];
        [[XMPPManager sharedXMPPManager]loginWithUser:userName password:password];
        [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];
    }
    return YES;
}
#pragma mark--XMPPStreamDelegate
//驗(yàn)證成功
-(void)xmppStreamDidAuthenticate:(XMPPStream *)sender{
    NSLog(@"%s__%d__",__FUNCTION__,__LINE__);
    
    //我們驗(yàn)證之后默認(rèn)的狀態(tài)是離線的 于是我們想顯示在線，需要告訴服務(wù)器自己的狀態(tài)
    XMPPPresence *presence = [XMPPPresence presenceWithType:@"available"];
    [[XMPPManager sharedXMPPManager].stream sendElement:presence];
}
//驗(yàn)證失敗
-(void)xmppStream:(XMPPStream *)sender didNotAuthenticate:(DDXMLElement *)error{
}

注冊

  • 其實(shí)注冊和登陸是有很大的相似性的，例如同樣需要遵守XMPPStreamDelegate協(xié)議，我們點(diǎn)擊注冊按鈕的時(shí)候是會(huì)執(zhí)行XMPPManager的-(void)registWithUser:(NSString*)user password:(NSString *)password;進(jìn)行注冊一樣的注冊成功還是失敗都會(huì)有相應(yīng)的方法來執(zhí)行，
#import "RegistViewController.h"
#import "XMPPManager.h"
@interface RegistViewController ()<XMPPStreamDelegate>
@property (weak, nonatomic) IBOutlet UITextField *userName;
@property (weak, nonatomic) IBOutlet UITextField *userPassword;

@end

@implementation RegistViewController

- (IBAction)registButton:(id)sender {
    NSString *userName =self.userName.text;
    NSString *userpassword = self.userPassword.text;
    [[XMPPManager sharedXMPPManager]registWithUser:userName password:userpassword];
}
- (void)viewDidLoad {
    [super viewDidLoad];
    
    //設(shè)置代理
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];
}
- (void)didReceiveMemoryWarning {
    [super didReceiveMemoryWarning];
    // Dispose of any resources that can be recreated.
}

#pragma mark--XMPPStreamDelegate
//注冊成功
-(void)xmppStreamDidRegister:(XMPPStream *)sender{
    NSLog(@"%s__%d__注冊成功",__FUNCTION__,__LINE__);
    
    //注冊成功之后返回到登陸界面
    [self.navigationController popToRootViewControllerAnimated:YES];
}
//注冊失敗
-(void)xmppStream:(XMPPStream *)sender didNotRegister:(DDXMLElement *)error{
    NSLog(@"%s__%d__注冊失敗%@",__FUNCTION__,__LINE__,error);
}
@end

獲取好友列表

  • 獲取還有列表我們需要在XMPPManager里面創(chuàng)建一個(gè)XMPPRoster對象
  • 這個(gè)對象具有添加好友 刪除好友 獲取好友列表等功能
@property(nonatomic,strong)XMPPRoster *xmppRoster;

具體的代碼部分 我寫的非常詳細(xì) 大家接著看

#import "RosterTableViewController.h"
#import "XMPPManager.h"
#import "ChatTableViewController.h"
@interface RosterTableViewController ()<XMPPRosterDelegate>
@property(nonatomic,strong)NSMutableArray *rosterArray;//保存獲取的好友
@end

@implementation RosterTableViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    
    //初始化數(shù)組 這個(gè)數(shù)組里面保存的是獲取的好友
    self.rosterArray = [NSMutableArray arrayWithCapacity:10];
    
    [[XMPPManager sharedXMPPManager].xmppRoster addDelegate:self delegateQueue:dispatch_get_main_queue()];
}

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

#pragma mark - Table view data source

- (NSInteger)numberOfSectionsInTableView:(UITableView *)tableView {
    return 1;
}

- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
    return self.rosterArray.count;
}

- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {
    UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:@"Cell" forIndexPath:indexPath];
    XMPPJID *jid = self.rosterArray[indexPath.row];
    cell.textLabel.text = jid.user;
    return cell;
}

#pragma mark--XMPPRosterDelegate
//剛開始獲取好友列表
-(void)xmppRosterDidBeginPopulating:(XMPPRoster *)sender{
    NSLog(@"%s__%d__",__FUNCTION__,__LINE__);
}
//正在獲取好友列表
-(void)xmppRoster:(XMPPRoster *)sender didReceiveRosterItem:(DDXMLElement *)item{
    NSLog(@"%s__%d__Item=%@",__FUNCTION__,__LINE__,item);
    NSString *jidStr = [[item attributeForName:@"jid"]stringValue];
    XMPPJID *jid =[XMPPJID jidWithString:jidStr];
    [self.rosterArray addObject:jid];
    
    //將數(shù)據(jù)添加進(jìn)數(shù)組
    [self.tableView insertRowsAtIndexPaths:@[[NSIndexPath indexPathForRow:self.rosterArray.count-1 inSection:0]] withRowAnimation:UITableViewRowAnimationLeft];
}
//已經(jīng)完成獲取好友列表
-(void)xmppRosterDidEndPopulating:(XMPPRoster *)sender{
    NSLog(@"%s__%d__",__FUNCTION__,__LINE__);
}

#pragma mark--這個(gè)方法的作用是傳遞一個(gè)值到我們需要點(diǎn)擊進(jìn)入的聊天頁面，同時(shí)在聊天頁面設(shè)置一個(gè)屬性值來接收
- (void)prepareForSegue:(UIStoryboardSegue *)segue sender:(id)sender {
    UITableViewCell *cell = (UITableViewCell *)sender;
    NSIndexPath *indexPath = [self.tableView indexPathForCell:cell];
    XMPPJID *jid = self.rosterArray[indexPath.row];
    ChatTableViewController *chat = segue.destinationViewController;
    chat.chatToJid = jid;
}
@end

聊天頁面

  • 我們在聊天頁面開了一個(gè)接口，來接受列表頁面?zhèn)鬟M(jìn)來的XMPPJID
#import <UIKit/UIKit.h>
#import "XMPPManager.h"
@interface ChatTableViewController : UITableViewController
@property(nonatomic,strong)XMPPJID *chatToJid;//要聊天的好友
@end
  • 首先，在ChatTableViewController.m里面 我們同樣的遵守代理協(xié)議XMPPStreamDelegate，定義一個(gè)可變數(shù)組來接收查詢的所有聊天信息
@implementation ChatTableViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    self.allMessageArray = [NSMutableArray array];//初始化數(shù)組
    
    [[XMPPManager sharedXMPPManager].stream addDelegate:self delegateQueue:dispatch_get_main_queue()];//設(shè)置監(jiān)測對象
    [self reloadMessage];
}
//點(diǎn)擊右上角添加按鈕傳遞一條信息
- (IBAction)addButton:(id)sender {
    XMPPMessage *message = [XMPPMessage messageWithType:@"chat" to:self.chatToJid];
    [message addBody:@"Hello"];
    [[XMPPManager sharedXMPPManager].stream sendElement:message];
}
  • 以下是XMPPStreamDelegate對于信息發(fā)送的幾個(gè)方法
#pragma mark--XMPPStreamDelegate
//發(fā)送信息成功
-(void)xmppStream:(XMPPStream *)sender didSendMessage:(XMPPMessage *)message{
    NSLog(@"%s__%d__",__FUNCTION__,__LINE__);
    [self reloadMessage];//發(fā)送信息是 刷新一次頁面
}
//發(fā)送信息失敗
-(void)xmppStream:(XMPPStream *)sender didFailToSendMessage:(XMPPMessage *)message error:(NSError *)error{
    NSLog(@"%s__%d__Error：%@",__FUNCTION__,__LINE__,error);
}
//收到信息
-(void)xmppStream:(XMPPStream *)sender didReceiveMessage:(XMPPMessage *)message{
    NSLog(@"%s__%d__Message=%@",__FUNCTION__,__LINE__,message);
    [self reloadMessage];//收到信息是刷新一次頁面
}
  • 我們在發(fā)送消失 或者接收到消失 以及我們進(jìn)入頁面的時(shí)候都會(huì)顯示相應(yīng)的內(nèi)容 這其實(shí)就設(shè)計(jì)頁面數(shù)據(jù)加載的內(nèi)容，因此我們自定義一個(gè)方法，用來加載聊天頁面的內(nèi)容，并在相應(yīng)的方法里進(jìn)行調(diào)用
#pragma mark--加載聊天信息
-(void)reloadMessage{
    
    NSManagedObjectContext *managerObjectContext =[XMPPManager sharedXMPPManager].messageManagerContext;
    NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] init];
    NSEntityDescription *entity = [NSEntityDescription entityForName:@"XMPPMessageArchiving_Message_CoreDataObject" inManagedObjectContext:managerObjectContext];
    [fetchRequest setEntity:entity];
    // Specify criteria for filtering which objects to fetch
    
    //我們要是不設(shè)置相應(yīng)的檢索條件的話 就會(huì)吧所有的聊天信息檢索出來出來
    NSPredicate *predicate = [NSPredicate predicateWithFormat:@"bareJidStr == %@ And streamBareJidStr == %@", self.chatToJid.bare,[XMPPManager sharedXMPPManager].stream.myJID.bare];//對方的Jid和自己的Jid
    [fetchRequest setPredicate:predicate];
    //以上查詢出來的結(jié)果就是當(dāng)前用戶和聊天用戶之間的信息
    // Specify how the fetched objects should be sorted
    //設(shè)置
    NSSortDescriptor *sortDescriptor = [[NSSortDescriptor alloc] initWithKey:@"timestamp" ascending:YES];
    [fetchRequest setSortDescriptors:[NSArray arrayWithObjects:sortDescriptor, nil]];
    
    NSError *error = nil;
    NSArray *fetchedObjects = [managerObjectContext executeFetchRequest:fetchRequest error:&error];
    if (fetchedObjects == nil) {
        NSLog(@"沒有檢索出任何內(nèi)容");
    }else{
        
        //在此判斷一下，因?yàn)槿找屈c(diǎn)擊一個(gè)人，沒有聊天記錄的話直接return 否則會(huì)崩掉的
        if (fetchedObjects.count == 0) {
            return;
        }
        [self.allMessageArray removeAllObjects];
        [self.allMessageArray addObjectsFromArray:fetchedObjects];
        [self.tableView reloadData];
        
        //進(jìn)行信息加載的時(shí)候讓tableView 滾動(dòng)到最底部
        [self.tableView scrollToRowAtIndexPath:[NSIndexPath indexPathForRow:self.allMessageArray.count-1 inSection:0] atScrollPosition:UITableViewScrollPositionBottom animated:YES];
    }
}
  • 至于UITableView data source的幾個(gè)代理方法就簡單的不行不行的了。。。Table view data source
- (NSInteger)numberOfSectionsInTableView:(UITableView *)tableView {
    
    return 1;
}
- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section {
    
    return self.allMessageArray.count;
}
- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath {
    UITableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:@"Message" forIndexPath:indexPath];
    
    XMPPMessageArchiving_Message_CoreDataObject *message = self.allMessageArray[indexPath.row];
    
    //判斷聊天信息是發(fā)出去的 還是接受進(jìn)來的，在cell上顯示不一樣的樣式
    if (message.isOutgoing == YES) {
        cell.detailTextLabel.text = message.body;
        cell.textLabel.text = @"";
    }else{
        cell.textLabel.text = message.body;
        cell.detailTextLabel.text = @"";
    }
    return cell;
}
  • 以上就是XMPP實(shí)現(xiàn)聊天功能的基本內(nèi)容，我們在以代碼為伍的時(shí)候 可以用Openfile和spark等工具幫助我們進(jìn)行調(diào)試~~~~~
最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時(shí)請結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點(diǎn)，簡書系信息發(fā)布平臺(tái)，僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容