Как мне совместно использовать хранилище Core Data между процессами, использующими NSDistributedNotifications?
BackgroundI»
Мы уже разместили вопрос об основахсовместное использование основного хранилища данных между процессами.
Я пытаюсь выполнить рекомендации, и яЯ сталкиваюсь с проблемами.
Моя цель
У меня есть два процесса - приложение-помощник и пользовательский интерфейс. Они оба используют одно хранилище данных. Я хочу, чтобы пользовательский интерфейс обновил егоNSManagedObjectContext, когда приложение-помощник сохранило новые данные в хранилище.
Текущий поток программы
Вспомогательный процесс приложения записывает данные в хранилище.
В приложении Helper я слушаю уведомления NSManagedObjectContextDidSaveNotification.
Когда контекст сохранен, я кодирую вставленные, удаленные и обновленные объекты, используя их представления URI и NSArchiver.
Я отправляю NSNotification в NSDistributedNotificationCenter с этим закодированным словарем как userInfo.
Процесс пользовательского интерфейса прослушивает уведомление о сохранении. Когда он получает уведомление, он разархивирует userInfo, используя NSUnarchiver.
Он просматривает все обновленные / вставленные / удаленные объекты из данных URI и заменяет их NSManagedObjects.
Он создает NSNotification с обновленными / вставленными / удаленными объектами.
Я вызываю mergeChangesFromContextDidSaveNotification: в контексте управляемого объекта процесса пользовательского интерфейса, передавая NSNotification, которое я построил на предыдущем шаге.
Эта проблема
Вставленные объекты штрафуются в штраф в контексте управляемого объекта пользовательского интерфейса, и они появляются в пользовательском интерфейсе. Проблема приходит с обновленными объектами. Они просто нет обновление.
Что я'мы пытались
Наиболее очевидная вещь, которую стоит попробовать, - это передать уведомление о сохранении из процесса вспомогательного приложения в процесс пользовательского интерфейса. Легко, правда? Ну нет. Распределенные уведомления выигралиЯ не могу этого сделать, так как словарь userInfo имеет неправильный формат. Тот'почему яя делаю все NSArchiving вещи. Я
мы пытались вызвать refreshObject: mergeChanges: YES для NSManagedObjects, которые нужно обновить, но это некажется, не имеет никакого эффекта.
мы попытались выполнить mergeChangesFromContextDidSaveNotification: селектор в основном потоке и текущем потоке. Похоже, ни один из них не влияет на результат.
мы пробовали использовать mergeChangesFromContextDidSaveNotification: раньше между потоками, что, конечно, намного проще и работает отлично. Но мне нужна эта же функциональность между процессами.
Альтернативы?
Я что-то здесь упускаю? Я'Я постоянно чувствую, что яЯ делаю это намного сложнее, чем нужно, но, прочитав несколько раз документацию и потратив на это несколько дней, я могуНе вижу другого способа обновления MOC в интерфейсе.
Есть ли более элегантный способ сделать это? Или я просто делаю глупую ошибку где-то в моем коде?
Кодекс
мы старались сделать его максимально читабельным, но этовсе еще беспорядок. Сожалею.
Код приложения Helper
-(void)workerThreadObjectContextDidSave:(NSNotification *)saveNotification {
NSMutableDictionary *savedObjectsEncodedURIs = [NSMutableDictionary dictionary];
NSArray *savedObjectKeys = [[saveNotification userInfo] allKeys];
for(NSString *thisSavedObjectKey in savedObjectKeys) {
// This is the set of updated/inserted/deleted NSManagedObjects.
NSSet *thisSavedObjectSet = [[saveNotification userInfo] objectForKey:thisSavedObjectKey];
NSMutableSet *thisSavedObjectSetEncoded = [NSMutableSet set];
for(id thisSavedObject in [thisSavedObjectSet allObjects]) {
// Construct a set of URIs that will be encoded as NSData
NSURL *thisSavedObjectURI = [[(NSManagedObject *)thisSavedObject objectID] URIRepresentation];
[thisSavedObjectSetEncoded addObject:thisSavedObjectURI];
}
// Archive the set of URIs.
[savedObjectsEncodedURIs setObject:[NSArchiver archivedDataWithRootObject:thisSavedObjectSetEncoded] forKey:thisSavedObjectKey];
}
if ([[savedObjectsEncodedURIs allValues] count] > 0) {
// Tell UI process there are new objects that need merging into it's MOC
[[NSDistributedNotificationCenter defaultCenter] postNotificationName:@"com.synapticmishap.lapsus.save" object:@"HelperApp" userInfo:(NSDictionary *)savedObjectsEncodedURIs];
}
}
Код пользовательского интерфейса
-(void)mergeSavesIntoMOC:(NSNotification *)notification {
NSDictionary *objectsToRefresh = [notification userInfo];
NSMutableDictionary *notificationUserInfo = [NSMutableDictionary dictionary];
NSArray *savedObjectKeys = [[notification userInfo] allKeys];
for(NSString *thisSavedObjectKey in savedObjectKeys) {
// Iterate through all the URIs in the decoded set. For each URI, get the NSManagedObject and add it to a set.
NSSet *thisSavedObjectSetDecoded = [NSUnarchiver unarchiveObjectWithData:[[notification userInfo] objectForKey:thisSavedObjectKey]];
NSMutableSet *savedManagedObjectSet = [NSMutableSet set];
for(NSURL *thisSavedObjectURI in thisSavedObjectSetDecoded) {
NSManagedObject *thisSavedManagedObject = [managedObjectContext objectWithID:[persistentStoreCoordinator managedObjectIDForURIRepresentation:thisSavedObjectURI]];
[savedManagedObjectSet addObject:thisSavedManagedObject];
// If the object is to be updated, refresh the object and merge in changes.
// This doesn't work!
if ([thisSavedObjectKey isEqualToString:NSUpdatedObjectsKey]) {
[managedObjectContext refreshObject:thisSavedManagedObject mergeChanges:YES];
[managedObjectContext save:nil];
}
}
[notificationUserInfo setObject:savedManagedObjectSet forKey:thisSavedObjectKey];
}
// Build a notification suitable for merging changes into MOC.
NSNotification *saveNotification = [NSNotification notificationWithName:@"" object:nil userInfo:(NSDictionary *)notificationUserInfo];
[managedObjectContext performSelectorOnMainThread:@selector(mergeChangesFromContextDidSaveNotification:)
withObject:saveNotification
waitUntilDone:YES];
}