1. xmpp簡介
XMPP 是一組基于 XML 的技術(shù)京髓。用于實時應(yīng)用程序弯汰。最初综慎。XMPP 作為一個框架開發(fā)莱找。目標是支持企業(yè)環(huán)境內(nèi)的即時消息傳遞和聯(lián)機狀態(tài)應(yīng)用程序酬姆。詳細簡介
xmpp客戶端：
iOS端：
- 單聊：xmpp單聊是基于服務(wù)器端好友設(shè)置來進行聊天的，類似于微信奥溺，你可以添加好友辞色，經(jīng)過同意以后就可以進行聊天。
- 群聊: xmpp 群聊類似于聊天室的類型浮定，你可以創(chuàng)建一個房間相满，可以邀請其他人加入這個房間，也可以主動加入群桦卒，當房間里面大于等于兩個人立美，就可以進行群聊。不過跟微信不同的是方灾，用戶在退出這個聊天建蹄，性質(zhì)就跟退出這個群。如果下次再進入這個群裕偿，需要在加入這個群洞慎，這樣會通過傳給服務(wù)器的最后一次登錄時間，服務(wù)器會把這個時間段以后的消息嘿棘，全部推送給你拢蛋。
xmpp服務(wù)器：
Openfire + Spark 簡介：下載地址及簡單介紹：
openfire + Spark這邊服務(wù)器端了解不多，只是知道通過下載這個應(yīng)用蔫巩，通過配置來創(chuàng)建好友和創(chuàng)建房間谆棱，進行簡單的單聊群聊。如果做服務(wù)器的話圆仔，肯定不止這么少東西垃瞧，如果要學(xué)習(xí)的話還是自己查資料吧。 Openfire下載地址
2. xmpp聊天原理
xmpp是基于xml類型進行消息傳遞的坪郭。所有的消息傳遞類型都是xmpp類型的个从。
(1) 發(fā)送消息類型：
<message type="chat" to="110095@domain" id="d851f47818db46b58abf4e982327ab36"><request xmlns="urn:xmpp:receipts"></request><body>{
"messageId" : "d851f47818db46b58abf4e982327ab36", //messageid
"content" : "你好", //消息內(nèi)容
"fromUserName" : "張三", //發(fā)送人
"isSecret" : 0, //單聊是否是密聊消息 0:正常聊天 1:密聊
"timeLen" : 0,
"isAt" : 0, //群聊是否@人
"timeSend" : 1522034423, //發(fā)送時間
"type" : 1 //消息類型
}</body></message>
(2) 接收消息類型：
<message xmlns="jabber:client" id="cdc6007ca03b401f8c9e4a2ccb75d8d5" type="chat" to="111751@domain" from="109965@domain/resource"><request xmlns="urn:xmpp:receipts"></request><body>{
"messageId" : "cdc6007ca03b401f8c9e4a2ccb75d8d5",
"content" : "天津",
"fromUserName" : "李四",
"isSecret" : 0,
"timeLen" : 0,
"isAt" : 0,
"timeSend" : 1522034878,
"type" : 1
}</body></message>
(3)發(fā)送回執(zhí)消息類型：
<message to="109965@domain/resource" type="chat"><received xmlns="urn:xmpp:receipts" id="cdc6007ca03b401f8c9e4a2ccb75d8d5"/></message>
(4)接收回執(zhí)消息類型：
<message xmlns="jabber:client" type="chat" to="111751@domain/resource" from="109965@domain/resource"><received xmlns="urn:xmpp:receipts" id="626b61f461eb485fa99177b69512273e"></received></message>
流程：客戶端A給客戶端B發(fā)送一條消息，消息先從客戶端A傳到服務(wù)器歪沃，服務(wù)器通過判斷客戶端B是否在線嗦锐，如果在線的就直接把消息推送給客戶端B，客戶端B收到消息以后沪曙，則發(fā)送后回執(zhí)奕污，服務(wù)器收到回執(zhí)以后再推給客戶端A。
如果客戶端B不在線液走，則消息在服務(wù)器端保存碳默，服務(wù)器發(fā)送回回執(zhí)告訴客戶端A發(fā)送消息成功，等客戶端B上線以后再把消息推送給客戶端B缘眶。
問題1: 當客戶端A給B推送消息時嘱根，客戶端B正好此時進入后臺。由于后臺心跳檢測還沒有檢測到B已經(jīng)離線巷懈，這個時候服務(wù)器會把消息推送給客戶端B该抒，并且服務(wù)器沒有保存這條消息。而此時客戶端B已經(jīng)進入后臺顶燕，無法接收到消息凑保，也就無法發(fā)送回執(zhí)。會造成客戶端A發(fā)送消息失敗割岛。
解決方法：服務(wù)器每次收到客戶端A都會發(fā)送的消息愉适，都會由服務(wù)器發(fā)送回執(zhí)告訴A已經(jīng)發(fā)送成功⊙⑵幔客戶端首先保存聊天信息维咸，再客戶端B是否在線。如果在線惠爽，則發(fā)送消息癌蓖，接受回執(zhí)，如果沒有收到回執(zhí)婚肆，則當成不在線租副，保存聊天消息為未發(fā)送狀態(tài)，下次等客戶端B連線后推送较性。
3. xmpp IOS端使用架構(gòu)
封裝的xmpp類圖
（1） XMPPStream 類主要是設(shè)置主機名(HostName), 端口號(port), 鏈接xmpp服務(wù)器用僧，及獲取其delegate,來獲取登錄狀態(tài)及輸入xmppPassword來進行登錄
（2）XMPPReconnect來設(shè)置重新連接的時間结胀，及激活xmppStream
(3) xmppRoster 獲取好友花名冊
（4）xmppRosterStorage 來通過xmpp自帶的coreData數(shù)據(jù)庫保存用戶數(shù)據(jù)
（5）roomPool是保存用戶進入房間的池子，可以通過池子中的所有房間责循，獲取群聊房間的離線消息和退出登錄時糟港，退出所有群聊房間。
APPDelegate中調(diào)用xmpp的流程
- applicationWillEnterForeground方法中[[NTXmpp sharedInstance] login];
- applicationDidEnterBackground方法中[[NTXmpp sharedInstance] disconnect];
- 登錄成功以后[[NTXmpp sharedInstance] performSelector:@selector(login) withObject:nil afterDelay:0.5];//0.5秒后執(zhí)行xmpp登錄
XMPPHelper方法代碼
+ (NTXmpp*)sharedInstance
{
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
sharedManager = [[NTXmpp alloc] init];
[sharedManager setupStream];
});
return sharedManager;
}
//開始配置xmppstream
#pragma mark--------配置XML流---------
- (void)setupStream
{
NSAssert(xmppStream == nil, @"Method setupStream invoked multiple times");
xmppStream = [[XMPPStream alloc] init];
#if !TARGET_IPHONE_SIMULATOR
{
xmppStream.enableBackgroundingOnSocket = YES;
}
#endif
xmppReconnect = [[XMPPReconnect alloc] init];
xmppReconnect.reconnectTimerInterval = 10;
//xmppRosterStorage = [[XMPPRosterCoreDataStorage alloc] init];
//xmppRoster = [[XMPPRoster alloc] initWithRosterStorage:xmppRosterStorage];
//xmppRoster.autoFetchRoster = YES;
//xmppRoster.autoAcceptKnownPresenceSubscriptionRequests = YES;
[xmppReconnect activate:xmppStream];
//[xmppRoster activate:xmppStream];
// Add ourself as a delegate to anything we may be interested in
[xmppStream addDelegate:self delegateQueue:dispatch_get_main_queue()];
[xmppReconnect addDelegate:self delegateQueue:dispatch_get_main_queue()];
[xmppStream setHostName:g_config.XMPPHost];
[xmppStream setHostPort:5222];
// You may need to alter these settings depending on the server you're connecting to
//allowSelfSignedCertificates = NO;
//allowSSLHostNameMismatch = NO;
self.roomPool = [[NTRoomPool alloc] init];
}
//xmpp登陸
- (void)login
{
if (isLogined == login_status_yes)
return;
if (![self connect]) {
[HUDNotificationCenter showMessage:@"服務(wù)連接失敗" hideAfter:2.0f];
};
}
- (BOOL)connect
{
if (![xmppStream isDisconnected])
return YES;
NSString* myJID = g_loginUser.userId;
//NSString *myPassword = [[NSUserDefaults standardUserDefaults] stringForKey:kMY_USER_PASSWORD]; 112003
NSString* myPassword = g_loginUser.xmppPassword;
if (myJID == nil || myPassword == nil) {
return NO;
}
self.isLogined = login_status_ing;
[self notify];
[xmppStream setMyJID:[XMPPJID jidWithString:[NSString stringWithFormat:@"%@@%@/%@", myJID, g_config.XMPPDomain, XMPP_RESOURCE]]];
password = myPassword;
NSError* error = nil;
if (![xmppStream connectWithTimeout:10 error:&error]) {
self.isLogined = login_status_no;
[self notify];
return NO;
}
return YES;
}
- (void)disconnect
{
[self goOffline];
[xmppStream disconnect];
}
#xmppStreamDelegate
- (void)xmppStreamDidConnect:(XMPPStream*)sender
{
NTLog(@"xmpp connect success");
isXmppConnected = YES;
NSError* error = nil;
if (![xmppStream authenticateWithPassword:password error:&error]) {
self.isLogined = login_status_no;
[self notify];
//DDLogError(@"Error authenticating: %@", error);
}
}
- (void)xmppStreamDidDisconnect:(XMPPStream*)sender withError:(NSError*)error
{
NTLog(@"xmpp did disconnect");
[self logout];
if (!isXmppConnected) {
//[xmppStream authenticateWithPassword:password error:&error];
}
}
- (void)xmppStreamDidAuthenticate:(XMPPStream*)sender
{
NTLog(@"xmpp did authenticate");
//DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
[self doLogin];
// NSError* error;
//[xmppStream authenticateWithPassword:password error:&error];
}
- (void)xmppStream:(XMPPStream*)sender didNotAuthenticate:(NSXMLElement*)error
{
NTLog(@"xmpp did not Autherticate");
NTLog(@"didNotAuthenticate :密碼校驗失敗院仿，登錄不成功,原因是：%@", [error XMLString]);
self.isLogined = login_status_no;
[self notify];
//DDLogVerbose(@"%@: %@", THIS_FILE, THIS_METHOD);
}
4. xmpp發(fā)送消息
xmpp發(fā)送消息需要把消息包裝成xml類型
#pragma mark------收發(fā)消息-------
- (void)sendMessage:(NTMessage*)msg roomName:(NSString*)roomName //TODO: 添加是否secret參數(shù)
{
XMPPMessage* aMessage;
NSString* from = [NSString stringWithFormat:@"%@@%@", msg.fromUserId, g_config.XMPPDomain];
if (roomName == nil) {
//單聊
NSString* to = [NSString stringWithFormat:@"%@@%@", msg.toUserId, g_config.XMPPDomain];
aMessage = [XMPPMessage messageWithType:@"chat" to:[XMPPJID jidWithString:to]];
to = nil;
}
else {
//群聊
NSString* roomJid = [NSString stringWithFormat:@"%@@muc.%@", roomName, g_config.XMPPDomain];
aMessage = [XMPPMessage messageWithType:@"groupchat" to:[XMPPJID jidWithString:roomJid]];
roomJid = nil;
}
[aMessage addAttributeWithName:@"id" stringValue:msg.messageId];
NSXMLElement* request = [NSXMLElement elementWithName:@"request" xmlns:@"urn:xmpp:receipts"];
[aMessage addChild:request];
request = nil;
DDXMLNode* node = [DDXMLNode elementWithName:@"body" stringValue:jsonString];
[aMessage addChild:node];
[xmppStream sendElement:aMessage];
//[aMessage release];
[_poolSend setObject:msg forKey:msg.messageId];
//NSrunloop的一個方法
[self performSelector:@selector(onSendTimeout:) withObject:msg afterDelay:[msg getMaxWaitTime]];
from = nil;
}
5. xmpp 接收消息流程
- (void)xmppStream:(XMPPStream*)sender didReceiveMessage:(XMPPMessage*)message
{
//analysis message
}
6 xmpp遇到的問題
- 群組消息同時推送過來的壓力
在xmpp登錄以后秸抚，需要通過接口獲取群列表，在使用for循環(huán)進行請求每個群的離線消息歹垫，如果距離上次時間太長剥汤，就會有很多離線消息等待解析，存儲到數(shù)據(jù)庫排惨。
解決方法：采用異步請求服務(wù)器吭敢，獲取離線消息，使用多線程來執(zhí)行消息的數(shù)據(jù)庫存儲若贮。使用主線程來把用戶加入到當前群省有。
- 當過多消息同時推送過來，內(nèi)存耗用過多谴麦，cpu耗能過大造成卡頓蠢沿。
主要是xmpp框架中有內(nèi)置的coredata數(shù)據(jù)庫，每條消息會存儲到coreData中匾效。并且這個是xmpp內(nèi)部控制的舷蟀。
解決方法。在xmpp框架中面哼，手動設(shè)置信息不保存到coreData中野宜。我們是用的fmdb來保存消息。
