在即时通讯中需要不断接收服务端的消息。
JMessage提供了Event来匹配本地和服务端的消息接收。
在即时通讯项目中需要大量用到消息接收事件。所以结合项目简单分析下其实现的原理和过程。
事件接收类的注册
JMessageClient.registerEventReceiver(Object receiver);
JMessageClient.registerEventReceiver(Object receiver, int priority);
参数说明
Object receiver 消息接收类对象
int priority 定义事件接收者接收事件的优先级，默认值为0，优先级越高将越先接收到事件。（优先级只对同一个线程模式中的接收者有效）
事件接收类的解绑
JMessageClient.unRegisterEventReceiver(Object receiver);
事件接收
注册事件接收类之后，需要在消息接收类中实现如下方法来接收对应消息。sdk将根据实现方法的方法名来区分不同的线程模式，常用的线程模式有onEvent(默认线程模式)和onEventMainThread(主线程模式)两种。
可以通过定义不同类型的参数，来接收不同种类的事件
1、默认线程（子线程）模式
public void onEvent(EventEntity event){
//do your own business
}
方法体将在默认线程（子线程）中被调用， 可以用来处理耗时操作。
参数定义
EventEntity event 事件对象。（ 定义不同类型参数可以接收不同种类事件，具体用法可以参考“示例代码“。）
2、主线程模式
public void onEventMainThread(EventEntity event){
//do your own business
}
源码
跟踪进入注册事件，发现其实注册事件是通过EventBus来完成
public static void registerEventReceiver(Object var0, int var1) {
if(var0 != null) {
if(!EventBus.getDefault().isRegistered(var0)) {
EventBus.getDefault().register(var0, var1);
} else {
j.h(TAG, z[19] + var0);
}
} else {
j.j(TAG, z[20]);
}
}
public static void unRegisterEventReceiver(Object var0) {
if(var0 != null) {
EventBus.getDefault().unregister(var0);
} else {
j.j(TAG, z[20]);
}
}
那么EventBus到底是个什么东西？
GreenDao和EventBus同属于一个开发者。
但是EventBus在GitHub的订阅量是GreenDao的两倍之多。可见应用之广泛，已经使用过GreenDao的开发者相信已经体会到了他的强大。
关于EventBus：
Android优化的事件总线，简化了活动，片段，线程，服务等之间的通信。较少的代码，更好的质量。
同样在JMessage中，也使用了EventBus作为事件接收的方法。
按照EventBus的使用方法，必须要做的三件事就是：
定义事件、消息订阅者、发送事件。
1、定义事件
用于消息的解析或者也可以说是消息的事件分类。
JMessage中已经定义了好了多个消息事件，用于即时通讯的事件处理。所以我们只需要去理解和应用。
常用的有：
- MessageEvent 消息事件
- MessageRetractEvent 撤回消息事件
- ContactNotifyEvent 好友通知事件
- ConversationRefreshEvent 消息漫游事件
- OfflineMessageEvent 离线消息事件
定义消息示例代码：
public class MessageRetractEvent {
private Conversation conversation;
private Message message;
public MessageRetractEvent(Conversation var1, Message var2) {
this.message = var2;
this.conversation = var1;
}
public Conversation getConversation() {
return this.conversation;
}
public Message getRetractedMessage() {
return this.message;
}
}
2、 消息订阅者
在任何收到任何消息，并且想要对消息做处理之前，都需要先注册消息事件，
一般是在生命周期开始的地方注册，在结束的地方销毁。
这里用的方法都是JMessage封装后的，原始请参考EventBus官方文档
比如：
public void onStart() {
super.onStart();
//注册
JMessageClient.registerEventReceiver(this);
}
@Override
protected void onDestroy() {
super.onDestroy();
//销毁
JMessageClient.unRegisterEventReceiver(this);
}
订阅者还需要一个消息接收的方法，用来匹配接收事件，所有的消息的操作都必须在注册了接收事件之后。
方法名是自定义的，在使用的时候要注意方法名的匹配，否则无法接收到消息。
在3.0以后使用了注解的方式，3.0之前必须要以onEvent为开头定义类。
所以从JMessage的方法定义来看，显然不是最新的。
建议在自己项目中使用的最新的EventBus
// 主线程
@Subscribe(threadMode = ThreadMode.MAIN)
public void onEventMainThread(MessageEvent event) {
Toast.makeText(getActivity(), event.message, Toast.LENGTH_SHORT).show();
}
// 子线程
@Subscribe
public void onEvent(SomeOtherEvent event) {
doSomethingWith(event);
}
3、发布者
如果直接使用EventBus，虽然能实现消息发送，但是对于复杂的消息分类无法区分，并且消息对话需要依赖服务端的实现。
EventBus.getDefault().post(new MessageEvent(0,"",message1));
所以只能用
JMessageClient.sendMessage(message1);
其它应用
上面只是对于在即时通讯中结合JMessage来简单了解EventBus的消息传递。
其他应用的地方还有：
- 用于线程间的通讯代替handler或用于组件间的通讯代替Intent
- 广泛用于团购,商城,社交等应用,比如易大师APP,易宸锋Application...
---------------来自百度百科
项目中引入EventBus的方法：
compile 'org.greenrobot:eventbus:3.0.0'
然后可以参照上面的使用步骤进行测试。
项目地址：https://github.com/wapchief/Android-IM
相关文章推荐
