iOS開發之使用XMPPFramework實現即時通信(二)

上篇的博客iOS開發之使用XMPPFramework實現即時通信(一)只是本篇的引子，本篇博客就給之前的微信加上即時通訊的功能，主要是對XMPPFramework的使用。本篇博客中用到了Spark做測試，當然也少不了Openfire服務器，在這就不詳述Openfire的安裝過程了（網上的教程還是蠻多的），Openfire的安裝僅需要一個數據庫的支持，本篇是用的MySql數據庫。當然這不是本篇的重點。

廢話少說，切入今天的正題。今天要給之前的微信加入登陸，獲取好友列表，聊天(發送文字，表情，圖片，聲音等功能)，最近聯系人等。在博客的開頭還是先來幾張圖來介紹一下功能，然后再給出核心代碼的實現。

　　

一、功能模塊截圖

1.登陸和獲取好友列表

登陸的過程就是連接用XMPPFramework連接Openfire的過程，如果用戶登陸過，就從UserDefault里獲取用戶的JID和密碼自動連接，如果用戶沒有登陸過則登陸。獲取好友列表也是通過XMPPFramework中的Roster來獲取的，運行截圖如下：

　　

 

2、內容發送處理

好友點擊去就是聊天頁面，聊天時如果是發送的圖片或者聲音，先存儲到服務器上存儲，服務器會返回存儲路徑然后再把URL發送給接收方，接收方再下載

（1）如果是發送的文字，把文字轉成屬性字符串，然后再轉成NSData,最后轉成字符串放在Message的Body中進行發送，下面是用Spark做接收端做得測試，截圖如下：

　　

　　　　

(2)發送圖片，把圖片的存儲路徑發送給對方，讓對方從服務器上下載。截圖如下：

　　

　　　　

（3）發送聲音和圖片一樣都是發送URL,截圖如下：

　　

 

二、代碼實現部分

上面的部分是允許的效果截圖，從截圖上是不難看出功能點的。圖就先貼到這吧，下面給出核心代碼的實現。

1.使用XMPPFramework前的准備

獲取XmppStream和激活要用的組件,在AppDelegate添加代碼。以后要用xmppStream時，要通過AppDelegate獲取。下面的代碼是在AppDelegate.m中進行的相關組件的初始化，代碼如下

(1)實例化XMPPStream

    //創建xmppstream
    self.xmppStream = [[XMPPStream alloc]init];

 

(2)創建重連組件，並在xmppStream中激活

  //創建重寫連接組件
    xmppReconnect= [[XMPPReconnect alloc] init];
    //使組件生效
    [xmppReconnect activate:self.xmppStream];

 

(3)創建message部分的內容，接受的消息我們保存在本地數據庫中，我們要顯示的時候是從數據庫中獲取的。在初始化消息組件的時候，要指定保存策略，一般可以選的是CoreData還是內存。指定完保存策略后實例化Message是要關聯保存策略，之后也是需要在XMPPStream中進行激活的,最后要獲取CoreData的上下文。代碼如下：

    //創建消息保存策略（規則，規定）
    messageStorage = [XMPPMessageArchivingCoreDataStorage sharedInstance];
    //用消息保存策略創建消息保存組件
    xmppMessageArchiving = [[XMPPMessageArchiving alloc]initWithMessageArchivingStorage:messageStorage];
    //使組件生效
    [xmppMessageArchiving activate:self.xmppStream];
    //提取消息保存組件的coreData上下文
    self.xmppManagedObjectContext = messageStorage.mainThreadManagedObjectContext;

 

(4)，初始化獲取好友列表的相關組件並指定保存策略，和上面的代碼步驟極為相似。這也能看出來在XMPPFramework中進行組件的初始化步驟是差不多的。下面我們設定自動獲取花名冊，代碼如下：

    xmppRosterStorage = [[XMPPRosterCoreDataStorage alloc] init];
    xmppRoster = [[XMPPRoster alloc] initWithRosterStorage:xmppRosterStorage];
    //自動獲取用戶列表
    xmppRoster.autoFetchRoster = YES;
    xmppRoster.autoAcceptKnownPresenceSubscriptionRequests = YES;
    
    [xmppRoster activate:self.xmppStream];
    self.xmppRosterManagedObjectContext = xmppRosterStorage.mainThreadManagedObjectContext;

 

2.登陸模塊的實現

登陸時就是用戶輸入JID和Password,然后連接服務器和驗證密碼，如果認證成功則跳轉到好友列表才Controller，同時把JID和Password存儲到UserDefaults中便於下次自動連接。下面的代碼就是登陸部分的代碼(LoginViewController.m)：

(1).通過應用代理獲取XMPPStream,並注冊回調，代碼如下：

-(void) initXmpp
{
    //獲取應用的xmppSteam(通過Application中的單例獲取)
    UIApplication *application = [UIApplication sharedApplication];
    id delegate = [application delegate];
    self.xmppStream = [delegate xmppStream];
    
    //注冊回調
    [self.xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()];
}

 

(2).創建JID連接服務器

//連接服務器
-(void) xmppConnect
{
    if (![self.userNameTextFiled.text isEqualToString:@""] && self.userNameTextFiled.text != nil)
    {
        //1.創建JID
        XMPPJID *jid = [XMPPJID jidWithUser:self.userNameTextFiled.text domain:MY_DOMAIN resource:@"iPhone"];
        
        //2.把JID添加到xmppSteam中
        [self.xmppStream setMyJID:jid];
        
        //連接服務器
        NSError *error = nil;
        [self.xmppStream connectWithTimeout:10 error:&error];
        if (error)
        {
            NSLog(@"連接出錯：%@",[error localizedDescription]);
        }

    }
    else
    {
        UIAlertView *alter = [[UIAlertView alloc] initWithTitle:@"提示" message:@"用戶名不能為空" delegate:nil cancelButtonTitle:@"取消" otherButtonTitles:nil];
        [alter show];
    }
}

 

