ios - コア データ: バックグラウンド コンテキスト ios

Question

私はすでにこの問題を投稿しましたが、何が問題なのか誰も教えてくれません。助けてください。

iOSCore Data を使用してアプリにデータを保存すると問題が発生します。

私のアプリケーションは、サーバーから 1 秒間に非常に多くのテキスト メッセージを受信できます。

そのため、これらのメッセージをデータベースに保存する必要があります。今度はキュー内を使用してメッセージを保存します (したがって、内のNSOperationsの数を想像できます)。 NSOperationNSOperationQueue

問題は、メッセージの通常の流れがある場合は正常に機能し、重要なメッセージの流れがある場合、アプリが無期限にフリーズするか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