本文為大家分享了使用Rxjava做一個(gè)發(fā)送驗(yàn)證碼倒計(jì)時(shí)，供大家參考，具體內(nèi)容如下
首先在gradle添加依賴：
compile 'io.reactivex:rxandroid:1.2.1'
compile 'io.reactivex:rxjava:1.1.6'
xml布局：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
|
<?xml version="1.0" encoding="utf-8"?><LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" 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"> <EditText android:id="@+id/editText" android:layout_width="match_parent" android:layout_height="wrap_content" android:hint="請輸入手機(jī)號碼" /> <Button android:id="@+id/btn" android:layout_width="match_parent" android:layout_height="wrap_content" android:background="#f97e7e" android:text="獲取驗(yàn)證碼" /></LinearLayout> |
java代碼：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
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)//設(shè)置0延遲，每隔一秒發(fā)送一條數(shù)據(jù) .take(count+1) //設(shè)置循環(huán)11次 .map(new Func1<Long, Long>() { @Override public Long call(Long aLong) { return count-aLong; // } }) .doOnSubscribe(new Action0() { @Override public void call() { mSend.setEnabled(false);//在發(fā)送數(shù)據(jù)的時(shí)候設(shè)置為不能點(diǎn)擊 mSend.setBackgroundColor(Color.GRAY);//背景色設(shè)為灰色 } }) .observeOn(AndroidSchedulers.mainThread())//操作UI主要在UI線程 .subscribe(new Observer<Long>() { @Override public void onCompleted() { Log.d(TAG, "onCompleted: "); mSend.setText("獲取驗(yàn)證碼");//數(shù)據(jù)發(fā)送完后設(shè)置為原來的文字 mSend.setTextColor(Color.BLACK); mSend.setBackgroundColor(Color.parseColor("#f97e7e"));//數(shù)據(jù)發(fā)送完后設(shè)置為原來背景色 } @Override public void onError(Throwable e) { e.printStackTrace(); } @Override public void onNext(Long aLong) { //接受到一條就是會操作一次UI Log.d(TAG, "onNext: "+aLong); mSend.setText("剩余時(shí)間"+aLong+"秒"); mSend.setEnabled(true); mSend.setTextColor(Color.WHITE); } }); } }); } } |
代碼相對比較簡單，做了詳細(xì)的注釋，要使用Rxjava需要明白什么是觀察者模式。剩下的就去理解和怎么樣組合使用Rxjava的各種操作符。
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持服務(wù)器之家。
原文鏈接：https://blog.csdn.net/ifreeboard/article/details/53965580
