Swift DeveloperiOS猿媛圈iOS学习开发

Objective-C 通知(NSNotification)

2018-06-11  本文已影响12人  FlyElephant

Objective-C的通知是负责对象之间的通信,可以在NSNotificationCenter中注册观察对象,对象也可以NSNotificationCenter发送消息通知.发送对象和接收对象是一对多的关系,通知算是多播(multiCast)形式的一种,如果是向非特定的多个对象发送消息称之为广播(broadcast).

同步 or 异步

通知的注册和发送都是在NSNotificationCenter中实现的,注册观察者,发送消息,还有非常重要的对象销毁的时候注意移除通知.

- (void)addObserver:(id)observer selector:(SEL)aSelector name:(nullable NSNotificationName)aName object:(nullable id)anObject;
#endif

- (void)postNotification:(NSNotification *)notification;
- (void)postNotificationName:(NSNotificationName)aName object:(nullable id)anObject;
- (void)postNotificationName:(NSNotificationName)aName object:(nullable id)anObject userInfo:(nullable NSDictionary *)aUserInfo;

- (void)removeObserver:(id)observer;
- (void)removeObserver:(id)observer name:(nullable NSNotificationName)aName object:(nullable id)anObject;

- (id <NSObject>)addObserverForName:(nullable NSNotificationName)name object:(nullable id)obj queue:(nullable NSOperationQueue *)queue usingBlock:(void (^)(NSNotification *note))block NS_AVAILABLE(10_6, 4_0);
    // The return value is retained by the system, and should be held onto by the caller in
    // order to remove the observer with removeObserver: later, to stop observation.

注册观察者:

 [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(updateData1:) name:@"updateData" object:nil];
    
    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(updateData2:) name:@"updateData" object:nil];

发送通知:

[[NSNotificationCenter defaultCenter] postNotificationName:@"updateData" object:@{@"age":@"27"} userInfo:@{@"name":@"FlyElephant"}];

收到通知:

- (void)updateData1:(NSNotification *)notificaton {
    sleep(1);
    NSLog(@"收到通知1---%@",notificaton);
}

- (void)updateData2:(NSNotification *)notificaton {
    NSLog(@"收到通知2---%@",notificaton);
}

执行结果:

收到通知1---NSConcreteNotification 0x60800004fc90 {name = updateData; object = {
    age = 27;
}; userInfo = {
    name = FlyElephant;
}}
收到通知2---NSConcreteNotification 0x60800004fc90 {name = updateData; object = {
    age = 27;
}; userInfo = {
    name = FlyElephant;
}}
FENotification[3959:7759128] 通知执行完成

调用通知的方法时,所有相关的观察者都会被有序的发送通知消息,是一个同步的过程,我们可以在收到消息之后异步执行代码,通知如果是在子线程中发出,主线程也会收到通知,最好发送的通知和接收通知都在同一个线程中.Objective-C提供了更简单的机制-通知队列(NSNotificationQueue).

NSNotificationQueue定义如下:

@property (class, readonly, strong) NSNotificationQueue *defaultQueue;
#endif

- (instancetype)initWithNotificationCenter:(NSNotificationCenter *)notificationCenter NS_DESIGNATED_INITIALIZER;

- (void)enqueueNotification:(NSNotification *)notification postingStyle:(NSPostingStyle)postingStyle;
- (void)enqueueNotification:(NSNotification *)notification postingStyle:(NSPostingStyle)postingStyle coalesceMask:(NSNotificationCoalescing)coalesceMask forModes:(nullable NSArray<NSRunLoopMode> *)modes;

- (void)dequeueNotificationsMatching:(NSNotification *)notification coalesceMask:(NSUInteger)coalesceMask;

注册通知:

