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

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优化的事件总线，简化了活动，片段，线程，服务等之间的通信。较少的代码，更好的质量。

null

同样在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

相关文章推荐