一款简单的消息防抖框架

WQthrottle 是一款消息防抖框架，在必定的时间延时中作到只触发一次结果的回调。

使用

使用的话，仍是看 github 的 README 吧。

开发目的

开发这款框架的初衷是为了解决如下的几个痛点:

• 多余的操做请求
• 多页面消息传递

痛点一(多余的操做请求)

这个痛点在咱们的业务中常常出现，下面列出两个比较常见的业务操做：

点赞

在咱们设计点赞的时候，每点击一次 赞 操做都会请求服务器，以告知服务器当前是 点赞 操做仍是 取消赞 操做，若是用户这时频繁去点赞，就会致使过多的网络请求，产生了没必要要的浪费。对于设计层面来讲，点赞功能无非就是两种状态，赞或是没赞 ，咱们彻底能够等待用户中止操做后再去请求服务器。

搜索

实时搜索展现搜索内容也是咱们平时业务中比较常见的功能，咱们给 EditText 注册 TextWatcher 监听，在 onTextChanged 中实时拿到用户输入的内容而后请求网络，看似一段没有任何问题的操做，就败在不一样用户的输入习惯，有的人打字很是慢，打入一些词组，onTextChanged 收到消息立马请求服务器显示结果，而有的人打字很是快，并且每打一个词组就回车到 EditText 上，这就会致使频繁的网络请求，更糟糕的状况就是频繁的页面渲染，100次请求就会致使100次的页面渲染。

痛点二(多页面消息传递)

在刚接触 Android 开发时，页面的消息传递通常都是 Intent ，回传经过 setResult 将结果带回上一个页面，很是蛋疼的操做，直到后来出现 EventBus ，在业内很是流行，一款很是解耦的框架，能够作到在任何地方发送消息和接收消息，但对于我来讲，缺点仍是蛮多的：

• Subcribe 太随意，致使后面项目乱，很差维护
• Eventbus 的内部实现原理是反射，性能问题须要斟酌
• 每次 post 一个消息过去都要想，我这个 bean 会不会影响到其余的消息接收，算了，仍是建立一个 bean 类吧

原理剖析

实现原理很是简单， 就一个核心东西------《Handler》

初始化

初始化操做使用的单例，他会默认构造一个 handler 处理类：

handler = HandlerFactory.create(HandlerType.MAIN_THREAD, callBacks);
复制代码

HandlerType 是一个枚举类，该枚举主要为了告知接收器是在主线程仍是子线程，具体可看 HandlerFactory 类。

注册

注册很是简单，就是注册一个 CallBack 接口，等 post 消息时，会一一回调注册的 callback

private List<CallBack> callBacks = new ArrayList<>();
public void register(CallBack callBack) {
        callBacks.add(callBack);
}
复制代码

发送消息

发送消息整个框架的核心部分：

WQThrottle.getInstance().delay(int tag, long timeMillis, Object params);
复制代码

咱们来看下 delay 作的什么东西：

public void delay(int tag, long timeMillis, Object params) {
        handler.removeMessages(tag);
        Message msg = handler.obtainMessage();
        msg.obj = params;
        msg.what = tag;
        handler.sendMessageDelayed(msg, timeMillis);
   }
复制代码

仍是很是简单，就是在 delay 时间内，移除以前触发的消息，而后从新发送消息，直到用户不触发了，等 delay 时间到了，消息就会发送出去了。

消息接收

消息的接收须要先看看回调部分的代码：

new Handler(Looper.getMainLooper()) {
            @Override
            public void handleMessage(Message msg) {
                super.handleMessage(msg);
                sendMessages(msg, callBacks);
            }
};

private static void sendMessages(Message msg, List<WQThrottle.CallBack> callBacks) {
        for (int i = 0, len = callBacks.size(); i < len; i++) {
            callBacks.get(i).throttleResult(msg.what, msg.obj);
        }
}
复制代码

发送的消息被 Handler 接收到了，会遍历全部 CallBack 注册接口，将信息 post 出去。

@Override
 public void throttleResult(int tag, Object obj) {
     switch(tag){//do something}
 }
复制代码

CallBack 根据发送的 tag 进行比较，肯定是什么操做，而后取出参数 obj。

结束

整个设计很是简单，仅仅只经过 Handler 就实现了基于消息的框架。

话很少，就这样吧