[[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(updateData6:) name:@"updateData6" object:nil];

异步发送消息:

    NSNotification *myNotification = [NSNotification notificationWithName:@"updateData6" object:nil];
    [[NSNotificationQueue defaultQueue] enqueueNotification:myNotification postingStyle:NSPostWhenIdle coalesceMask:NSNotificationCoalescingOnName forModes:nil];
    NSLog(@"NSNotificationQueue---通知结束");

执行代码:

- (void)updateData6:(NSNotification *)notificaton {
    sleep(2);
    NSLog(@"NSNotificationQueue收到通知6---%@",notificaton);
}

关于通知队列有两个枚举比较重要:

typedef NS_ENUM(NSUInteger, NSPostingStyle) {
    NSPostWhenIdle = 1,
    NSPostASAP = 2,
    NSPostNow = 3
};

typedef NS_OPTIONS(NSUInteger, NSNotificationCoalescing) {
    NSNotificationNoCoalescing = 0,
    NSNotificationCoalescingOnName = 1,
    NSNotificationCoalescingOnSender = 2
};

NSPostingStyle设置消息发送的时机:
NSPostWhenIdle:在runloop空闲时发送,当runloop要退出时,不会发送.
NSPostASAP:Posting As Soon As Possible,在runloop的当前迭代完成时发送给通知中心,但是当前mode和设定的mode要一致.
NSPostNow:同步调用.

NSNotificationCoalescing是指消息聚合,默认不聚合.
NSNotificationCoalescingOnName:根据通知名称来聚合,如果一段时间多个消息通知,只执行一次.
NSNotificationCoalescingOnSender:根据发送方来聚合.

以下代码聚合类型设置为NSNotificationNoCoalescing执行五次,如果设置为聚合类型,通知只执行一次.

for (NSInteger i = 0; i < 5; i++) {
        NSNotification *myNotification = [NSNotification notificationWithName:@"updateData6" object:nil];
        [[NSNotificationQueue defaultQueue] enqueueNotification:myNotification postingStyle:NSPostWhenIdle coalesceMask:NSNotificationCoalescingOnName forModes:nil];
    }
    NSLog(@"NSNotificationQueue---通知结束");

自定义实现

通知是典型的观察者模式,可以通过NSNotificationCenter提供的方法进行简单的通知实现模拟.

FENotification定义:

@interface FENotification : NSObject

@property (copy, nonatomic) NSString *name;

@property (strong, nonatomic) id object;

@property (copy, nonatomic) NSDictionary *userInfo;

@end

FENotificationCenter定义:

@interface FENotificationCenter : NSObject

@property (class, readonly, strong) FENotificationCenter *defaultCenter;

- (void)addObserver:(id)observer selector:(SEL)aSelector name:(NSString *)aName object:(nullable id)anObject;

- (void)postNotification:(NSString *)notification;
- (void)postNotificationName:(NSString *)aName object:(nullable id)anObject;
- (void)postNotificationName:(NSString *)aName object:(nullable id)anObject userInfo:(nullable NSDictionary *)aUserInfo;

- (void)removeObserver:(id)observer;
- (void)removeObserver:(id)observer name:(nullable NSString *)aName object:(nullable id)anObject;

- (id <NSObject>)addObserverForName:(nullable NSString *)name object:(nullable id)obj queue:(nullable NSOperationQueue *)queue usingBlock:(void (^)(FENotification *note))block NS_AVAILABLE(10_6, 4_0);
// The return value is retained by the system, and should be held onto by the caller in
// order to remove the observer with removeObserver: later, to stop observation.

@end

FENotificationModel定义:

typedef void(^OperationBlock)(FENotification *notification);

@interface  FENotificationModel: NSObject

@property (strong, nonatomic) id observer;

@property (assign, nonatomic) SEL sel;

@property (copy, nonatomic) NSString *notificationName;

@property (strong, nonatomic) id object;

@property (strong, nonatomic) NSOperationQueue *operationQueue;

@property (copy, nonatomic) OperationBlock block;

@end

@implementation FENotificationModel


@end

消息通知内部通过通知名称作为key,多个FENotificationModel对象的数组作为value.

@interface FENotificationCenter()

@property (strong, nonatomic) NSMutableDictionary  *observerDict;

@end

单例实现:

#pragma mark - LifeCycle

+ (FENotificationCenter *)defaultCenter {
    static FENotificationCenter *sharedCenter = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        sharedCenter = [[FENotificationCenter alloc] init];
    });
    return sharedCenter;
}

