- 即时通讯是目前最为流行的通讯方式.
- 即时通讯的多种实现方式: XMPP,环信,融云.
XMPP基于XML的点对点的即时通讯协议,通过CoreData管理数据
XMPP(XML,Messages,Presence,Protocol)是基于可扩展标记语言(XML)的协议,可用于即时通信(IM). —————可扩展消息处理现场协议
- XMPP优点:
- 1.开放: XMPP协议是由JSF开源社区组织开发的,不属于任何的机构和个人,从根本上保证了其开发性
- 2.标准: 互联网工程工作组将XMPP于2002年正式列为认可的实时通讯及Peesence技术.
- 3.分布式的网络架构: XMPP协议虽然是基于Client/Server架构,但是XMPP协议本身并没有这样的限制. 网络的架构和电子邮件十分相似, 但没有结合任何特定的网络架构, 适用范围非常广泛
- 4.XMPP协议具有良好的扩展性: 基于XML建立起来的应用具有良好的语义完整性和扩展
- 5.XMPP具有很好的弹性: XMPP除了可用在即时通讯的应用程序,还能在网络管理,内容供稿,协同工作,档案共享,游戏,远端系统监控等
- 6.安全性: XMPP在Client-to-Server通信和Server-to-Server通信中都使用TLS(Transport Layer Security)协议作为通信通道的加密方法,保证通信的安全
实现
- 原理: 实现即时通讯至少需要一个服务器端,两个客户端.所以需要准备的环境:
1.XMPP服务器
2: XMPP客户端 - 搭建XMPP环境需要几个辅助工具:
1: XAMPP
XAMPP (Apache + MySQL + PHP + PERL ) 是一个功能强大的建 XAMPP软件站集成软件包.XAMPP是一个易于安装且包含MySQL, PHP和Perl的Apache发行版. XAMPP的确非常容易安装和使用: 只需下载, 解压缩, 启动即可.
2: Openfire
Openfire采用Java开发, 开源的实时协作 (RTC) 服务器 基于XMPP(Jabber) 协议. Openfire安装和使用都非常简单, 并利用Web 进行管理. 单台服务器可支持上万并发用户.Openfire服务是基于Java语言写的,你的电脑必须要有java运行环境. 安装JDK成功后进行Openfire的安装.
3:Spark
XMPP系统的一个设计标准是必须支持简单的客户端. 事实上,XMPP系统架构对客户端只有很少的几个限制. 一个XMPP客户端必须支持的功能有:
- 1.通过TCP套接字与XMPP服务器进行通信;
- 2.解析组织好的XML信息包;
- 3.理解消息数据类型;
上代码
// 引入第三方的.h
#import "XMPPFramework.h"
// 遵守协议尖括号中
@interface XMPPmanage : NSObject<XMPPStreamDelegate, XMPPRosterDelegate>
+ (XMPPmanage *)defaultManage;
//通道管理器类
@property (nonatomic,strong) XMPPStream *xmppStream;
//好友花名册
@property (nonatomic,strong) XMPPRoster *xmppRoster;
//登录方法
- (void)loginWithUserName:(NSString *)userName
passWord:(NSString *)passWord;
//注册方法
- (void)registerWithUserName:(NSString *)userName
passWord:(NSString *)passWord;
@end
实现部分
#import "XMPPmanage.h"
@interface XMPPmanage ()
typedef NS_ENUM(NSInteger, ConnectToServer){
ConnectToServerLogin,
ConnectToServerRegister,
};
@property (nonatomic) ConnectToServer connectToServer;
@property (nonatomic, copy) NSString *userName;
@property (nonatomic, copy) NSString *passWord;
@property (nonatomic, copy) NSString *registerUserName;
@property (nonatomic, copy) NSString *registerPassWord;
@end
static XMPPmanage *manage = nil;
@implementation XMPPmanage
+ (XMPPmanage *)defaultManage{
//同一时间内只有一个线程可以访问这里面的东西
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
if (manage == nil) {
manage = [XMPPmanage new];
}
});
return manage;
}
- (instancetype)init{
self = [super init];
if (self) {
//初始化通道管理类
self.xmppStream = [[XMPPStream alloc]init];
//设置openFire服务器的ip地址
self.xmppStream.hostName = kHostName;
//设置端口号 默认5222
self.xmppStream.hostPort = kHostPort;
//设置XMPPStream的代理
[self.xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()];
// XMPP使用了CoreData做缓存。所以在创建roster的时候，需要一个CoreData类
XMPPRosterCoreDataStorage *storage = [XMPPRosterCoreDataStorage sharedInstance];
self.xmppRoster = [[XMPPRoster alloc]initWithRosterStorage:storage dispatchQueue:dispatch_get_main_queue()];
//添加到通道管理器里面
[self.xmppRoster activate:self.xmppStream];
[self.xmppRoster addDelegate:self delegateQueue:dispatch_get_main_queue()];
}
return self;
}
//登录
- (void)loginWithUserName:(NSString *)userName passWord:(NSString *)passWord{
self.userName = userName;
self.passWord = passWord;
self.connectToServer = ConnectToServerLogin;
[self didConnect];
}
//注册
- (void)registerWithUserName:(NSString *)userName passWord:(NSString *)passWord{
self.registerUserName = userName;
self.registerPassWord = passWord;
self.connectToServer = ConnectToServerRegister;
[self didConnect];
}
- (void)didConnect{
NSString *user;
switch (self.connectToServer) {
case ConnectToServerLogin:
user = self.userName;
break;
case ConnectToServerRegister:
user = self.registerUserName;
break;
default:
break;
}
//XMPPJID类标识,用户的标识类 可以找到一个唯一的用户
//参数 1: 用户名
//参数 2: openFire地址
//参数 3: 来源
XMPPJID *jid = [XMPPJID jidWithUser:user domain:kDomin resource:kResource];
//给通道管理器类 myJID赋值
self.xmppStream.myJID = jid;
//如果这个通道连接器 已经连接上或者正在连接服务器,应该断掉连接
if ([self.xmppStream isConnected] || [self.xmppStream isConnecting]) {
#warning 断掉连接
}
NSError *error = nil;
//让XMPPStream建立连接
//参数 1: 表示超时时间
//参数 2: 表示错误信息
[self.xmppStream connectWithTimeout:30.0f error:&error];
if (error != nil) {
NSLog(@"error --> %@ ,%d",error,__LINE__);
}
}
#pragma mark - 连接超时
- (void)xmppStreamConnectDidTimeout:(XMPPStream *)sender{
NSLog(@"网络不给力啊,亲");
}
//连接成功
- (void)xmppStreamDidConnect:(XMPPStream *)sender{
switch (self.connectToServer) {
case ConnectToServerLogin:
// 通道管理器 发送登录消息的方法
[self.xmppStream authenticateWithPassword:self.passWord error:nil];
break;
case ConnectToServerRegister:
// 通道管理器 发送注册消息的方法
[self.xmppStream registerWithPassword:self.registerPassWord error:nil];
break;
default:
break;
}
}
//断开连接
- (void)xmppStreamDidDisconnect:(XMPPStream *)sender withError:(NSError *)error{
}
@end
