RxAndroid + Volley 結(jié)合使用的簡(jiǎn)單例子

  • 本文簡(jiǎn)單的講下如何將Volley的回調(diào)模式跟RxAndroid結(jié)合起來(lái)使用。使用RxAndroid的主要原因就是其能實(shí)現(xiàn)鏈?zhǔn)骄幋a,代碼比較好看莹桅;使用Volley的主要原因是大廠出品質(zhì)量有保障,項(xiàng)目涉及的網(wǎng)絡(luò)請(qǐng)求也比較簡(jiǎn)單。

結(jié)合使用步驟:

1.引入需要用到的資源:

compile 'com.android.volley:volley:1.0.0'
compile 'io.reactivex:rxandroid:1.2.1'

2.首先自定義自己的請(qǐng)求類

自定義請(qǐng)求類HttpJsonRequest珊擂,該類繼承于com.android.volley.Request,volley
有幾個(gè)自己定義好的請(qǐng)求類费变,在com.android.volley.toolbox下摧扇,根據(jù)需要使用。我這里為了跟RxAndrod結(jié)合挚歧,也為了傳遞傳統(tǒng)的鍵值對(duì)形式參數(shù)扛稽,采用自定義的。
HttpJsonRequest.java如下:

import java.util.List;
import org.json.JSONObject;
import android.text.TextUtils;
import com.android.volley.DefaultRetryPolicy;
import com.android.volley.NetworkResponse;
import com.android.volley.ParseError;
import com.android.volley.Request;
import com.android.volley.Response;
import com.android.volley.VolleyError;
import com.android.volley.toolbox.HttpHeaderParser;
import rx.Observer;

public class HttpJsonRequest extends Request<JSONObject> {

    private final String PROTOCOL_CHARSET = "utf-8";

    /**
     * 鍵值對(duì)形式參數(shù)
     */
    private List<ParamItem> mParams;

    /**
     * 觀察者滑负,在請(qǐng)求結(jié)束后在张,向其傳遞成功、失敗的事件
     */
    private Observer<? super JSONObject> mObserver;

    public HttpJsonRequest(int method, String url, List<ParamItem> params, Observer<? super JSONObject> observer) {
        super(method, url, null);
        mObserver = observer;
        mParams = params;

        // 設(shè)置請(qǐng)求超時(shí)時(shí)間以及重試次數(shù)
        setRetryPolicy(new DefaultRetryPolicy(60000, 0, 1.0f));
    }

    /**
     * 該方法必須重寫0健G撇簟!
     * 請(qǐng)求完成時(shí)觸發(fā)觀察者中事件凡傅,記得加onCompleted();
     */
    @Override
    protected void deliverResponse(JSONObject response) {
        mObserver.onNext(response);
        mObserver.onCompleted();
    }

    /**
     * 該方法必須重寫1俦贰!夏跷!
     * 發(fā)生錯(cuò)誤時(shí)哼转,觸發(fā)事件
     */
    @Override
    public void deliverError(VolleyError error) {
        mObserver.onError(error);
    }

    @Override
    protected Response<JSONObject> parseNetworkResponse(NetworkResponse response) {
        try {
            String jsonString = new String(response.data, HttpHeaderParser.parseCharset(response.headers));
            if (TextUtils.isEmpty(jsonString)) {
                return Response.success(new JSONObject(), HttpHeaderParser.parseCacheHeaders(response));
            } else {
                return Response.success(new JSONObject(jsonString), HttpHeaderParser.parseCacheHeaders(response));
            }
        } catch (Exception e) {
            return Response.error(new ParseError(e));
        }
    }

    /**
     * 由于參數(shù)是按照傳統(tǒng)的鍵值對(duì)形式傳遞至后臺(tái),所以這塊需要重寫;
     * 如果能保證參數(shù)名稱不重復(fù)槽华,其實(shí)只要重寫Request中g(shù)etParams()方法即可壹蔓,我這里直接重寫的getBody(),因?yàn)樘峤粓D片時(shí)是同一個(gè)參數(shù)名稱多次提交
     * Volley.toolbox中提供了幾種強(qiáng)格式的request,比如com.android.volley.toolbox.JsonObjectRequest,要求參數(shù)是json格式;
     * 實(shí)際開發(fā)中猫态,前后臺(tái)交互模式很多佣蓉,主要就是修改getBody()來(lái)達(dá)到自定義目的披摄。
     */
    @Override
    public byte[] getBody() {
        String paramStr;
        if (mParams == null) {
            paramStr = "";
        } else {
            StringBuilder params = new StringBuilder();
            for (ParamItem p : mParams) {
                params.append("&").append(p.getKey()).append("=").append(p.getValue());
            }

            paramStr = params.toString();
            if (paramStr.length() > 0) {
                // 去除第一個(gè)&
                paramStr = paramStr.substring(1);
            }
        }

        try {
            return paramStr.getBytes(PROTOCOL_CHARSET);
        } catch (Exception uee) {
            throw new RuntimeException("Encoding not supported: " + PROTOCOL_CHARSET, uee);
        }
    }
}

