全栈工场实训13---Android---消息总线机制

昨天发表的博文讲述了Android中，采用异步任务进行网络请求的内容，在异步任务结束时，采用Handler机制通知原来的Activity进行界面更新，网友 traburiss指出，异步任务的onPostExecute已经在UI线程中了，再用Handler等于要到下一个UI运行周期才能执行，效率会降低不少，而且违反了异步任务的本意。感谢 traburiss的意见，他说得非常正确，我之所以用到Handler，是因为要在Android应用开发中引入消息总线的概念，想基于Handler来做，所以才使用了这个技术，看来是不恰当的。所以在本篇博文中，我把涉及消息总线实现部分，一起讲出来，这样就避免了网友的提出的问题。

首先介绍一下消息总线，消息总线指系统发生的事件，如收到用户注册成功的异步任务完成消息，系统将消息放到消息总线上，对这个消息感兴趣的应用组件，可以订阅这个消息总线，这样当消息发生时，这些组件会得到通知，从而完成消应的操作。引入消息总线技术，其主要优点是可以实现组件间的松耦合，消息生产者不用关心哪个组件会使用这个消息，只需将产生的消息放到消息总线上即可。而消息消费者订阅这个消息总线，当消息发生时，就可以进行相应的处理了。

我们先来看消息总线的实现机制，代码如下所示：

public class WkyMessageBus {
	public static void prepareEventBus() {
		messageBus = new HashMap<String, HashMap<String, Handler>>();
		// 将所有消息类型加到消息总线上
		HashMap<String, Handler> registerUserListeners = new HashMap<String, Handler>();
		messageBus.put("" + WkyConstants.MSG_WHAT_REGISTER_USER, registerUserListeners);
	}

	public static void registerToMessageBus(int messageTypeId, String listenerName, Handler handler) {
		HashMap<String, Handler> listeners = messageBus.get("" + messageTypeId);
		listeners.put(listenerName, handler);
	}

	public static void unregisterToMessageBus(int messageTypeId, String listenerName) {
		HashMap<String, Handler> listeners = messageBus.get("" + messageTypeId);
		listeners.remove(listenerName);
	}

	public static void postMessage(Message msg) {
		HashMap<String, Handler> handlers = messageBus.get("" + msg.what);
		for (Handler handler : handlers.values()) {
			handler.sendMessage(msg);
		}
	}
	private static HashMap<String, HashMap<String ,Handler>> messageBus = null;
}

如上面代码所示，用messageBus来代表消息总线的集合，Android的Message对象的what值变为字符串作为key，其值为一个列表，列表元素为Handler，通过该handler可以向Activity发送消息，通知相应Activity进行相关操作。

Activity通过registerToMessageBus方法，订阅到消息总线。在Activity销毁时调用unregisterToMessageBus方法，从消息总线上注销。

消息生产者产生消息后，通过postMessage将消息发布到消息总线上来。

在应用启动时，即应用的Application对象的onCreate方法中，初始化消息总线。

WkyMessageBus.prepareEventBus();

如上篇文章所述，当异步任务结束时，会发送消息到消息总线：

	/**
	 * 异步任务结束时要调用的方法，通知页面进行更新
	 * 【闫涛 2015.09.24】初始版本
	 */
	@Override
	protected void onPostExecute(String result) {
		JSONObject json = null;
		long userId = 0;
		try {
			json = new JSONObject(result);
			userId = json.getLong("userId");
		} catch (JSONException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		WkyRegisterLoginModel model = (WkyRegisterLoginModel)activity.getModel();
		model.setUserId(userId);
		activity.onAsyncTaskResult();
		Message msg = handler.obtainMessage();
		msg.what = WkyConstants.MSG_WHAT_REGISTER_USER;
		Bundle params = new Bundle();
		params.putString(WkyConstants.MSG_DATA_NAME, result);
		msg.setData(params);
		WkyMessageBus.postMessage(msg);
	}

这段代码有三个部分，第一部分是更新对应的Model对象中的数据，第二个部分是调用WkyActivity基类所定义JysRegisterLoginActivity重载的onAsyncTaskResult方法，实现界面的更新，第三个部分是产生一个Message对象，并发送到消息总线上去。

JysRegisterLoginActivity在启动时，注册到消息总线上去，在销毁时从消息总线注销，代码如下所示：

	@Override
	protected void onCreate(Bundle savedInstanceState) {
		super.onCreate(savedInstanceState);
		setContentView(com.weikangyun.wkylib.R.layout.activity_register_login);
		handler = new JysRegisterLoginHandler(this);
		messageBusListenerName = this.getClass().getCanonicalName() + System.currentTimeMillis();
		WkyMessageBus.registerToMessageBus(WkyConstants.MSG_WHAT_REGISTER_USER,
				messageBusListenerName, handler);
		getViewObjects();
		setupGuis();
		setupActionListeners();
	}	

	@Override
	public void onDestroy() {
		super.onDestroy();
		WkyMessageBus.unregisterToMessageBus(WkyConstants.MSG_WHAT_REGISTER_USER, messageBusListenerName);
	}

当系统产生消息，会向Activity发送消息，其消息处理如下所示：

	static protected class JysRegisterLoginHandler extends WkyRegisterLoginHandler {
		public JysRegisterLoginHandler(JysRegisterLoginActivity activity) {
			this.activity = activity;
		}

		public void handleMessage(Message msg) {
			super.handleMessage(msg);
			// 自己额外的处理
			switch (msg.what) {
			case WkyConstants.MSG_WHAT_REGISTER_USER:
				activity.processRegisterUserResult(msg);
				break;
			}
		}
		private JysRegisterLoginActivity activity = null;
	}

上面其实还遗留了一个问题，就是异步消息结束时更新界面的问题。我们在应用的公共基Activity类WkyActivity中，定义了异步任务回调函数onAsyncTaskResult方法，如下所示：

	/**
	 * 当异步任务完成后，会回调本方法，执行具体的页面更新操作。需要实现两部分功能：
	 * 1. 异步任务：在onPostExecute函数中，将结果放到Activity对应的Model中
	 * 2. Activity中：从Model中取出数据，更新界面
	 * 【闫涛 2015.12.04】初始版本
	 */
	public void onAsyncTaskResult() {
	}

在具体的Activity类里，编写界面更新函数。注意，在异步任务结束的方法onPostExecute方法中，我们已经将所需数据更新到Model中，所以onAsyncTaskResult方法只需从Model中读出数据进行显示就可以了。

这里在补充一个问题，我们的网络请求为什么采用异步任务，而不是直接采用线程技术呢？是因为异步任务封装了线程与UI线程之间的交互吗？其实这只是其中的一个方面。因为在异步任务背后，是系统管理的线程池，系统会根据CPU核数，当前负载等因素，给出合适的线程解决方案（启动新线程还是复用老线程）。而自己启动线程的方案，由于不能获取上述信息，所以不可能进行任何系统级的优化。因此，建议在能用异步任务的情况下，还是尽量用异步任务来解决问题。

华丽的分隔线
******************************************************************************************************************************************************************************
希望大家多支持，有大家的支持，我才能走得更远，谢谢！
银行账号：622202 0200 1078 56128 闫涛
我的支付宝：[email protected]