前陣子看了 Mr Simple的部落格，關於事件匯流排的，自己也跟著學了下

一、什麼是EventBus

EventBus是一種基於事件釋出與訂閱模式的事件匯流排，實現了Activity、Fragment、Service元件或物件之間互動。讓釋出與訂閱充分的解耦。

二、與Android其他事件傳遞的區別

Android傳遞方式包括Handler、BroadcastReceiver、Interface回撥方式相比，它不需要像Handler一樣通過回撥進行通訊，還需要考慮是否需要在子執行緒操作等問題。

三、流程圖

註冊接受者的簡單流程圖

釋出事件的簡單流程圖

通俗的說：

訂閱事件

1、在我們OnCreate的時候EventBus.getDefault().register(this)註冊事件匯流排，EventBus會遍歷當前

物件的所有方法把所有的OnEvent方法記錄下來，以Map的方式記錄下來，其中key為OnEvent的引數型別，即傳遞的物件，value為OnEvent的方法。OnCreate執行完成後OnEventMainThread方法就以鍵值的形式存放在EventBus裡面。

釋出事件

2、呼叫EventBus.getDefault().post(傳遞的物件)，EventBus會根據傳遞的物件實參去查詢匯流排Map裡面對應的方法，找到了我們的onEventMainThread，最終呼叫反射去執行我們的方法。

四、以實時監控網路狀態為例子

Activity註冊事件匯流排

public class EventNetWorkActivity extends Activity {

	private TextView mNetworkState;
	NetWorkBroadCactReceiver receiver = null;

	@Override
	protected void onCreate(Bundle savedInstanceState) {
		// TODO Auto-generated method stub
		super.onCreate(savedInstanceState);
		setContentView(R.layout.activity_network);
		mNetworkState = (TextView) findViewById(R.id.id_network_state);
		registerBroadcastReceiver();
		EventBus.getDefault().register(this);

	}

	// 這裡的引數必須要是Event，跟post的對應一致
	public void onEventMainThread(NetEvent event) {
		Log.i("網路狀態onEventMainThread", "" + event.getConnectResult());
		if (event.getConnectResult()) {
			mNetworkState.setVisibility(View.GONE);
		} else {
			mNetworkState.setVisibility(View.VISIBLE);
		}
	}

	public void registerBroadcastReceiver() {
		IntentFilter intentfilter = new IntentFilter();
		intentfilter.addAction(ConnectivityManager.CONNECTIVITY_ACTION);
		receiver = new NetWorkBroadCactReceiver();
		registerReceiver(receiver, intentfilter);

	}

	@Override
	protected void onDestroy() {
		// TODO Auto-generated method stub
		EventBus.getDefault().unregister(this);
		unregisterReceiver(receiver);
		super.onDestroy();
	}

}
 

注意：onEventMainThread裡面的引數必須要是自定義的EventType，就是傳遞的物件，否則系統找不到該方法不會執行。

public class NetWorkBroadCactReceiver extends BroadcastReceiver {

	@Override
	public void onReceive(Context context, Intent intent) {
		String action = intent.getAction();
		if (ConnectivityManager.CONNECTIVITY_ACTION.equals(action)) {
			boolean isConnected = NetUtils.isNetworkConnected(context);
			System.out.println("網路狀態：" + isConnected);
			System.out.println("wifi狀態：" + NetUtils.isWifiConnected(context));
			System.out.println("行動網路狀態：" + NetUtils.isMobileConnected(context));
			System.out.println("網路連線型別：" + NetUtils.getConnectedType(context));
			if (isConnected) {
				Log.i("提交", isConnected+"");
				<span style="color:#ff0000;">EventBus.getDefault().post(new NetEvent(true));</span>
			} else {
				<span style="color:#ff0000;">EventBus.getDefault().post(new NetEvent(false));</span>
			}
		}

	}

五、訂閱事件的四種方法

1、OnEvent ：該事件在哪個執行緒發出，OnEvent就在那個執行緒執行，即釋出事件和接收事件都在同一個執行緒，使用這個方法OnEvent不能執行耗時的任務，否則會阻塞主執行緒

2、OnEventMainThread：無論事件在那個執行緒釋出，OnEventMainThread都在UI執行緒執行執行，接收執行緒就在UI執行緒執行，更新UI是在主執行緒，當然也不能執行耗時任務

3、OnEventMainThread：無論事件在那個執行緒釋出，OnEventMainThread都在UI執行緒執行執行，接收執行緒就在UI執行緒執行，更新UI是在主執行緒，當然也不能執行耗時任務

4、onEventBackground:如果使用onEventBackgrond作為訂閱函式，那麼如果事件是在UI執行緒中釋出出來的，那麼onEventBackground就會在子執行緒中執行，如果事件本來就是子執行緒中釋出出來的，那麼onEventBackground函式直接在該子執行緒中執行。

5、onEventAsync：使用這個函式作為訂閱函式，非同步訂閱，無論事件在哪個執行緒釋出，都會建立新的子執行緒在執行onEventAsync.

public void onEvent(Object object)

{
Log.e("hongliang","onEvent");
}

本類釋出本類訂閱

public class ItemListFragment extends ListFragment {

	@Override  
    public void onCreate(Bundle savedInstanceState)  
    {  
        super.onCreate(savedInstanceState);  
        // Register  
        EventBus.getDefault().register(this);  
    }  
  
    @Override  
    public void onDestroy()  
    {  
        super.onDestroy();  
        // Unregister  
       </span> EventBus.getDefault().unregister(this);<span style="color:#ff0000;">  
    }  
  
    @Override  
    public void onViewCreated(View view, Bundle savedInstanceState)  
    {  
        super.onViewCreated(view, savedInstanceState);  
        // 開啟執行緒載入列表  
        new Thread()  
        {  
            public void run()  
            {  
                try  
                {  
                    Thread.sleep(2000); // 模擬延時  
                    // 釋出事件，在後臺執行緒發的事件  
                    EventBus.getDefault().post(new ItemListEvent(Item.ITEMS));  
                } catch (InterruptedException e)  
                {  
                    e.printStackTrace();  
                }  
            };  
        }.start();  
    }  
  
    public void onEventMainThread(ItemListEvent event)  
    {  
        </span>setListAdapter(new ArrayAdapter<Item>(getActivity(),  
                android.R.layout.simple_list_item_activated_1,  
                android.R.id.text1, event.getItems())); <span style="color:#ff0000;"> 
    }  
  
    @Override  
    public void onListItemClick(ListView listView, View view, int position,  
            long id)  
    {  
        super.onListItemClick(listView, view, position, id);  
        EventBus.getDefault().post(getListView().getItemAtPosition(position));  
    }  

}