1

我已经发布了这个问题，没有人告诉我是什么问题，请帮助。

当我使用 Core Data 在我的iOS应用程序中保存数据时遇到问题。

我的应用程序可以在一秒钟内从服务器接收许多文本消息。

所以我需要将这些消息保存在我的数据库中，现在我使用NSOperations内部队列来保存消息（所以你可以想象中的数量NSOperation）NSOperationQueue。

问题是，如果我有正常的消息流，那么它工作正常，如果有重要的消息流，应用程序会无限期冻结或NSOperations队列中无限制地增加。

PS：如果删除合并的观察者，则保存消息没有任何问题

这是我的代码NSOperation：

@interface SaveRecievedMessageOperation()

@property (nonatomic, strong) NSManagedObjectContext *managedObjectContext;

@property (nonatomic, strong) AppDelegate *appdelegate;

@property (nonatomic, assign) BOOL executing;

@property (nonatomic, assign) BOOL finished;

@end

@implementation SaveRecievedMessageOperation

@synthesize message;
@synthesize managedObjectContext;
@synthesize appdelegate;
@synthesize executing;
@synthesize finished;



- (id)initWithMessage:(SipMessage *)messageToSave
{
    if (self = [super init]) {
        self.message = messageToSave;

    }
    return self;
}

- (void)main
{

    @autoreleasepool
    {

        self.appdelegate = [[UIApplication sharedApplication] delegate];

        [self managedObjectContext];

        [[NSNotificationCenter defaultCenter] addObserver:self
                                                       selector:@selector(mergeChanges:)
                                                             name:NSManagedObjectContextDidSaveNotification
                                                           object:self.managedObjectContext];

        [self saveMessage];


    }

}

- (NSManagedObjectContext *)managedObjectContext
{

    if (managedObjectContext != nil)
    {

        return managedObjectContext;

    }

    NSPersistentStoreCoordinator *coordinator = [self.appdelegate persistentStoreCoordinator];
    if (coordinator != nil) {
        managedObjectContext = [[NSManagedObjectContext alloc] initWithConcurrencyType:NSPrivateQueueConcurrencyType];
        [managedObjectContext setPersistentStoreCoordinator:coordinator];
        [managedObjectContext setMergePolicy:NSOverwriteMergePolicy];
    }
    return managedObjectContext;
}

- (void)saveMessage
{

    NSDictionary *header = self.message.headers;

    NSArray *bodies = self.message.bodies;

    SipBody *sipBody;
    NSDictionary* body;
    NSData *ContentData;
    if ([[header valueForKey:@"Content-Type"] rangeOfString:@"application/json"].location != NSNotFound)
    {
        sipBody = [bodies objectAtIndex:0];
        body = [NSJSONSerialization
                JSONObjectWithData:sipBody.content
                options:NSJSONReadingAllowFragments
                error:nil];
    }

    else if ([[header valueForKey:@"Content-Type"] rangeOfString:@"multipart/mixed"].location != NSNotFound)
    {
        for (SipBody *sipB in bodies) {
            if ([[sipB.headers valueForKey:@"Content-Type"] rangeOfString:@"application/json"].location != NSNotFound)
            {
                body = [NSJSONSerialization
                        JSONObjectWithData:sipB.content
                        options:NSJSONReadingAllowFragments
                        error:nil];
            }
            else
            {
                ContentData = [NSData dataWithData:sipB.content];
            }
        }
    }

    else
    {
        return;
    }
    MGMPhone *sender;

    NSArray *senders = [self updatePhonesFromMSISDNsList:[[header valueForKey:@"swfrom"] componentsSeparatedByString:MGMseparator]];
    sender = senders[0];


    NSError *error;
    MGMMessage *aMesage = [MGMMessage createInContext:self.managedObjectContext];
    [aMesage setBoxType:[NSNumber numberWithInteger:BoxTypeIncomingMessage]];
    [aMesage setContent:[body valueForKey:@"Content"]];
    [aMesage setContentType:[header valueForKey:@"Content-Type"]];
    [aMesage setGroupMessage:( [[header valueForKey:@"groupmessage"] isEqualToString:@"true"]
                              ?
  [self saveContext];   
}


#pragma mark core data

- (void)mergeChanges:(NSNotification *)notification
{

        dispatch_async(dispatch_get_main_queue(), ^{
            NSManagedObjectContext *mainContext = [appdelegate managedObjectContext];
            [mainContext performSelector:@selector(mergeChangesFromContextDidSaveNotification:) withObject:notification];


[self setManagedObjectContext:nil];

}

- (void)saveContext
{


    NSError *error = nil;
    if (self.managedObjectContext != nil)
    {
        if ([self.managedObjectContext hasChanges]) {

            BOOL isSaved = [self.managedObjectContext save:&error];
            if(!isSaved){

                NSLog(@"Unresolved error %@, %@", error, [error userInfo]);
                abort();
            }
        }
        else if (![self.managedObjectContext hasChanges]){
             [self setManagedObjectContext:nil];
        }
    }


  }


@end
4

1 回答 1

0

我认为一切都很好，除了合并操作。我自己在后台使用非常相似的 CoreData 操作。

通常，您希望将来自后台操作的更新与“主”托管对象上下文合并。所以基本上在后台操作中你应该只执行 save: 方法。（所以不要注册保存通知，也不要启动合并操作）。

除非您确实需要在后台线程中合并托管对象上下文，否则保存通知应该只在主线程中注册一次（通常在单例中，例如 appDelegate 或您自己的单例中）。在其他上下文中进行任何保存操作后，CoreData 将发送保存通知，允许您将这些更改与主上下文合并。

于 2013-11-13T14:44:39.370 回答