#pragma mark - Accessors

- (NSMutableDictionary *)observerDict {
    if (!_observerDict) {
        _observerDict = [[NSMutableDictionary alloc] init];
    }
    return _observerDict;
}

添加观察者:

- (void)addObserver:(id)observer selector:(SEL)aSelector name:(NSString *)aName object:(id)anObject {
    
    FENotificationModel *model = [[FENotificationModel alloc] init];
    model.observer = observer;
    model.sel = aSelector;
    model.notificationName = aName;
    model.object = anObject;
    
    NSMutableArray *value = [self.observerDict objectForKey:aName];
    if ([value count]) {
        [value addObject:model];
    } else {
        NSMutableArray *arr = [[NSMutableArray alloc] init];
        [arr addObject:model];
        self.observerDict[aName] = arr;
    }
}

- (id<NSObject>)addObserverForName:(NSString *)name object:(id)obj queue:(NSOperationQueue *)queue usingBlock:(void (^)(FENotification *))block {
    
    FENotificationModel *model = [[FENotificationModel alloc] init];

    model.notificationName = name;
    model.operationQueue = queue;
    model.block = block;
    
    NSMutableArray *value = [self.observerDict objectForKey:name];
    if ([value count]) {
        [value addObject:model];
    } else {
        NSMutableArray *arr = [[NSMutableArray alloc] init];
        [arr addObject:model];
        self.observerDict[name] = arr;
    }
    return nil;
}

发送通知实现:

- (void)postNotification:(NSString *)notification {
    [self postNotificationName:notification object:nil];
}

- (void)postNotificationName:(NSString *)aName object:(id)anObject {
    [self postNotificationName:aName object:anObject userInfo:nil];
}

- (void)postNotificationName:(NSString *)aName object:(id)anObject userInfo:(NSDictionary *)aUserInfo {
    NSMutableArray *value = self.observerDict[aName];
    if ([value count]) {
        
        for (FENotificationModel *model in value) {
            
            if (model.operationQueue) {
                NSOperationQueue *queue = model.operationQueue;
                NSBlockOperation *blockOperation = [NSBlockOperation blockOperationWithBlock:^{
                    FENotification *notification = [FENotification new];
                    notification.name = model.notificationName;
                    model.block(notification);
                }];
                [queue addOperation:blockOperation];
                
            } else {
                id observer = model.observer;
                SEL sel = model.sel;
#pragma clang diagnostic ignored "-Warc-performSelector-leaks"
                
                FENotification *notification = [FENotification new];
                notification.name = aName;
                notification.object = anObject;
                notification.userInfo = aUserInfo;
                [observer performSelector:sel withObject:notification];
            }
        }
    }
}

移除观察者:

- (void)removeObserver:(id)observer {
    
    for (NSString *key in [self.observerDict allKeys]) {
        
        NSMutableArray *data = self.observerDict[key];
        NSMutableArray *newData = [NSMutableArray new];
        for (NSInteger i=0; i < [data count]; i++) {
            FENotificationModel *model = data[i];
            if (model.observer != observer) {
                [newData addObject:model];
            }
        }
        
        if ([newData count] == 0) {
            [self.observerDict removeObjectForKey:key];
        } else {
            self.observerDict[key] = newData;
        }
    }
}

- (void)removeObserver:(id)observer name:(NSString *)aName object:(id)anObject {
    for (NSString *key in [self.observerDict allKeys]) {
        if (key == aName) {
            NSMutableArray *data = self.observerDict[key];
            NSMutableArray *newData = [NSMutableArray new];
            for (NSInteger i=0; i < [data count]; i++) {
                FENotificationModel *model = data[i];
                if (model.observer != observer) {
                    [newData addObject:model];
                }
            }
           
            if ([newData count] == 0) {
                [self.observerDict removeObjectForKey:key];
            } else {
                self.observerDict[key] = newData;
            }
        }
    }
}

参考链接:
NSNotifications

上一篇下一篇

猜你喜欢

热点阅读