責(zé)任鏈模式及OkHttp中的實現(xiàn)
責(zé)任鏈模式
責(zé)任鏈模式是對一個事件的處理方法,所有能對事件進行處理的對象按順序形成一個鏈表.事件經(jīng)過鏈表中每個處理對象輪流處理.如果有返回值.則返回也是順著這條鏈表反向返回.這個鏈表是先進后出模式.
- 在現(xiàn)實中的責(zé)任鏈模型之一就是網(wǎng)絡(luò)連接.對與程序猿而言,七層或五層的網(wǎng)絡(luò)連接模型是肯定知道的.
當(dāng)一個網(wǎng)絡(luò)請求發(fā)出時,需要經(jīng)過應(yīng)用層->傳輸層->網(wǎng)絡(luò)層->連接層->物理層
收到響應(yīng)后正好反過來,物理層->連接層->網(wǎng)絡(luò)層->傳輸層->應(yīng)用層
在請求經(jīng)過各層時,由每層輪流處理.每層都可以對請求或響應(yīng)進行處理.并可以中斷鏈接,以自身為終點返回響應(yīng)
- 另一個現(xiàn)實模型就是Web服務(wù)器的請求緩存
一個請示從客戶端發(fā)送到Web服務(wù)器需要經(jīng)過客戶端->中間服務(wù)器->反向代理->Web端緩存(如Redis)->Web數(shù)據(jù)庫
除了Web數(shù)據(jù)庫是請求的點外,中間所有層都可以緩存數(shù)據(jù).如果有緩存時會終止請求,以自身為終點返回數(shù)據(jù).
如果途經(jīng)的層沒有緩存,則會在收到下一級的返回的數(shù)據(jù)時對數(shù)據(jù)進行緩存.然后返回上一層.
在設(shè)計模式中,負責(zé)鏈模式就是對這種順序處理事件的行為的抽象,通過接口來定義處理事件的方法.順序分發(fā)/處理事件.
- 每個責(zé)任人實現(xiàn)相同的接口,處理一個事件對象
- 讓事件對象責(zé)任人之間順序傳遞
- 事件的處理結(jié)果的返回是逆序的
- 責(zé)任鏈中的每個責(zé)任人都可以有權(quán)不繼續(xù)傳遞事件,以自身為終點處理事件返回結(jié)果
OkHttp中的責(zé)任鏈模式
在Okhttp中,Intercepter就是典型的責(zé)任鏈械的實現(xiàn).它可以設(shè)置任意數(shù)量的Intercepter來對網(wǎng)絡(luò)請求及其響應(yīng)做任何中間處理.比如設(shè)置緩存,Https的證書驗證,統(tǒng)一對請求加密/防串改,打印自定義Log,過濾請求等.
interface Intercepter{
Response response chain(Chain chain);
}
這個接口很簡單,拿到Chain對象.最后返回個Response,那這個對象是什么鬼??
它有兩個重要的方法
public Request getQuest()及public Response process(Request quest)
拿到請求及設(shè)置請求拿到響應(yīng).
一般的實現(xiàn)是先拿到請求.然后對請求做一番蹂躪,然后process一下,拿到Response,折騰一下.然后return掉
Response response chain(Chain chain){
Requset quest = chian.getRequset()
ooxx(request);
Response response = chian.process(quest);
xxoo(response);
return response;
}
或許它不知道,Resquse其實是被上家ooxx過的,Respnse也是被下家xxoo過的.
具體的實現(xiàn)可以去看一下源碼,我這里就寫一下自己理解的超簡單的實現(xiàn)
public class Okhttp {
private List<Intercepter> mIntercepters=new LinkedList<>();
private Request mRequest;
private int mIndex;
private Callback mCallback;
private Chain mChain=new Chain();
private Intercepter mNetIntercepter =new Intercepter() {
@Override
public Response chain (Chain chain) {
//這里是真實的發(fā)送網(wǎng)絡(luò)請求
return 網(wǎng)絡(luò)請示的響應(yīng);
}
};
/**
* 添加攔截器,后加的放最前面
* @param intercper 攔截器
*/
public void addIntercepter(Intercepter intercper){
mIntercepters.add(0, intercper);
}
/**
* OkHttp請求的入口
* @param request 請示
* @param callback 回調(diào)
*/
public void execute(Request request ,Callback callback){
mCallback=callback;
mIndex=0;
mRequest=request;
new Thread(new Runnable() {
@Override
public void run () {
Response response=mChain.process(mRequest);
mCallback.onResponse(response);
}
}).start();
}
/**
* 定義的一個類用與遞歸的方式完成責(zé)任鏈發(fā)送請求獲取響應(yīng)
*/
private class Chain {
public Request getRequest(){
return mRequest;
}
/**
* 順序獲取攔截器,傳遞chain對象給攔截器,獲取響應(yīng)
* @return 請求的響應(yīng)
*/
private Response getResponse () {
Intercepter intercepter = mIntercepters.get(mIndex);
mIndex++;
return intercepter.chain(this);
}
/**
* 如果責(zé)任鏈沒走完,則順序從責(zé)任鏈中獲取攔截器,處理請求
* 否則由真正的負責(zé)網(wǎng)絡(luò)請求的攔截器處理請求
* @param request 請求
* @return 響應(yīng)
*/
Response process(Request request){
mRequest=request;
if (mIndex>=mIntercepters.size()){
return Okhttp.this.mNetIntercepter.chain(this);
}else{
return getResponse();
}
}
}
}
不得不說程序猿寫文章真是容易騙字數(shù).我已經(jīng)極力在簡化了.代碼還是差不多上百行.
應(yīng)該寫得夠簡單吧.重點也就幾個
- 內(nèi)部有個處理真實網(wǎng)絡(luò)請求的
Intercepter,做為最后的接盤俠. - 返回響應(yīng)的是
intercepter.chain(this),如果這個攔截器調(diào)用了chain的process()方法就形成遞歸,否則就是終斷了請求的傳遞 - 整個責(zé)任鏈的傳遞都是同步的.整體在子線程運行,最后通過回調(diào)返回響應(yīng).
還有一個很經(jīng)典的實現(xiàn)就是Android的事件分發(fā)機制.這里我就不貼代碼騙字數(shù)了.網(wǎng)上隨便一找一堆.
責(zé)任鏈模式的用途
當(dāng)業(yè)務(wù)邏輯需要形成一個事件處理流時,就可以考慮使用責(zé)任鏈模式.通過接口來規(guī)范中間環(huán)節(jié)的行為,專注與事件流的傳遞.可以隨意擴展及調(diào)整中間環(huán)節(jié).
我在實際業(yè)務(wù)中的有一個場景中使用了責(zé)任鏈模式.(當(dāng)時使用的時候其實并不清楚)
- 在一個列表中可以彈出一個篩選菜單,菜單項是不定的.某些項選擇后可以增加更多的選項條目
- 選項條目類型不同.有單選,多選,輸入等.
- 點擊完成時才把所有篩選條目形成對應(yīng)的網(wǎng)絡(luò)請求參數(shù)
實際處理起來很簡易.定義了兩個類
interface ParamsSetAble{
void setParams(NetParams params);
}
public class NetParams{}
每個條目實現(xiàn)ParamsSetAble接口用與設(shè)置參數(shù).
NetParams類用與收集參數(shù),最后轉(zhuǎn)換成網(wǎng)絡(luò)請求所用的格式
當(dāng)點擊完成時,遍歷所有的條目,傳遞NetParams對象.最后把這個對象傳遞給網(wǎng)絡(luò)請求的類.
在傳遞時進行可以進行參數(shù)檢查,錯誤時可以中斷傳遞,提示錯誤.我這里是通過手動拋異常來中斷的.在外部統(tǒng)一catch處理.如果用Rxjava可以不用catch,在onError里統(tǒng)一管理.如Observer.error(new 自定義異常(中斷提示信息))
