本文內(nèi)容思維導(dǎo)圖如下:
一、責(zé)任鏈模式介紹
責(zé)任鏈模式定義:為請(qǐng)求創(chuàng)建一個(gè)處理此請(qǐng)求對(duì)象的鏈。
適用場(chǎng)景(核心):只要把你的請(qǐng)求拋給第一個(gè)處理者,不用關(guān)心誰(shuí)處理的,并且最終會(huì)返回你一個(gè)結(jié)果券敌。
優(yōu)點(diǎn):請(qǐng)求者和處理者解耦从藤,請(qǐng)求者不用知道誰(shuí)處理的窖杀,處理者可以不用知道請(qǐng)求的全貌。
缺點(diǎn):每個(gè)請(qǐng)求從鏈頭遍歷到鏈尾隅忿,影響性能。代碼調(diào)試時(shí)候不方便邦尊。
類(lèi)型:行為型背桐。
類(lèi)圖:
源碼中的典型應(yīng)用:
- Netty 中的 Pipeline和ChannelHandler通過(guò)責(zé)任鏈設(shè)計(jì)模式來(lái)組織代碼邏輯。
- Spring Security 使用責(zé)任鏈模式蝉揍,可以動(dòng)態(tài)地添加或刪除責(zé)任(處理 request 請(qǐng)求)链峭。ref:SPRING與設(shè)計(jì)模式---責(zé)任鏈模式
- Spring AOP 通過(guò)責(zé)任鏈模式來(lái)管理 Advisor。
- Dubbo Filter 過(guò)濾器鏈也是用了責(zé)任鏈模式(鏈表)又沾,可以對(duì)方法調(diào)用做一些過(guò)濾處理弊仪,譬如超時(shí)(TimeoutFilter)熙卡,異常(ExceptionFilter),Token(TokenFilter)等励饵。
- Mybatis 中的 Plugin 機(jī)制使用了責(zé)任鏈模式驳癌,配置各種官方或者自定義的 Plugin,與 Filter 類(lèi)似曲横,可以在執(zhí)行 Sql 語(yǔ)句的時(shí)候做一些操作喂柒。
- Tomcat 調(diào)用 ApplicationFilterFactory過(guò)濾器鏈。
二禾嫉、請(qǐng)假示例
員工在OA系統(tǒng)中提交請(qǐng)假申請(qǐng)灾杰,首先項(xiàng)目經(jīng)理處理,他能審批3天以?xún)?nèi)的假期熙参,如果大于3天艳吠,則由項(xiàng)目經(jīng)理則轉(zhuǎn)交給總經(jīng)理處理。接下來(lái)我們用責(zé)任鏈模式實(shí)現(xiàn)這個(gè)過(guò)程孽椰。
1昭娩、封裝請(qǐng)假信息實(shí)體類(lèi)
public class LeaveRequest {
private String name; // 請(qǐng)假人姓名
private int numOfDays; // 請(qǐng)假天數(shù)
private int workingAge; //員工工齡(在公司大于2年則總經(jīng)理會(huì)審批)
//省略get..set..
}
2、抽象處理者類(lèi) Handler黍匾,維護(hù)一個(gè)nextHandler屬性栏渺,該屬性為當(dāng)前處理者的下一個(gè)處理者的引用;聲明了抽象方法process锐涯,其實(shí)在這里也用了方法模板模式:
public abstract class ApproveHandler {
protected ApproveHandler nextHandler;//下一個(gè)處理者(與類(lèi)一致,這段代碼很重要)
public void setNextHandler(ApproveHandler approveHandler){
this.nextHandler=approveHandler;
}
public abstract void process(LeaveRequest leaveRequest); // 處理請(qǐng)假(這里用了模板方法模式)
}
3磕诊、項(xiàng)目經(jīng)理處理者,能處理小于3天的假期纹腌,而請(qǐng)假信息里沒(méi)有名字時(shí)凡傅,審批不通過(guò):
public class PMHandler extends ApproveHandler{
@Override
public void process(LeaveRequest leaveRequest) {
//未填寫(xiě)姓名的請(qǐng)假單不通過(guò)
if(null != leaveRequest.getName()){
if(leaveRequest.getNumOfDays() <= 3){
System.out.println(leaveRequest.getName()+",你通過(guò)項(xiàng)目經(jīng)理審批!");
}else {
System.out.println("項(xiàng)目經(jīng)理轉(zhuǎn)交總經(jīng)理");
if(null != nextHandler){
nextHandler.process(leaveRequest);
}
}
}else {
System.out.println("請(qǐng)假單未填寫(xiě)完整,未通過(guò)項(xiàng)目經(jīng)理審批!");
return;
}
}
}
4砌溺、總經(jīng)理處理者艰赞,能處理大于3天的假期浴栽,且工齡超過(guò)2年才會(huì)審批通過(guò):
public class GMHandler extends ApproveHandler{
@Override
public void process(LeaveRequest leaveRequest) {
//員工在公司工齡超過(guò)2年,則審批通過(guò)
if(leaveRequest.getWorkingAge() >=2 && leaveRequest.getNumOfDays() > 3){
System.out.println(leaveRequest.getName()+",你通過(guò)總經(jīng)理審批!");
if(null != nextHandler){
nextHandler.process(leaveRequest);
}
}else {
System.out.println("在公司年限不夠,長(zhǎng)假未通過(guò)總經(jīng)理審批!");
return;
}
}
}
實(shí)例代碼完成,我們測(cè)試一下:
public class Test {
public static void main(String[] args) {
PMHandler pm = new PMHandler();
GMHandler gm = new GMHandler();
LeaveRequest leaveRequest = new LeaveRequest();
leaveRequest.setName("張三");
leaveRequest.setNumOfDays(4);//請(qǐng)假4天
leaveRequest.setWorkingAge(3);//工齡3年
pm.setNextHandler(gm);//設(shè)置傳遞順序
pm.process(leaveRequest);
}
}
運(yùn)行結(jié)果:
項(xiàng)目經(jīng)理轉(zhuǎn)交總經(jīng)理
張三,你通過(guò)總經(jīng)理審批!
三涎劈、源碼中的責(zé)任鏈模式
Filter接口有非常多的實(shí)現(xiàn)類(lèi)广凸,這里挑選doFilter方法中的FilterChain參數(shù)來(lái)看,Tomcat和SpringSecurity中都用到責(zé)任鏈模式:
進(jìn)入第一個(gè)责语,過(guò)濾器鏈 ApplicationFilterChain 的關(guān)鍵代碼如下炮障,過(guò)濾器鏈實(shí)際是一個(gè) ApplicationFilterConfig 數(shù)組:
final class ApplicationFilterChain implements FilterChain, CometFilterChain {
private ApplicationFilterConfig[] filters = new ApplicationFilterConfig[0]; // 過(guò)濾器鏈
private Servlet servlet = null; // 目標(biāo)
// ...
@Override
public void doFilter(ServletRequest request, ServletResponse response) throws IOException, ServletException {
if( Globals.IS_SECURITY_ENABLED ) {
// ...
} else {
internalDoFilter(request,response); // 調(diào)用 internalDoFilter 方法
}
}
private void internalDoFilter(ServletRequest request, ServletResponse response) throws IOException, ServletException {
// Call the next filter if there is one
if (pos < n) {
// 從過(guò)濾器數(shù)組中取出當(dāng)前過(guò)濾器配置,然后下標(biāo)自增1
ApplicationFilterConfig filterConfig = filters[pos++];
Filter filter = null;
try {
filter = filterConfig.getFilter(); // 從過(guò)濾器配置中取出該 過(guò)濾器對(duì)象
if( Globals.IS_SECURITY_ENABLED ) {
final ServletRequest req = request;
final ServletResponse res = response;
Principal principal = ((HttpServletRequest) req).getUserPrincipal();
Object[] args = new Object[]{req, res, this};
SecurityUtil.doAsPrivilege("doFilter", filter, classType, args, principal);
} else {
// 調(diào)用過(guò)濾器的 doFilter坤候,完成一個(gè)過(guò)濾器的過(guò)濾功能
filter.doFilter(request, response, this);
}
return; // 這里很重要胁赢,不會(huì)重復(fù)執(zhí)行后面的 servlet.service(request, response)
}
// 執(zhí)行完過(guò)濾器鏈的所有過(guò)濾器之后,調(diào)用 Servlet 的 service 完成請(qǐng)求的處理
if ((request instanceof HttpServletRequest) && (response instanceof HttpServletResponse)) {
if( Globals.IS_SECURITY_ENABLED ) {
} else {
servlet.service(request, response);
}
} else {
servlet.service(request, response);
}
}
// 省略...
}
這里可以看出ApplicationFilterChain類(lèi)扮演了抽象處理者角色白筹,doFilter就類(lèi)似于剛才請(qǐng)假流程里的process方法智末。
當(dāng)下標(biāo)小于過(guò)濾器數(shù)組長(zhǎng)度 n 時(shí)谅摄,也就是過(guò)濾器鏈未執(zhí)行完,所以從數(shù)組中取出并調(diào)用當(dāng)前過(guò)濾器的 doFilter方法 系馆,如果下標(biāo)一直小于n送漠,則循環(huán)調(diào)用doFilter方法通過(guò)嵌套遞歸的方式來(lái)串成一條鏈。
當(dāng)最后的過(guò)濾器執(zhí)行完畢由蘑,也就是走到最后一個(gè)return闽寡;時(shí),結(jié)束遞歸調(diào)用doFilter尼酿。if (pos < n) 為false爷狈,調(diào)用后面的servlet.service(request, response) 方法。return裳擎;這一點(diǎn)在請(qǐng)假流程里也有體現(xiàn)涎永。
參考: