Rxjava实现发送验证码倒计时功能

Rxjava实现发送验证码倒计时功能

本文为大家分享了使用Rxjava做一个发送验证码倒计时，供大家参考，具体内容如下

首先在gradle添加依赖：

compile 'io.reactivex:rxandroid:1.2.1'

compile 'io.reactivex:rxjava:1.1.6'

xml布局：

xmlns:tools="http://schemas.android.com/tools"

android:id="@+id/activity_main"

android:layout_width="match_parent"

android:layout_height="match_parent"

tools:context="luoxiang.com.rxcountdown.MainActivity"

android:padding="16dp"

android:orientation="vertical">

android:id="@+id/editText"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:hint="请输入手机号码"

http:///>

android:id="@+id/btn"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:background="#f97e7e"

android:text="获取验证码"

/>

xmlns:tools="http://schemas.android.com/tools"

android:id="@+id/activity_main"

android:layout_width="match_parent"

android:layout_height="match_parent"

tools:context="luoxiang.com.rxcountdown.MainActivity"

android:padding="16dp"

android:orientation="vertical">

android:id="@+id/editText"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:hint="请输入手机号码"

http:///>

android:id="@+id/btn"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:background="#f97e7e"

android:text="获取验证码"

/>

android:id="@+id/editText"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:hint="请输入手机号码"

http:///>

android:id="@+id/btn"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:background="#f97e7e"

android:text="获取验证码"

/>

android:id="@+id/btn"

android:layout_width="match_parent"

android:layout_height="wrap_content"

android:background="#f97e7e"

android:text="获取验证码"

/>

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的各种操作符。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。