(3).連接成后需要認證密碼，代碼如下：

//連接后的回調
-(void)xmppStreamDidConnect:(XMPPStream *)sender
{
    if (![self.passwordTextFiled.text isEqualToString:@""] && self.passwordTextFiled.text != nil)
    {
        //連接成功后認證用戶名和密碼
        NSError *error = nil;
        [self.xmppStream authenticateWithPassword:self.passwordTextFiled.text error:&error];
        if (error)
        {
            NSLog(@"認證錯誤：%@",[error localizedDescription]);
        }
    }
    else
    {
        UIAlertView *alter = [[UIAlertView alloc] initWithTitle:@"提示" message:@"密碼不能為空" delegate:self cancelButtonTitle:@"取消" otherButtonTitles:nil];
        [alter show];
    }
}

 

(4)密碼認證成功后的回調

//認證成功后的回調
-(void)xmppStreamDidAuthenticate:(XMPPStream *)sender
{
    NSLog(@"登陸成功");
    
    //密碼進入userDefault
    NSUserDefaults *userDefult = [NSUserDefaults standardUserDefaults];
    [userDefult setObject:self.userNameTextFiled.text forKey:@"username"];
    [userDefult setObject:self.passwordTextFiled.text forKey:@"password"];
    
    //設置在線狀態
    XMPPPresence * pre = [XMPPPresence presence];
    [self.xmppStream sendElement:pre];
    
    UIStoryboard *storybard = [UIStoryboard storyboardWithName:@"Main" bundle:[NSBundle mainBundle]];
    UIViewController *viewController = [storybard instantiateViewControllerWithIdentifier:@"mainController"];
    [self presentViewController:viewController animated:YES completion:^{
    }];
}

 

(5)密碼認證失敗后的回調

//認證失敗的回調
-(void)xmppStream:sender didNotAuthenticate:(DDXMLElement *)error
{
    NSLog(@"認證失敗");
}

 

(6),二次登陸自動連接代碼：

   // 如果已登錄就直接填充密碼登陸
    NSUserDefaults *userDefult = [NSUserDefaults standardUserDefaults];
    
    NSString *userName = [userDefult objectForKey:@"username"];
    NSString *password = [userDefult objectForKey:@"password"];
    NSLog(@"%@,%@",userName,password);
    if (userName != nil && password != nil && ![userName isEqualToString:@""] && ![password isEqualToString:@""])
    {
        self.userNameTextFiled.text = userName;
        self.passwordTextFiled.text = password;
        [self xmppConnect];
    }

　　　　

3.獲取好友列表的XMPPFramework的代碼實現

在獲取用戶列表的代碼中就會用到我們之前注冊的Roster的內容，因為我們在實例化Roster的時候指定的保存策略是用CoreData進行保存的，並且是自動獲取好友列表。所以在獲取好友列表的TableViewController中我們只需要通過CoreData來獲取好友列表即可。下面將給出獲取好友列表的核心代碼：

(1),獲取Roster對應的上下文，用於獲取存儲在Roster相應實體中的數據

    //獲取Roster的上下文
    UIApplication *application = [UIApplication sharedApplication];
    id delegate = [application delegate];
    self.xmppRosterManagedObjectContext = [delegate xmppRosterManagedObjectContext];

　　　　　　

(2).獲取FetchRequst對象，並指定CoreData實體類，之后添加排序規則，代碼如下：

    //從CoreData中獲取數據
    //通過實體獲取FetchRequest實體
    NSFetchRequest *request = [[NSFetchRequest alloc] initWithEntityName:NSStringFromClass([XMPPUserCoreDataStorageObject class])];
    //添加排序規則
    NSSortDescriptor * sortD = [NSSortDescriptor sortDescriptorWithKey:@"jidStr" ascending:YES];
    [request setSortDescriptors:@[sortD]];

　　

(3).獲取FetchedResultController並注冊回調，用於自動刷新TableView,代碼如下：

    //獲取FRC
    self.fetchedResultsController = [[NSFetchedResultsController alloc] initWithFetchRequest:request managedObjectContext:self.xmppRosterManagedObjectContext sectionNameKeyPath:nil cacheName:nil];
    self.fetchedResultsController.delegate = self;

 

(4)獲取存儲的內容

    
    //獲取內容
    NSError * error;
    ;
    if (![self.fetchedResultsController performFetch:&error])
    {
        NSLog(@"%s  %@",__FUNCTION__,[error localizedDescription]);
    }

　　

至於如何在TableView上顯示FetchedResultController獲取的數據，請參考之前的博客：iOS開發之表視圖愛上CoreData。

最近聯系人的代碼和歷史表情的代碼類似，請參考之前的博客：iOS開發之微信聊天工具欄的封裝

聊頁面的實現請參考之前的博客：iOS開發之微信聊天頁面實現

　　

今天的XMPPFramework就先到這兒吧，內容也挺多的了，其實XMPPFramework中的組件使用方法都差不多，首先第初始化內存，然后進行相關配置，在后就是在XMPPStream中激活，最后就是如何使用了。

gitHub分享地址：https://github.com/lizelu/WeChat