首先感謝王曉老師的[接口優(yōu)化的常見方案實戰(zhàn)總結(jié)]一文總結(jié)，恰巧最近在對穩(wěn)健理財BFF層聚合查詢服務(wù)優(yōu)化治理，針對文章內(nèi)的串行改并行章節(jié)進行展開，分享下實踐經(jīng)驗，主要涉及原同步改異步的過程、全異步化后衍生的問題以及治理方面的思考與改進。 希望通過分享這些經(jīng)驗，能夠?qū)Υ蠹业墓ぷ饔兴鶈l(fā)和幫助。如果有任何問題或建議，請隨時提出。 感謝大家的關(guān)注和支持！

一、問題背景

將不同理財產(chǎn)品（如基金、券商、保險、銀行理財?shù)龋┽槍Σ煌斗徘廊巳哼M行個性化商品推薦，每個渠道或人群看到的商品或特性數(shù)據(jù)又各不相同，為方便渠道快速對接，由BFF層統(tǒng)一對所有數(shù)據(jù)進行聚合下發(fā)，因此BFF層聚集依賴了大量底層原子服務(wù)，所以主要問題是在依賴大量上游接口的場景下保障TP99、以及可用率。

案例：

以其中比較典型的商品推薦接口為例，需要依賴本地商品池緩存、算法推薦服務(wù)、商品基礎(chǔ)信息服務(wù)、持倉查詢服務(wù)、人群標簽服務(wù)、券配置服務(wù)，可領(lǐng)用券服務(wù)、其他數(shù)據(jù)服務(wù)ServN……等等，其中大部分上游原子接口對單次批量查詢支持有限，所以極端情況，單個推品接口單次推薦1-n個推品，每個商品如果要綁定10個動態(tài)屬性，至少需要發(fā)起(1~n)*10次io調(diào)用。

改造前的流程和問題：

流程：

問題：

?一是邏輯流程強耦合，很多上下游服務(wù)強同步依賴；

?二是鏈路較長，其中某個上游服務(wù)不穩(wěn)定時很容易造成整體鏈路失敗。

改造后的流程和實現(xiàn)的目標：

流程：

目標：

?改造目標也很明確，就是對現(xiàn)有邏輯改造，盡可能增加弱依賴比例，一是方便異步提前加載，二是弱依賴代表可摘除，為降級操作奠定基礎(chǔ)，減少因某個鏈路抖動影響整體鏈路失敗；

初步改造后的新問題【【重點解決】】：

?邏輯上解耦比較簡單，無非就是前置參數(shù)或冗余加載，本次不展開探討；

?技術(shù)上改造前期異步邏輯主要是采用@Async("tpXXX")標注，這也是最快捷實現(xiàn)的方式，但也存在以下幾個問題，主要是涉及治理方面：

1. 隨著項目和人員不斷迭代，造成@Async注解滿天飛；

2. 不同人員在不熟悉其他模塊的情況下，無法界定不同線程池的是否可公用，大多都會采用聲明新的線程池，造成線程池資源泛濫；

3. 部分調(diào)用場景不合理造成@Async嵌套過多或注解失效問題；

4. 降級機制重復代碼太多，需要頻繁手動聲明各種降級開關(guān)；

5. 缺少統(tǒng)一的請求級別的緩存機制，雖然jsf已經(jīng)提供了一定程度的支持；

6. 線程池上下文傳遞問題；

7. 缺少線程池狀態(tài)的統(tǒng)一監(jiān)控報警，無法觀測實際運行過程中的每個線程池狀態(tài)，可能每次都是拍腦袋覺設(shè)置線程池參數(shù)。

二、整體改造路徑

切入點：

鑒于大部分項目都會封裝單獨的io調(diào)用層，比如 com.xx.package.xxx.client，所以以此為切入點進行重點改造治理。

最終目標：

實現(xiàn)、應(yīng)用簡單，對老代碼改造友好，盡可能降低改造成本；

1. 抽象io調(diào)用模板，統(tǒng)一io調(diào)用層封裝規(guī)范，標準化io調(diào)用需要的增強屬性聲明并提供默認配置，如所屬線程池分配、超時、緩存、熔斷、降級等；

2. 優(yōu)化@Async調(diào)用，所有io異步操作統(tǒng)一收縮至io調(diào)用層，在模板層實現(xiàn)回調(diào)機制，老代碼僅繼承模板即可實現(xiàn)異步回調(diào);

3. 請求級別的緩存實現(xiàn)，默認支持r2m;

4. 請求級別的熔斷降級支持，在上游故障時使服務(wù)實現(xiàn)一定程度的自治理；

5. 線程池集中管理，對上下文自動傳遞MDC參數(shù)提供支持；

6. 線程池狀態(tài)自動可視化監(jiān)控、報警實現(xiàn)；

7. 支持配置中心動態(tài)設(shè)置。

具體實現(xiàn)：

1. io調(diào)用抽象模板

模板主要作用是進行規(guī)范和增強，目前提供兩種模板，默認模板、緩存模板，核心思想就是對io操作涉及的大部分行為進行聲明，比如當前服務(wù)所屬線程池分組、請求分組等，由委托組件按照聲明的屬性進行增強實現(xiàn)，示例如下：

主要是提供代碼級別的默認聲明，從日常實踐看大部分采用開發(fā)時的代碼級別的配置即可。

?.

2. 委托代理

此委托屬于整個執(zhí)行過程的橋接實現(xiàn)，io封裝實現(xiàn)繼承抽象模板后，由模板創(chuàng)建委托代理實例，主要用于對io封裝進行增強實現(xiàn)，比如調(diào)用前、調(diào)用后、以及調(diào)用失敗自動調(diào)用聲明的降級方法等處理。