這里需要注意的點(diǎn),參見(jiàn)代碼里的注釋勇凭。其核心就是deliverResponsedeliverError兩個(gè)方法的重寫疚膊,其原來(lái)的方式,可以看volley.toolbox下的幾個(gè)請(qǐng)求類源碼

3.初始化請(qǐng)求隊(duì)列以及加入請(qǐng)求虾标、取消請(qǐng)求方法

private RequestQueue mRequestQueue;

/**
 * 獲取請(qǐng)求隊(duì)列
 */
public RequestQueue getRequestQueue() {
    if (mRequestQueue == null) {
        mRequestQueue = Volley.newRequestQueue(this);
    }
    return mRequestQueue;
}

/**
 * 將一個(gè)請(qǐng)求加入隊(duì)列寓盗,,并設(shè)置其TAG;
 * 其中tag通常就是當(dāng)前請(qǐng)求所處的頁(yè)面璧函,頁(yè)面銷毀時(shí)調(diào)用cancelALl終止被頁(yè)面請(qǐng)求
 */
public <T> void addToRequestQueue(Request<T> req, Object tag) {
    addToRequestQueue(req, tag.getClass().getSimpleName());
}

private <T> void addToRequestQueue(Request<T> req, String tag) {
    req.setTag(tag);
    BuglyLog.d(TAG, "添加請(qǐng)求至隊(duì)列:" + req.getUrl());

    getRequestQueue().add(req);
}

/**
 * 取消指定TAG的請(qǐng)求傀蚌,通常在onDestory()中調(diào)用
 */
public void cancelPendingRequests(Object tag) {
    cancelPendingRequests(tag.getClass().getSimpleName());
}

private void cancelPendingRequests(String tag) {
    BuglyLog.e(TAG, "從隊(duì)列里去除指定TAG的請(qǐng)求:" + tag);
    if (mRequestQueue != null) {
        mRequestQueue.cancelAll(tag);
    }
}

這塊沒(méi)什么好說(shuō)的,如果你要集成okhttp,就是在 Volley.newRequestQueue(this)這里做文章

4.RxAndroid與Volley結(jié)合使用

主要代碼如下:

/**
 * 執(zhí)行注冊(cè)
 */
private void doRegister(String email, String password) {
    int versionCode = com.afap.utils.Utils.getAppVersionCode(getContext());
    String sdk = Build.VERSION.RELEASE;


    Observable.create(new Observable.OnSubscribe<JSONObject>() {
        @Override
        public void call(final Subscriber<? super JSONObject> subscriber) {
            String url = "http://www.weather.com.cn/data/cityinfo/101010100.html";
            List<ParamItem> params = new ArrayList<>();
            HttpJsonRequest request = new HttpJsonRequest(Request.Method.GET, url, null, subscriber);
            MyApplication.getInstance().addToRequestQueue(request, RegisterFormFragment.this);
        }
    })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Observer<JSONObject>() {
                @Override
                public void onCompleted() {
                    BuglyLog.i(TAG, "Observer.onCompleted");
                }

                @Override
                public void onError(Throwable e) {
                    e.printStackTrace();
                    BuglyLog.e(TAG, "Observer.onError");
                }

                @Override
                public void onNext(JSONObject json) {
                    BuglyLog.i(TAG, "Observer.onNext");
                    BuglyLog.i(TAG, json.toString());
                }
            });
}

@Override
public void onDestroy() {
    MyApplication.getInstance().cancelPendingRequests(this);

    super.onDestroy();
}

