码迷,mamicode.com
首页 > 其他好文 > 详细

[Guava] EventBus

时间:2015-07-12 17:14:45      阅读:218      评论:0      收藏:0      [点我收藏+]

标签:

1.  发布-订阅模式

发布-订阅模式(publish-subscribe)是一种编程范式,发布方不发布消息给特定的接收方,而是由订阅方选择性接收。这使得发布方和订阅方相对独立,减少了耦合性。

在发布-订阅模式中,有以下几个难点:

1)如何区分或分配订阅者关注的消息;

2)发布者如何将消息提交给对应订阅者;

下图描述Guava EventBus对发布-订阅模式的实现。 

技术分享

 

2. 订阅者注册

下面是简单的订阅者实现:

// 订阅者
public class Subscriber  {
	@Subscribe
	public void process(String event) {
		System.out.print(event);		
	}
}

注册订阅者:

// 消息订阅
EventBus eventBus = new EventBus();
eventBus.register(new Subscriber());

Guava EventBus中有关注册的流程:

技术分享

 

Guava EventBus中有关注册的代码:

// SubscriberRegistry.register()
void register(Object listener) {
    // 查找订阅者中有Subscribe注解的方法
    // findAllSubscribers返回值: 函数参数类型-{EventBus,listener,有Subscribe注解的方法}
    Multimap<Class<?>, Subscriber> listenerMethods = findAllSubscribers(listener);

    for (Map.Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) {
      Class<?> eventType = entry.getKey();
      Collection<Subscriber> eventMethodsInListener = entry.getValue();

      // 所有订阅者  
      CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType);

      if (eventSubscribers == null) {
        CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<Subscriber>();
        eventSubscribers = MoreObjects.firstNonNull(
            subscribers.putIfAbsent(eventType, newSet), newSet);
      }

      eventSubscribers.addAll(eventMethodsInListener);
    }
  }

  

3. 事件提交&处理

eventBus.post("Hello, EventBus");

Guava EventBus中消息提交和处理流程:

  技术分享

 

Guava EventBus中消息提交和处理代码:

// EventBus.post(..)
public void post(Object event) {
    // 查找相关订阅者
    Iterator<Subscriber> eventSubscribers = subscribers.getSubscribers(event);
    
   if (eventSubscribers.hasNext()) {
      // 事件处理类型
      dispatcher.dispatch(event, eventSubscribers);
    } else if (!(event instanceof DeadEvent)) {
      // the event had no subscribers and was not itself a DeadEvent
      post(new DeadEvent(this, event));
    }
  }

  

Dispatcher有以下几种:

1. PerThreadQueuedDispatcher : 按照事件提交顺序进行处理(a breadth-first dispatch)。 // EventBus默认分配类型

2. LegacyAsyncDispatcher:若订阅者处理函数上有AllowConcurrentEvents注解,则使用线程中对象进行多线程并行处理;否则将使用同步处理。// AsyncEventBus默认分配类型

class Subscriber {
  static Subscriber create(EventBus bus, Object listener, Method method) {
    return method.getAnnotation(AllowConcurrentEvents.class) != null
        ? new Subscriber(bus, listener, method)
        : new SynchronizedSubscriber(bus, listener, method);
  }
}
Subscriber中dispatchEvent中处理方法:
final void dispatchEvent(final Object event) {
    executor.execute(new Runnable() {
      @Override
      public void run() {
         method.invoke(target, checkNotNull(event));
    });
  }

3. ImmediateDispatcher:立即将事件提交给对应的订阅者(a depth-first dispatch)

[Guava] EventBus

标签:

原文地址:http://www.cnblogs.com/life91/p/4641077.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!