不再分析了，理解了LiveData后，不难理解这个框架。

阅读本文前，请先阅读《Jetpack之LiveData源码分析》。因为LiveEventBus是基于LiveData构建的。

源码地址：LiveEventBus

典型用法如下：

// 监听消息
LiveEventBus
	.get("some_key", String.class)
	.observe(this, new Observer<String>() {
	    @Override
	    public void onChanged(@Nullable String s) {
	    }
	});

// 发送消息
LiveEventBus
	.get("some_key")
	.post(some_value);

其实，这三个方法就是最核心的，get、observe和post。通过get获取一个Observable对象，通过observe进行监听，通过post发送消息。我们就从这三个方法入手去分析其源码。

get方法分析

跟踪get方法，不难发现，是由LiveEventBusCore单例提供的with()方法返回的Observable，LiveEventBusCore中有一个名为bus的Map<String, LiveEvent

主要代码如下：

##LiveEvent

private class LiveEvent<T> implements Observable<T> {
  @NonNull
  private final String key;
  private final LifecycleLiveData<T> liveData;	// 继承自MutableLiveData，实现生命周期感知
  private final Map<Observer, ObserverWrapper<T>> observerMap = new HashMap<>(); // 存储ObserverWrapper对象
  private final Handler mainHandler = new Handler(Looper.getMainLooper()); // 便于切换到主线程
  
  /**
  * 进程内发送消息
  *
  * @param value 发送的消息
  */
  @Override
  public void post(T value) {
    if (ThreadUtils.isMainThread()) {
      postInternal(value);
    } else {
      mainHandler.post(new PostValueTask(value));
    }
  }
  
  /**
  * 注册一个Observer，生命周期感知，自动取消订阅
  *
  * @param owner    LifecycleOwner
  * @param observer 观察者
  */
  @Override
  public void observe(@NonNull final LifecycleOwner owner, @NonNull final Observer<T> observer) {
    if (ThreadUtils.isMainThread()) {
      observeInternal(owner, observer);
    } else {
      mainHandler.post(new Runnable() {
        @Override
        public void run() {
          observeInternal(owner, observer);
        }
      });
    }
  }
  
}

LiveEvent中通过一个成员变量Map<Observer, ObserverWrapper<T>> observerMap来存储ObserverWrapper。

ObserverWrapper是LiveData库中的Observer类的子类，