本文实例为大家分享了RxJava实现获取验证码辅助类的具体代码,供大家参考,具体内容如下
应用场景:
一般的项目中都有获取验证码这个功能,并且可能不止一个地方用到。其逻辑时通的:
…实时监控输入框中手机号或者邮箱的合法性
…合法时可点击获取验证码按钮
…点击按钮时调用接口去请求验证码,同时按钮变为不可点击,显示倒计时
…请求成功时执行正常逻辑,请求失败后倒计时取消,按钮状态恢复
设计思路
…整个功能涉及的对象:一个EditText用于输入账号信息,一个获取验证码的Button,一个Rxjava的管理器用于管理Rx事件的生命周期(不同的管理方案可自行配对)
…初始化监控EditText输入,初始化防抖按钮点击事件
…处理事件中的逻辑
…开发两个抽象方法,获取验证码的方法和验证规则方法
代码
package txcap.com.bigtime.utils;
import android.widget.Button;
import android.widget.EditText;
import com.jakewharton.rxbinding.view.RxView;
import com.jakewharton.rxbinding.widget.RxTextView;
import java.util.concurrent.TimeUnit;
import rx.Observable;
import rx.Subscriber;
import rx.Subscription;
import rx.android.schedulers.AndroidSchedulers;
import rx.functions.Action0;
import rx.functions.Action1;
import txcap.com.bigtime.Constant;
import txcap.com.bigtime.R;
import txcap.com.library.core.app.BaseApplication;
import txcap.com.library.core.rx.RxManager;
import txcap.com.library.utils.file.ResUtil;
/**
* @author gaojigong
* @version V1.0
* @Description: 处理验证码的工具
* @date 17/3/22
*/
public abstract class CheckCodeUtil {
private RxManager mRxManager;
private Button btnGetCheckCode;
private EditText edtAccount;
//验证码获取中,按钮始终是倒计时状态,不受输入框事件的影响
protected boolean countDowning = false;
//用于取消倒计时
private Subscription intervalSub;
public CheckCodeUtil(RxManager mRxManager, Button btnGetCheckCode, EditText edtAccount) {
this.mRxManager = mRxManager;
this.btnGetCheckCode = btnGetCheckCode;
this.edtAccount = edtAccount;
init();
}
private void init() {
RxView.enabled(btnGetCheckCode).call(false);
Observable<CharSequence> observableAccount = RxTextView.textChanges(edtAccount);
//账号输入不合理不能点击获取验证码
mRxManager.add(observableAccount
.subscribeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<CharSequence>() {
@Override
public void call(CharSequence charSequence) {
if(!countDowning){//这样能减少重复执行
if (etCheck(charSequence.toString())) {
RxView.enabled(btnGetCheckCode).call(true);
} else {
RxView.enabled(btnGetCheckCode).call(false);
}
}
}
}));
//点击获取验证码
mRxManager.add(
RxView.clicks(btnGetCheckCode)
.throttleFirst(Constant.CLICK_THROTTLE, TimeUnit.SECONDS)
.subscribe(new Action1<Void>() {
@Override
public void call(Void aVoid) {
getCheckCode();
}
})
);
}
/**
* 获取验证码
*/
private void getCheckCode() {
intervalSub = Observable.interval(0,1,TimeUnit.SECONDS, AndroidSchedulers.mainThread())
.take(Constant.CHECK_CODE_SECOND)
.doOnSubscribe(new Action0() {
@Override
public void call() {
getCodeNumber();
//按钮变为不可点击
RxView.enabled(btnGetCheckCode).call(false);
countDowning = true;
}
})
.subscribe(new Subscriber<Long>() {
@Override
public void onCompleted() {
countDowning = false;
RxTextView.text(btnGetCheckCode).call(ResUtil.getResString(BaseApplication.getAppContext(),R.string.get_check_code));
if(etCheck(edtAccount.getText().toString())){
RxView.enabled(btnGetCheckCode).call(true);
}
}
@Override
public void onError(Throwable e) {
countDowning = false;
RxTextView.text(btnGetCheckCode).call(ResUtil.getResString(BaseApplication.getAppContext(),R.string.get_check_code));
if(etCheck(edtAccount.getText().toString())){
RxView.enabled(btnGetCheckCode).call(true);
}
}
@Override
public void onNext(Long aLong) {
RxTextView.text(btnGetCheckCode).call((Constant.CHECK_CODE_SECOND - aLong)+"s");
}
});
mRxManager.add(intervalSub);
}
/**
* 获取验证码
*/
public abstract void getCodeNumber();
/**
* 验证规则
* @param str
* @return
*/
public abstract boolean etCheck(String str);
public void getCodeError(){
if(null != intervalSub){
if(!intervalSub.isUnsubscribed()){
intervalSub.unsubscribe();
RxTextView.text(btnGetCheckCode).call(ResUtil.getResString(BaseApplication.getAppContext(),R.string.get_check_code));
RxView.enabled(btnGetCheckCode).call(true);
countDowning = false;
}
}
}
}
使用实例
@BindView(R.id.edt_account)
EditText edtAccount;
@BindView(R.id.btn_get_check_code)
Button btnGetCheckCode;
private CheckCodeUtil checkCodeUtil;
checkCodeUtil = new CheckCodeUtil(mRxManager,btnGetCheckCode,edtAccount) {
@Override
public void getCodeNumber() {
mPresenter.getCode(edtAccount.getText().toString());
}
@Override
public boolean etCheck(String str) {
return StrCheckUtil.checkedAccount(str);
}
};
@Override
public void getCodeFailed(String message) {
showToastLong("获取验证码失败:" + message);
checkCodeUtil.getCodeError();
}
特点
…减少代码冗余
…方便需求维护
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持亿速云。
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。