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中激活

1   //创建重写连接组件
2     xmppReconnect= [[XMPPReconnect alloc] init];
3     //使组件生效
4     [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)密码认证失败后的回调

1 //认证失败的回调
2 -(void)xmppStream:sender didNotAuthenticate:(DDXMLElement *)error
3 {
4     NSLog(@"认证失败");
5 }

 

      (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相应实体中的数据

1     //获取Roster的上下文
2     UIApplication *application = [UIApplication sharedApplication];
3     id delegate = [application delegate];
4     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,代码如下:

1     //获取FRC
2     self.fetchedResultsController = [[NSFetchedResultsController alloc] initWithFetchRequest:request managedObjectContext:self.xmppRosterManagedObjectContext sectionNameKeyPath:nil cacheName:nil];
3     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中激活,最后就是如何使用了。

时间: 2024-10-30 14:16:31

iOS开发之使用XMPPFramework实现即时通信(二)的相关文章

iOS开发之使用XMPPFramework实现即时通信(三)

你看今天是(三)对吧,前面肯定有(一)和(二),在发表完iOS开发之使用XMPPFramework实现即时通信(一)和iOS开发之使用XMPPFramework实现即时通信(二)后有好多的小伙伴加我Q或者评论留言提出一些问题,比如:"楼主,在哪注册?","楼主,你的登录用户名和密码是多少?"之类的问题.在之前的博客中使用的账号和密码,为了方便,是用spark客户端注册的,在今天的博客中将会详细的介绍如何使用代码注册我们新用户,还有在这感谢关注我的小伙伴们,谢谢你们的

iOS开发之使用XMPPFramework实现即时通信(一)

关于XMPP的理论介绍在本篇博客中就不做赘述了,如何在我们之前的微信中加入XMPP协议来实现通信呢?下面将会介绍一下XMPP的基本的知识,让我们的微信可以实现互联通信.要做的准备工作是要有服务器支持XMPP协议,然后通过spark注册个测试账号,最后就可以通过XMPP用我们已有的账号和密码进行通信啦.至于如何使服务器支持XMPP协议,如何通过Spark注册账号,不是本篇博客的论述主题,本篇博客中主要是如何在我们的App中使用XMPP协议. 今天的博客中的内容是如何在工程中引入XMPPFramew

iOS开发多线程篇—线程间的通信

一.简单说明 线程间通信:在1个进程中,线程往往不是孤立存在的,多个线程之间需要经常进行通信 线程间通信的体现 1个线程传递数据给另1个线程 在1个线程中执行完特定任务后,转到另1个线程继续执行任务 线程间通信常用方法 - (void)performSelectorOnMainThread:(SEL)aSelector withObject:(id)arg waitUntilDone:(BOOL)wait; - (void)performSelector:(SEL)aSelector onThr

iOS开发网络篇—网络编程基础(二)

下面叙述的是关于几个必须要知道的iOS网络编程入门级别的要点: 1.客户端如何找到连接的服务器 客户端通过URL找到想要连接的服务器 2.什么是URL URL的全称是Uniform Resource Locator(统一资源定位符) 通过1个URL,能找到互联网上唯一的1个资源 URL就是资源的地址.位置,互联网上的每个资源都有一个唯一的URL URL的基本格式 = 协议://主机地址/路径 http://www.520it.com/img/logo.png 协议:不同的协议,代表着不同的资源查

iOS开发网络篇—NSURLConnection基本使用(二)

1.常用的类 NSURL:请求地址 NSURLRequest:一个NSURLRequest对象就代表一个请求,它包含的信息有: 一个NSURL对象 请求方法.请求头.请求体 请求超时 -... NSMutableURLRequest:NSURLRequest的子类 NSURLConnection 负责发送请求,建立客户端和服务器的连接. 发送数据给服务器,并收集来自服务器的响应数据. 2.NSURLConnection发送请求,常见的发送请求(默认都是GET请求)方式(都是类方法哦)有以下几种:

ios-iOS 开发,基于GCDAsyncSocket的即时通讯是怎样在两个用户间完成的

问题描述 iOS 开发,基于GCDAsyncSocket的即时通讯是怎样在两个用户间完成的 iOS 开发,基于GCDAsyncSocket的即时通讯是怎样在两个用户间完成的?比如a发一条信息给b,这条信息是怎样经过服务器到达b的 解决方案 A即时发送端也是 接受端 开不同的端口去监听,B也一样,一直监听与A发送端 端口相同的接口,这样A发送数据到 服务端B的端口XXX B一直监听者自身端口的XXX 这样A发送的消息 B就可以接受到 解决方案二: 两个客户端都连在服务器上,各自发送数据给服务器,然

android-使用环信SDK开发即时通信功能(附源码下载)_Android

最近项目中集成即时聊天功能,挑来拣去,最终选择环信SDK来进行开发,选择环信的主要原因是接口方便.简洁,说明文档清晰易懂.文档有Android.iOS.和后台服务器端,还是非常全的.  环信官网:http://www.easemob.com/ 本篇文章目的主要在于说明环信Demo如何实现即时通信的.我在集成环信SDK到我们自己开发的app之前,研究了一下环信demo的代码,看了两三天的样子,基本搞清楚来龙去脉,但是只是清楚来龙去脉,要说到里面的细节可能得深一步研究,但是这就够了,已经可以把dem

android-使用环信SDK开发即时通信功能(附源码下载)

最近项目中集成即时聊天功能,挑来拣去,最终选择环信SDK来进行开发,选择环信的主要原因是接口方便.简洁,说明文档清晰易懂.文档有Android.iOS.和后台服务器端,还是非常全的. 环信官网:http://www.easemob.com/ 本篇文章目的主要在于说明环信Demo如何实现即时通信的.我在集成环信SDK到我们自己开发的app之前,研究了一下环信demo的代码,看了两三天的样子,基本搞清楚来龙去脉,但是只是清楚来龙去脉,要说到里面的细节可能得深一步研究,但是这就够了,已经可以把demo

文档-iOS 融云即时通信 如何新建群,不是讨论组

问题描述 iOS 融云即时通信 如何新建群,不是讨论组 文档-iOS 融云即时通信 如何新建群,不是讨论组-qq新建讨论组"> 如图,找到官方文档如图所示 要传入用户ID 和群名 以及 群ID ,但是 我是要新建群,压根就没有群ID,总不可能我自己随机个群ID吧, 求大神来解惑,指点迷境. 解决方案 看接口需要传入的参数,应该是加入群组.但说明又是创建群组,好像是有一点冲突! 创建群组,与将用户加入群组,肯定是两个方法/接口. 解决方案二: 这个api只是加入群,你需要看川剧的API