Android-IM消息接收事件之EventBus的应用

在即时通讯中需要不断接收服务端的消息。

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]);
}
}

那么[b]EventBus到底是个什么东西？[/b]

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

相关文章推荐

Android-IM从零开始开发一个即时通讯项目

Android-IM即时通讯关于消息撤回的处理

Android-IM给即时通讯添加一个自动聊天机器人

Android-IM使用极光即时通讯发送、接收好友请求