融云用户信息
融云认为，每一个设计良好且功能健全的 App 都应该能够在本地获取、缓存并在合适的时机更新 App 中的用户信息。所以，融云不维护和管理用户基本信息（用户ID、昵称、头像）的获取、缓存、变更和同步。
融云用户信息.jpeg
这篇文章主要是用于理解Coredata简单使用，用户缓存只是举个栗子😕，所以融云的工具类我就不贴出来了。
Coredata管理类
- 作为一个合格的工具类，起码要是单例，放在这里当温习吧
#import <CoreData/CoreData.h>
static CoreDataManager *coreDataManager = nil;
+ (instancetype)sharedManager{
static dispatch_once_t onceToken;
dispatch_once(&onceToken, ^{
coreDataManager = [[CoreDataManager alloc]init];
});
return coreDataManager;
}
- 初始化。
我是这样理解这几个类的，毕竟我对 database / table 等的概念比它们深
- NSManagedObjectContext —— 数据库管理员
- NSPersistentStoreCoordinator —— 数据库
- NSManagedObjectModel —— 数据库表
- NSEntityDescription —— 实体
因着这几个类的组合关系，所以 init 的时候肯定是由小及大。
2.1 NSManagedObjectModel
- (NSManagedObjectModel *)managedObjectModel {
if (!_managedObjectModel) {
// 从应用程序包中加载模型文件
// url 为CoreDataDemo.xcdatamodeld，注意扩展名为 momd，而不是 xcdatamodeld 类型
NSURL *modelURL = [[NSBundle mainBundle] URLForResource:@"RCUserData" withExtension:@"momd"];
_managedObjectModel = [[NSManagedObjectModel alloc] initWithContentsOfURL:modelURL];
}
return _managedObjectModel;
}
2.2 NSPersistentStoreCoordinator
- (NSPersistentStoreCoordinator *)persistentStoreCoordinator {
if (!_persistentStoreCoordinator) {
// 创建 coordinator 需要传入 managedObjectModel
_persistentStoreCoordinator = [[NSPersistentStoreCoordinator alloc] initWithManagedObjectModel:self.managedObjectModel];
// 指定本地的 sqlite 数据库文件
NSURL *sqliteURL = [[NSFileManager documentsURL] URLByAppendingPathComponent:@"RCOtherUers.sqlite"];
NSError *error;
// 为 persistentStoreCoordinator 指定本地存储的类型，这里指定的是 SQLite
[_persistentStoreCoordinator addPersistentStoreWithType:NSSQLiteStoreType
configuration:nil
URL:sqliteURL
options:nil
error:&error];
if (error) { // 直接抛异常
[NSException raise:@"falied to create persistentStoreCoordinator" format:@"%@",[error localizedDescription]];
}
}
return _persistentStoreCoordinator;
}
2.3 NSManagedObjectContext
- (NSManagedObjectContext *)context {
if (!_context) {
// 指定 context 的并发类型： NSMainQueueConcurrencyType 或 NSPrivateQueueConcurrencyType
_context = [[NSManagedObjectContext alloc ] initWithConcurrencyType:NSMainQueueConcurrencyType];
_context.persistentStoreCoordinator = self.persistentStoreCoordinator;
}
return _context;
}
2.4 Enity 详见自己的 RCUserData.xcdatamodeld 文件
在这里，实体为RCUser。Attributes：name / userId / portraitUri 。
- 操作方法
3.1 增
- (void)insertNewObjectWithRCUserInfo:(NSString *)userId name:(NSString *)name portraitUri:(NSString *)portraitUri completion:(void (^)(RCUser* user))completion
{
NSEntityDescription *description = [NSEntityDescription entityForName:@"RCUser" inManagedObjectContext:self.context];
RCUser *user = [[RCUser alloc]initWithEntity:description insertIntoManagedObjectContext:self.context];
user.userId = userId;
user.name = name;
user.portraitUri = portraitUri;
// 利用上下文对象，将数据同步到持久化存储库
NSError *error = nil;
BOOL success = [self.context save:&error];
if (!success) {
[NSException raise:@"访问数据库错误" format:@"%@", [error localizedDescription]];
}else{
completion(user);
}
}
3.2 改
- (void)updateObjectWithRCUserInfo:(NSString *)userId name:(NSString *)name portraitUri:(NSString *)portraitUri{
NSArray *results = [self fetchObjectWithRCUserInfo:userId];
if (results.count >=1) {
RCUser *user = [results firstObject];
[self.context refreshObject:user mergeChanges:YES];
}
[self.context save:nil];
}
3.3 查
- (NSArray *)fetchObjectWithRCUserInfo:(NSString *)userId{
AXLog(@"%@",[NSFileManager documentsPath]);
// 初始化一个查询请求
NSFetchRequest *fetchRequest = [[NSFetchRequest alloc] init];
// 设置要查询的实体
NSEntityDescription *entity = [NSEntityDescription entityForName:@"RCUser" inManagedObjectContext:self.context];
[fetchRequest setEntity:entity];
// 注意：数据库SQL语句中的%要用*来代替
if (userId != nil) {
AXLog(@"走了");
NSPredicate *predicate = [NSPredicate predicateWithFormat:@"userId = %@",userId];
[fetchRequest setPredicate:predicate];
}
//设置排序（按照userId升序）
NSSortDescriptor *sortDescriptor = [[NSSortDescriptor alloc] initWithKey:@"userId" ascending:YES];
[fetchRequest setSortDescriptors:[NSArray arrayWithObjects:sortDescriptor, nil]];
// 如果没有setSortDescriptors 和 setPredicate ，查询到的数据是All
NSError *error = nil;
NSArray *fetchedObjects = [self.context executeFetchRequest:fetchRequest error:&error];
if (error) {
[NSException raise:@"查询错误" format:@"%@", [error localizedDescription]];
}
if (fetchedObjects.count > 0) {
return fetchedObjects;
}else{
return nil;
}
}
3.4 删
- (void)deleteObjectWithRCUserInfo:(NSString *)userId{
NSArray *results = [self fetchObjectWithRCUserInfo:userId];
for (RCUser *user in results) {
if (user.userId == userId) {
[self.context deleteObject:user];
}
}
[self.context save:nil];
}
CoredataManager使用
融云设置了RCIMReceiveMessageDelegate之后，当有信息时自动调用下面的方法。
注意区分：RCUserInfo是融云用户模型，RCUser是xcdatamodeld 文件中创建的实体
#pragma mark - RCIMReceiveMessageDelegate
// 接收消息的回调方法
- (void)onRCIMReceiveMessage:(RCMessage *)message
left:(int)left{
// 刷新角标
[self refreshBadgeValue];
// 查询本地是否有缓存
if(![self hasTheFriendWithUserId:message.senderUserId]){
if (![[CoreDataManager sharedManager] fetchObjectWithRCUserInfo:message.senderUserId]) {
//向服务器请求发送者信息信息并缓存---更新self.otherUserArrM
[self syncUsersInfoList:@[message.senderUserId] completion:^(NSMutableArray *friends, BOOL isSuccess) {
RCUserInfo *info = [friends firstObject];
[[CoreDataManager sharedManager]insertNewObjectWithRCUserInfo:info.userId name:info.name portraitUri:info.portraitUri completion:^(RCUser *user) {
AXLog(@"%@",user.portraitUri);
[self.otherUserArrM addObject:user];
}];
}];
}
}
}