以上蘸吓,就已經(jīng)將Volley和RxAndroid串起來(lái)了善炫。最最關(guān)鍵的一步就是deliverResponsedeliverError.

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末,一起剝皮案震驚了整個(gè)濱河市库继,隨后出現(xiàn)的幾起案子销部,更是在濱河造成了極大的恐慌,老刑警劉巖制跟,帶你破解...
    沈念sama閱讀 222,378評(píng)論 6 516
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件,死亡現(xiàn)場(chǎng)離奇詭異酱虎,居然都是意外死亡雨膨,警方通過(guò)查閱死者的電腦和手機(jī),發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,970評(píng)論 3 399
  • 文/潘曉璐 我一進(jìn)店門读串,熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)聊记,“玉大人,你說(shuō)我怎么就攤上這事恢暖∨偶啵” “怎么了?”我有些...
    開封第一講書人閱讀 168,983評(píng)論 0 362
  • 文/不壞的土叔 我叫張陵杰捂,是天一觀的道長(zhǎng)舆床。 經(jīng)常有香客問(wèn)我,道長(zhǎng)嫁佳,這世上最難降的妖魔是什么挨队? 我笑而不...
    開封第一講書人閱讀 59,938評(píng)論 1 299
  • 正文 為了忘掉前任,我火速辦了婚禮蒿往,結(jié)果婚禮上盛垦,老公的妹妹穿的比我還像新娘。我一直安慰自己瓤漏,他們只是感情好腾夯,可當(dāng)我...
    茶點(diǎn)故事閱讀 68,955評(píng)論 6 398
  • 文/花漫 我一把揭開白布颊埃。 她就那樣靜靜地躺著,像睡著了一般蝶俱。 火紅的嫁衣襯著肌膚如雪班利。 梳的紋絲不亂的頭發(fā)上,一...
    開封第一講書人閱讀 52,549評(píng)論 1 312
  • 那天跷乐,我揣著相機(jī)與錄音肥败,去河邊找鬼。 笑死愕提,一個(gè)胖子當(dāng)著我的面吹牛馒稍,可吹牛的內(nèi)容都是我干的。 我是一名探鬼主播浅侨,決...
    沈念sama閱讀 41,063評(píng)論 3 422
  • 文/蒼蘭香墨 我猛地睜開眼纽谒,長(zhǎng)吁一口氣:“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼!你這毒婦竟也來(lái)了如输?” 一聲冷哼從身側(cè)響起鼓黔,我...
    開封第一講書人閱讀 39,991評(píng)論 0 277
  • 序言:老撾萬(wàn)榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎不见,沒(méi)想到半個(gè)月后澳化,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 46,522評(píng)論 1 319
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡稳吮,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 38,604評(píng)論 3 342
  • 正文 我和宋清朗相戀三年缎谷,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片灶似。...
    茶點(diǎn)故事閱讀 40,742評(píng)論 1 353
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡列林,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出酪惭,到底是詐尸還是另有隱情希痴,我是刑警寧澤,帶...
    沈念sama閱讀 36,413評(píng)論 5 351
  • 正文 年R本政府宣布春感,位于F島的核電站砌创,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏鲫懒。R本人自食惡果不足惜纺铭,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 42,094評(píng)論 3 335
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望刀疙。 院中可真熱鬧舶赔,春花似錦、人聲如沸谦秧。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,572評(píng)論 0 25
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)。三九已至锥累,卻和暖如春缘挑,著一層夾襖步出監(jiān)牢的瞬間,已是汗流浹背桶略。 一陣腳步聲響...
    開封第一講書人閱讀 33,671評(píng)論 1 274
  • 我被黑心中介騙來(lái)泰國(guó)打工语淘, 沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留,地道東北人际歼。 一個(gè)月前我還...
    沈念sama閱讀 49,159評(píng)論 3 378
  • 正文 我出身青樓惶翻,卻偏偏與公主長(zhǎng)得像,于是被迫代替她去往敵國(guó)和親鹅心。 傳聞我的和親對(duì)象是個(gè)殘疾皇子吕粗,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 45,747評(píng)論 2 361

推薦閱讀更多精彩內(nèi)容

  • 注:本文轉(zhuǎn)自http://codekk.com/open-source-project-analysis/deta...
    Ten_Minutes閱讀 1,302評(píng)論 1 16
  • Volley簡(jiǎn)介 Volley 是 Google I/O 2013上發(fā)布的網(wǎng)絡(luò)通信庫(kù),使網(wǎng)絡(luò)通信更快旭愧、更簡(jiǎn)單颅筋、更健...
    shenhuniurou閱讀 932評(píng)論 0 3
  • 自己總結(jié)的Android開源項(xiàng)目及庫(kù)。 github排名https://github.com/trending,g...
    passiontim閱讀 2,543評(píng)論 1 26
  • 各種幫助類匯總:https://github.com/Blankj/AndroidUtilCode 常用的 ios...
    懦弱的me閱讀 1,245評(píng)論 0 51
  • 周一的時(shí)候開會(huì),說(shuō)起這周五是果糖兩周年桃熄,是不是要做點(diǎn)什么活動(dòng)先口?大家出出主意吧。做傳播造熱點(diǎn)我不在行蜻拨,但我會(huì)蹭熱點(diǎn)啊...
    braveyanan閱讀 429評(píng)論 0 1