基于RxJava框架实现获取验证码的辅助类
本文实例为大家分享了RxJava实现获取验证码辅助类的具体代码,供大家参考,具体内容如下
应用场景:
一般的项目中都有获取验证码这个功能,并且可能不止一个地方用到。其逻辑时通的:
…实时监控输入框中手机号或者邮箱的合法性
…合法时可点击获取验证码按钮
…点击按钮时调用接口去请求验证码,同时按钮变为不可点击,显示倒计时
…请求成功时执行正常逻辑,请求失败后倒计时取消,按钮状态恢复
设计思路
…整个功能涉及的对象:一个EditText用于输入账号信息,一个获取验证码的Button,一个Rxjava的管理器用于管理Rx事件的生命周期(不同的管理方案可自行配对)
…初始化监控EditText输入,初始化防抖按钮点击事件
…处理事件中的逻辑
…开发两个抽象方法,获取验证码的方法和验证规则方法
代码
packagetxcap.com.bigtime.utils; importandroid.widget.Button; importandroid.widget.EditText; importcom.jakewharton.rxbinding.view.RxView; importcom.jakewharton.rxbinding.widget.RxTextView; importjava.util.concurrent.TimeUnit; importrx.Observable; importrx.Subscriber; importrx.Subscription; importrx.android.schedulers.AndroidSchedulers; importrx.functions.Action0; importrx.functions.Action1; importtxcap.com.bigtime.Constant; importtxcap.com.bigtime.R; importtxcap.com.library.core.app.BaseApplication; importtxcap.com.library.core.rx.RxManager; importtxcap.com.library.utils.file.ResUtil; /** *@authorgaojigong *@versionV1.0 *@Description:处理验证码的工具 *@date17/3/22 */ publicabstractclassCheckCodeUtil{ privateRxManagermRxManager; privateButtonbtnGetCheckCode; privateEditTextedtAccount; //验证码获取中,按钮始终是倒计时状态,不受输入框事件的影响 protectedbooleancountDowning=false; //用于取消倒计时 privateSubscriptionintervalSub; publicCheckCodeUtil(RxManagermRxManager,ButtonbtnGetCheckCode,EditTextedtAccount){ this.mRxManager=mRxManager; this.btnGetCheckCode=btnGetCheckCode; this.edtAccount=edtAccount; init(); } privatevoidinit(){ RxView.enabled(btnGetCheckCode).call(false); ObservableobservableAccount=RxTextView.textChanges(edtAccount); //账号输入不合理不能点击获取验证码 mRxManager.add(observableAccount .subscribeOn(AndroidSchedulers.mainThread()) .subscribe(newAction1 (){ @Override publicvoidcall(CharSequencecharSequence){ 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(newAction1 (){ @Override publicvoidcall(VoidaVoid){ getCheckCode(); } }) ); } /** *获取验证码 */ privatevoidgetCheckCode(){ intervalSub=Observable.interval(0,1,TimeUnit.SECONDS,AndroidSchedulers.mainThread()) .take(Constant.CHECK_CODE_SECOND) .doOnSubscribe(newAction0(){ @Override publicvoidcall(){ getCodeNumber(); //按钮变为不可点击 RxView.enabled(btnGetCheckCode).call(false); countDowning=true; } }) .subscribe(newSubscriber (){ @Override publicvoidonCompleted(){ 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 publicvoidonError(Throwablee){ 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 publicvoidonNext(LongaLong){ RxTextView.text(btnGetCheckCode).call((Constant.CHECK_CODE_SECOND-aLong)+"s"); } }); mRxManager.add(intervalSub); } /** *获取验证码 */ publicabstractvoidgetCodeNumber(); /** *验证规则 *@paramstr *@return */ publicabstractbooleanetCheck(Stringstr); publicvoidgetCodeError(){ 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) EditTextedtAccount; @BindView(R.id.btn_get_check_code) ButtonbtnGetCheckCode; privateCheckCodeUtilcheckCodeUtil; checkCodeUtil=newCheckCodeUtil(mRxManager,btnGetCheckCode,edtAccount){ @Override publicvoidgetCodeNumber(){ mPresenter.getCode(edtAccount.getText().toString()); } @Override publicbooleanetCheck(Stringstr){ returnStrCheckUtil.checkedAccount(str); } }; @Override publicvoidgetCodeFailed(Stringmessage){ showToastLong("获取验证码失败:"+message); checkCodeUtil.getCodeError(); }
特点
…减少代码冗余
…方便需求维护
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。