本人有若干成套学习视频, 可试看! 可试看! 可试看, 重要的事情说三遍 包含Java, 数据结构与算法, iOS, 安卓, python, flutter等等, 如有需要, 联系微信tsaievan.
看了一下 XMPPFramework 的源码，真心看不懂啊，还是继续我们简单的内容吧
无论是使用单聊还是群聊, 我们都必须将三大节点之一的 message 节点加入到 XMPPStream 流中，这是完成消息传输的最重要的一步
其实，有这一步之后，我们的聊天消息是可以发送成功的，代码如下：
我们在 textField 的文本输入的文本取出，初始化消息 XMPPMessage 对象，再加入流中，就完成了消息的发送
#pragma mark *** textField代理 API ***
-(BOOL)textFieldShouldReturn:(UITextField *)textField
{
/* 初始化一个聊天模型 */
/**
* 第一个参数: 聊天类型,"chat"表示单聊
* 第二个参数: 聊天对象, 即聊天消息发送给谁
*/
XMPPMessage *message = [[XMPPMessage alloc]initWithType:@"chat" to:self.jid];
/* 添加聊天内容 */
[message addBody:textField.text];
/* 发送消息 */
[kYFXMPPManager.xmppstream sendElement:message];
/* 发送完毕之后清空文本 */
textField.text = nil;
[textField resignFirstResponder];
return YES;
}
我们在另外一个客户端给这个账号发送消息，可以发现两个代理方法都可以回调成功，控制台都有相应的日志输出
// -------- 流发送消息成功 --------
- (void)xmppStream:(XMPPStream *)sender didSendMessage:(XMPPMessage *)message
{
NSLog(@"消息发送成功");
!self.messageSendBlock ? :self.messageSendBlock(message);
}
// -------- 流接收消息成功 --------
- (void)xmppStream:(XMPPStream *)sender didReceiveMessage:(XMPPMessage *)message
{
NSLog(@"消息接收成功");
!self.messageReceiveBlock ? :self.messageReceiveBlock(message);
}
那么为什么在聊天界面不显示消息信息呢？那是因为我们的消息只存在 XMPPStream 流中，并没有进行数据持久化， 如果要做数据持久化的话，必须添加消息归档模块，这里涉及到的一个关键类就是“消息归档类”---
XMPPMessageArchiving
我们将这个模块添加到 XMPPStream 中就相当于将流截获，进行数据->模型的转换，然后用 CoreData框架保存在本地
斜体部分的功能 XMPPframework 框架已经帮我们完成
#import "YFXMPPManager+MessageArchive.h"
@implementation YFXMPPManager (MessageArchive)
- (void)addMessageArchivingModule
{
/* 初始化 */
self.xmppmessageArchiving = [[XMPPMessageArchiving alloc]initWithMessageArchivingStorage:[XMPPMessageArchivingCoreDataStorage sharedInstance] dispatchQueue:dispatch_get_main_queue()];
/* 无需配置 */
/* 激活 */
[self.xmppmessageArchiving activate:self.xmppstream];
}
@end
这样，我们在展示聊天信息的时候，就可以舒舒服服地使用 NSFetchResultsController 了
懒加载NSFetchResultsController（初始化）
#pragma mark *** Getter & Setter ***
- (NSFetchedResultsController *)fetchedResultsController
{
if (!_fetchedResultsController) {
/* 初始化查询请求 */
NSFetchRequest *fetchRequest = [NSFetchRequest fetchRequestWithEntityName:@"XMPPMessageArchiving_Message_CoreDataObject"];
fetchRequest.sortDescriptors = @[[NSSortDescriptor sortDescriptorWithKey:@"timestamp" ascending:YES]];
/* 设置谓词,只显示当前聊天者的聊天记录 */
fetchRequest.predicate = [NSPredicate predicateWithFormat:@"bareJidStr == %@",self.jid.bare];
_fetchedResultsController = [[NSFetchedResultsController alloc]initWithFetchRequest:fetchRequest managedObjectContext:[XMPPMessageArchivingCoreDataStorage sharedInstance].mainThreadManagedObjectContext sectionNameKeyPath:nil cacheName:nil];
/* 执行查询 */
[_fetchedResultsController performFetch:nil];
/* 刷新 tableView */
[self.tableView reloadData];
}
return _fetchedResultsController;
}
其实单聊和群聊是大同小异的， 有一点不同的就是，房间是要单独创建的，不然群聊在哪里进行呢？房间的创建又需要一个新的 JID，和 nickname，创建成功后，有代理方法的回调，在代理方法中完成房间配置和邀请
房间创建过程
#import "YFXMPPGroupChatManager.h"
#import "YFXMPPManager.h"
@implementation YFXMPPGroupChatManager
+ (instancetype)sharedManager
{
static id instanceType = nil;
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
instanceType = [[YFXMPPGroupChatManager alloc]init];
});
return instanceType;
}
/**
* @param jid 房间的 Jid
* @param nickname 房间的昵称
*/
- (void)joinRoomWithJid:(XMPPJID *)jid andNickname:(NSString *)nickname
{
/* 初始化房间 */
self.xmppRoom = [[XMPPRoom alloc]initWithRoomStorage:[XMPPRoomCoreDataStorage sharedInstance] jid:jid dispatchQueue:dispatch_get_main_queue()];
/* 配置,无需配置 */
/* 只需要添加一个代理 */
[self.xmppRoom addDelegate:self delegateQueue:dispatch_get_main_queue()];
/* 激活 */
[self.xmppRoom activate:kYFXMPPManager.xmppstream];
/**
* @参数1:nickname
* @参数2:历史记录,填写 nil, 表示不获取历史记录
*/
/* 如果加入的房间在服务器中不存在,则创建,如果存在,就直接加入 */
[self.xmppRoom joinRoomUsingNickname:nickname history:nil];
}
#pragma mark *** Getter & Setter ***
// -------- 创建房间成功之后一定要做两件事情,否则房间无法使用 --------
/**
* 1. 配置房间
* 2. 邀请人到房间
*/
- (void)xmppRoomDidCreate:(XMPPRoom *)sender
{
/* 配置房间 */
[sender configureRoomUsingOptions:nil];
/* 查询房间配置 */
[sender fetchConfigurationForm];
/* 邀请人到房间 */
/**
* 参数1: 邀请对象的 jid
* 参数2: 邀请信息
*/
[sender inviteUser:[XMPPJID jidWithUser:@"tsaievan" domain:@"tsaievan.com" resource:nil] withMessage:@"今天晚上放学别走"];
[sender inviteUser:[XMPPJID jidWithUser:@"caiyifan" domain:@"tsaievan.com" resource:nil] withMessage:@"今晚放学别走"];
[sender inviteUser:[XMPPJID jidWithUser:@"mary" domain:@"tsaievan.com" resource:nil] withMessage:@"今天晚上放学请你喝红牛"];
}
// -------- 房间加入成功 --------
- (void)xmppRoomDidJoin:(XMPPRoom *)sender
{
/* 配置房间 */
[sender configureRoomUsingOptions:nil];
/* 查询房间配置 */
[sender fetchConfigurationForm];
/* 邀请人到房间 */
/**
* 参数1: 邀请对象的 jid
* 参数2: 邀请信息
*/
[sender inviteUser:[XMPPJID jidWithUser:@"tsaievan" domain:@"tsaievan.com" resource:nil] withMessage:@"今天晚上放学别走"];
[sender inviteUser:[XMPPJID jidWithUser:@"caiyifan" domain:@"tsaievan.com" resource:nil] withMessage:@"今晚放学别走"];
[sender inviteUser:[XMPPJID jidWithUser:@"mary" domain:@"tsaievan.com" resource:nil] withMessage:@"今天晚上放学请你喝红牛"];
}
// -------- 房间解散成功 --------
- (void)xmppRoomDidLeave:(XMPPRoom *)sender
{
}
@end
单聊和群聊的过程基本上就是这样，但是在实际写代码的时候还是会遇到很多坑，大家还是要自己敲一遍才可以深刻体会。
