RxJava入门--一步步了解Java回调机制

前段时间看了些关于RxJava的文章和代码，感觉虽然讲的很透彻，奈何理解的比较少，只会用一些最基础的方法。囧

昨天发现了一个RxJava的视频，好吧，我还是感觉看视频学的比较快...
下载地址

这篇文章主要是对昨天看的视频的回顾

不整个图感觉不像简书的风格

引子

现在我需要几个计算器，帮我计算物品的单价，这个肯定很简单的啦，代码直接贴出来好了

public class CalcService {

    public int calc(int total, int amount) {
        int result = result = total / amount;
        return result;
    }
}

调用这个计算方法

public class MainActivity extends AppCompatActivity {

    @Bind(R.id.btn1)
    Button btn1;
    private CalcService calc;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        ButterKnife.bind(this);

        calc = new CalcService();
    }

    @OnClick(R.id.btn1)
    public void onClick() {
        int result = calc.calc(20,5);
        Log.e("result",result+"");
    }
}

现在问题来了

我的计算器有点老化了，计算问题特别慢，得缓两秒才能得到答案，怎么搞

public class CalcService {

    public int calc(int total, int amount) {
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        int result = result = total / amount;
        return result;
    }
}

在实际案例中，计算方法会包含大量的耗时操作，比如网络请求，数据库操作等等

现在运行程序发现问题所在了

Ashampoo_S_clip9.gif

这就是android中常见的阻塞线程，而如果不解决这个问题，很可能出现ANR异常

如何解决这个问题呢？

以前的我是这么做的，不是阻塞线程吗，我放到子线程中执行不就行了？

于是会出现这样的代码

public class CalcService {
    int result;

    public int calc(final int total, final int amount) {
        new Thread(){
            @Override
            public void run() {
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                result = total / amount;

            }
        }.start();
        return result;
    }
}

运行之后，又出现问题了，第一次运行的时候值是0，第二次就是正确的值了

这是为什么呢？

这是因为第二次请求是得到上一次的结果

因为这个值是两秒之后算出来的，但是在算之前就把result的默认值，也就是0，返回出去了

而第二次请求的时候，result已经被赋值为4了，他还是没有等待2秒之后的值，而是把这个4直接返回出去了

这就是所谓的开启异步请求获取数据

如何得到正确的值呢？

这个时候，我们就需要 监听回调了
改一下代码

@OnClick(R.id.btn1)
    public void onClick() {
        calc.calc(20,5,this);

    }
    public void onSuccess(int result){
        Log.e("result",result+"");
    }

这里的区别就是传的值发生改变了，计算器不给力，那我把自己传过去，你算完了告诉我，省的我还得等着，啥时候完了告诉我一声就行了

public class CalcService {
    int result;

    public void calc(final int total, final int amount, final MainActivity activity) {
        new Thread(){
            @Override
            public void run() {
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                result = total / amount;
                activity.onSuccess(result);

            }
        }.start();
    }
}

这里回调onSuccess(result) 方法，将result数据传回去就行了

那有了onSuccess()方法，如果出现问题了，比如除数是0，是不是需要一个onFail()方法呢？
那如果调用calc()方法的不是MainActivity，而是别的地方，这该怎么修改呢？

面向接口编程

public interface OnResultListener{
        void onSuccess(int result);
        void onFail();
}

public void calc(final int total, final int amount, final OnResultListener resultListener) {
        new Thread(){
            @Override
            public void run() {
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                try {
                    result = total / amount;
                    resultListener.onSuccess(result);
                } catch (Exception e) {
                    e.printStackTrace();
                    resultListener.onFail();
                }


            }
        }.start();
    }

这样只有需要calc()方法的地方，实现OnResultListener接口就可以调用这个方法了

通过监听回调的形式进行解耦

public class MainActivity extends AppCompatActivity implements CalcService.OnResultListener{

    @Bind(R.id.btn1)
    Button btn1;
    private CalcService calc;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        ButterKnife.bind(this);

        calc = new CalcService();
    }

    @OnClick(R.id.btn1)
    public void onClick() {
        calc.calc(20,5,this);

    }
    @Override
    public void onSuccess(int result){
        Log.e("result",result+"");
    }

    @Override
    public void onFail() {

    }
}

更进一步

如何向点击事件一样，写一个内部类形式的呢？

其实很简单，只需要写一个setOnResultListener(OnResultListener resultListener) 方法即可完美解决

private OnResultListener resultListener;
    public void setOnResultListener(OnResultListener resultListener){
        this.resultListener = resultListener;
    }

    public void calc(final int total, final int amount) {
        new Thread(){
            @Override
            public void run() {
                try {
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                try {
                    result = total / amount;
                    if(resultListener!=null){
                        resultListener.onSuccess(result);
                    }

                } catch (Exception e) {
                    e.printStackTrace();
                    resultListener.onFail();
                }


            }
        }.start();
    }

调用起来

@OnClick(R.id.btn1)
    public void onClick() {
        calc.calc(10,2);
        calc.setOnResultListener(new CalcService.OnResultListener() {
            @Override
            public void onSuccess(int result) {
                Log.e("success",result+"");
            }

            @Override
            public void onFail() {

            }
        });

    }

设计模式真的是很神奇，让代码的美展现的淋漓尽致

感谢大家喜欢