iOS-Coredata-融云用户信息缓存

融云用户信息

融云认为，每一个设计良好且功能健全的 App 都应该能够在本地获取、缓存并在合适的时机更新 App 中的用户信息。所以，融云不维护和管理用户基本信息（用户ID、昵称、头像）的获取、缓存、变更和同步。

融云用户信息.jpeg

这篇文章主要是用于理解Coredata简单使用，用户缓存只是举个栗子😕，所以融云的工具类我就不贴出来了。

Coredata管理类

1. 作为一个合格的工具类，起码要是单例，放在这里当温习吧

#import <CoreData/CoreData.h>

static CoreDataManager *coreDataManager = nil;

+ (instancetype)sharedManager{
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        coreDataManager = [[CoreDataManager alloc]init];
    });
    return coreDataManager;
}

2. 初始化。
   我是这样理解这几个类的，毕竟我对 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. 操作方法
   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];
                }];
                
            }];
        }
    }
    
}