可以理解為：模板專注請求行為，委托關(guān)注對象行為進行組合增強。

3. 執(zhí)行器選型

基于前面的實現(xiàn)目標，減少自研成本，調(diào)研目前已有框架，如 hystrix、sentinel、resilience4j，由于主要目的是期望支持線程池級別的壁艙模式實現(xiàn)，且hystrix集成度要優(yōu)于resilience4j，最終選型默認集成hystrix，備選resilience4j， 以此實現(xiàn)線程池的動態(tài)創(chuàng)建管理、熔斷降級、半連接重試等機制，HystrixCommander實現(xiàn)如下：

4. hystrix 適配 concrete 動態(tài)配置

1、繼承concrete.PropertiesNotifier, 注冊HystrixPropertiesNotifier監(jiān)聽器，緩存配置中心所有以hystrix起始的key配置；

2、實現(xiàn)HystrixDynamicProperties，注冊ConcreteHystrixDynamicProperties替換默認實現(xiàn)，最終支持所有的hystrix配置項，具體用法參考hystrix文檔。

5. hystrix 線程池上下文傳遞改造

hystrix已經(jīng)提供了改造點，主要是對HystrixConcurrencyStrategy#wrapCallable方法重寫實現(xiàn)即可，在submit任務(wù)前暫存主線程上下文進行傳遞。

6. hystrix、jsf、spring注冊線程池狀態(tài)多維可視化監(jiān)控、報警

主要依賴以下三個自定義組件，注冊一個狀態(tài)監(jiān)控處理器，單獨啟動一個線程，定期(每秒)收集所有實現(xiàn)數(shù)據(jù)上報模板的實例，通過指定的通道實現(xiàn)狀態(tài)數(shù)據(jù)推送，目前默認使用PFinder上報：

?ThreadPoolMonitorHandler 定義一個線程狀態(tài)監(jiān)控處理器，定期執(zhí)行上報過程；

?ThreadPoolEndpointMetrics 定義要上報的數(shù)據(jù)模板，包括應(yīng)用實例、線程類型（spring、jsf、hystrix……）、類型線程分組、以及線程池的幾個核心參數(shù)；

?AbstractThreadPoolMetricsPublisher 定義監(jiān)控處理器執(zhí)行上報時依賴的通道（Micrometer、PFinder、UMP……）。

例如以下是hystrix的狀態(tài)收集實現(xiàn)，最終可實現(xiàn)基于機房、分組、實例、線程池類型、名稱等不同維度的狀態(tài)監(jiān)控：

PFinder實際效果：支持不同維度組合查看及報警

7. 提供統(tǒng)一await future工具類

由于大部分調(diào)用是基于列表形式的異步結(jié)果List>、Map>，并且hystrix目前暫不支持返回CompletableFuture，方便統(tǒng)一await，提供工具類：

8. 其他小功能

1、除了sgm traceId支持，同時內(nèi)置自定義的traceId實現(xiàn)，主要是處理sgm在子線程內(nèi)打印traceId需要在控制臺手動添加監(jiān)控方法的問題以及提供對部分無sgm環(huán)境的鏈路Id支持，方便日志跟蹤；

2、比如針對jsf調(diào)用，基于jsf過濾器實現(xiàn)跨應(yīng)用級別的前后請求id傳遞支持；

3、默認增加jsf過濾器實現(xiàn)日志打印，同時支持provider、consume的動態(tài)日志打印開關(guān)，方便線上隨時開關(guān)jsf日志，不再需要在client層重復logger.isDebugerEnabled()；

4、代理層自動上報io調(diào)用方法、fallback等信息至ump，方便監(jiān)控報警。

日常使用示例：

1. 一個最簡單的io調(diào)用封裝

僅增加繼承即可支持異步回調(diào)，不重寫線程池分組時使用默認分組。

2. 一個支持請求級別熔斷的io調(diào)用封裝

默認支持的熔斷級別是服務(wù)級別，老服務(wù)僅需要繼承原請求參數(shù)，實現(xiàn)FallbackRequest接口即可，可防止因為某一個特殊參數(shù)引起的整體接口熔斷。

3. 一個支持請求級別緩存、接口級別熔斷降級、獨立線程池的io調(diào)用封裝

4. 上層調(diào)用，實際效果

1、直接將一個商品列表轉(zhuǎn)換成一個異步屬性綁定任務(wù)；

2、利用工具類await List>；

3、在上層無感知的狀態(tài)下，實現(xiàn)線程池的管理、熔斷、降級、或緩存邏輯的增強，且可根據(jù)pfinder監(jiān)控的可視化線程池狀態(tài)，通過concrete實時調(diào)整線程池及超時或熔斷參數(shù)；

4、舉例：比如某接口頻繁500ms超時，可通過配置直接打開短路返回降級結(jié)果，或者調(diào)低超時為100ms，快速觸發(fā)熔斷，默認10s內(nèi)請求總數(shù)達到20個，50%失敗時打開斷路器，每隔5s半鏈接重試。

三、最后

本篇主要是思考如何依賴現(xiàn)有框架、環(huán)境的能力，從代碼層面系統(tǒng)化的實現(xiàn)相關(guān)治理規(guī)范。

最后仍引用王曉老師文章結(jié)尾來結(jié)束

接口性能問題形成的原因思考我相信很多接口的效率問題不是一朝一夕形成的，在需求迭代的過程中，為了需求快速上線，采取直接累加代碼的方式去實現(xiàn)功能，這樣會造成以上這些接口性能問題。 變換思路，更高一級思考問題，站在接口設(shè)計者的角度去開發(fā)需求，會避免很多這樣的問題，也是降本增效的一種行之有效的方式。 以上，共勉！

審核編輯 黃宇