Rxjava如何实现发送验证码倒计时功能-创新互联

小编给大家分享一下Rxjava如何实现发送验证码倒计时功能，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！

成都创新互联致力于互联网网站建设与网站营销，提供成都网站建设、成都做网站、网站开发、seo优化、网站排名、互联网营销、小程序开发、公众号商城、等建站开发，成都创新互联网站建设策划专家，为不同类型的客户提供良好的互联网应用定制解决方案，帮助客户在新的全球化互联网环境中保持优势。

具体内容如下

首先在gradle添加依赖：

compile 'io.reactivex:rxandroid:1.2.1'

compile 'io.reactivex:rxjava:1.1.6'

xml布局：

java代码：

package luoxiang.com.rxcountdown;
 
import android.graphics.Color;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
 
 
import java.util.concurrent.TimeUnit;
 
import rx.Observable;
import rx.Observer;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Action0;
import rx.functions.Func1;
 
 
public class MainActivity extends AppCompatActivity {
 
  private Button mSend;
  private static final String TAG = "MainActivity";
 
  @Override
  protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_main);
 
    init();
 
  }
 
  private void init() {
 
    mSend = (Button) findViewById(R.id.btn);
    mSend.setOnClickListener(new View.OnClickListener() {
      @Override
      public void onClick(View view) {
        final int count = 30;
 
        Observable.interval(0, 1, TimeUnit.SECONDS)//设置0延迟，每隔一秒发送一条数据
            .take(count+1) //设置循环11次
            .map(new Func1() {
              @Override
              public Long call(Long aLong) {
                return count-aLong; //
              }
            })
            .doOnSubscribe(new Action0() {
              @Override
              public void call() {
                mSend.setEnabled(false);//在发送数据的时候设置为不能点击
 
                mSend.setBackgroundColor(Color.GRAY);//背景色设为灰色
              }
            })
 
            .observeOn(AndroidSchedulers.mainThread())//操作UI主要在UI线程
            .subscribe(new Observer() {
              @Override
              public void onCompleted() {
                Log.d(TAG, "onCompleted: ");
                mSend.setText("获取验证码");//数据发送完后设置为原来的文字
                mSend.setTextColor(Color.BLACK);
                mSend.setBackgroundColor(Color.parseColor("#f97e7e"));//数据发送完后设置为原来背景色
              }
 
              @Override
              public void onError(Throwable e) {
                e.printStackTrace();
              }
 
              @Override
              public void onNext(Long aLong) { //接受到一条就是会操作一次UI
                Log.d(TAG, "onNext: "+aLong);
                mSend.setText("剩余时间"+aLong+"秒");
                mSend.setEnabled(true);
                mSend.setTextColor(Color.WHITE);
 
              }
            });
      }
    });
  }
 
}

代码相对比较简单，做了详细的注释，要使用Rxjava需要明白什么是观察者模式。剩下的就去理解和怎么样组合使用Rxjava的各种操作符。

以上是“Rxjava如何实现发送验证码倒计时功能”这篇文章的所有内容，感谢各位的阅读！相信大家都有了一定的了解，希望分享的内容对大家有所帮助，如果还想学习更多知识，欢迎关注创新互联行业资讯频道！

文章标题：Rxjava如何实现发送验证码倒计时功能-创新互联
当前网址：http://mswzjz.cn/article/isigo.html