一、背景

業務監控是指通過技術手段監控業務代碼執行的最終結果或者狀態是否符合預期，實作業務監控主要分成兩步：一、在業務系統中選擇節點發送訊息觸發業務監控；二、系統在接收到mq訊息或者定時任務調度時，根據訊息中或者任務中的業務資料查詢業務執行的結果或狀態并與業務預期的結果相對比，目前供銷系統的方案如下：

由業務系統發送訊息觸發規則中心的校驗任務，校驗邏輯和報警規則通過規則中心的groovy腳本代碼實作，該方案的缺點如下：
1.業務監控代碼摻雜在正常的業務代碼中，業務監控的代碼侵入性高；
2.業務監控訊息觸發代碼可復用性極低，各個應用都要維護一套代碼，后期若要增加或維護某個功能時成本大；
3.增加業務監控的開發作業量，開發人員需要開發和維護與業務監控功能無關的代碼，如：訊息觸發降級功能、性能監控、異步觸發等功能；
為解決上述問題，本文提出了一種通用的業務監控觸發方案，

二、方案介紹

通用mq訊息體：

public class BusinessCheckMessage {
    /**
     * 監控型別
     */
    private String businessType;
    /**
     * 業務監控需要的引數
     */
    private Object data;
    /**
     * 業務方
     */
    private String businessSource;
    /**
     * 當前所屬的topic
     */
    private String topic;
}

其中，
businessType用于區分業務監控的型別，如：終止合作、提單等；
data用于存盤和業務相關的關鍵資料，如訂單id、商家id等；
businessSource用于區分不同業務方的業務，如：萬商的提單、供銷的提單等；
topic用于隔離訊息，如：業務監控任務執行快的可以用主題A、執行慢的的可以用主題B等；

2.自定義注解 + 切面
以供銷系統業務監控為例，接近50%的場景是將方法體中的引數作為業務資料來觸發業務監控，針對此場景，本文采用注解+切面解耦業務監控代碼和正常業務代碼，降低業務監控代碼對正常的業務代碼的侵入，其中自定義注解負責獲取業務監控需要用到的方法入參中的相關資料，切面負責組裝通用mq資料模型并完成訊息的發送，自定義注解定義如下：

public @interface BusinessCheckPoint {
    /**     
     * 業務監控型別     
     */    
   String businessType();    
   /**     
    * 業務方     
    */    
   String businessSource();    
   /**     
    * 要發送的訊息的topic     
    */    
   String businessTopic();    
   /**     
    * 方法引數的第幾個引數作為訊息內容，從0開始     
   */    
   int dataIndex();    
   /**     
    * 在執行業務流程前發送訊息     
    * 默認在業務流程執行后發送訊息     
    */    
   boolean beforeOperate() default false;
}

其中，
businesstype用于獲取業務監控型別；
businessSource用于獲取業務方；
businessTopic用于獲取當前要發送的訊息主體；
dataIndex用于獲取方法體引數中的資料，從0開始；
beforeOperate用于獲取訊息發送的時間，在業務流程執行后發送訊息還是業務流程執行前發訊息；

3.侵入式觸發業務監控
考慮到業務系統可能會在復雜場景下觸發業務監控，本文也提供了通用的解決方案，具體如何使用見下一章節的實戰介紹，

三、實戰介紹

1.引入依賴

<dependency>    
    <groupId>com.jd</groupId>    
    <artifactId>business.check</artifactId>   
    <version>1.0.0</version>
</dependency>

2.初始化切面

<bean id="businessCheckAspect" />

3.Producer及執行緒池賦值

<bean id="businessCheckHandler" >    
    <property name="messageProducerMap">        
        <map>            
            <entry key="gx_bussiness_check" value-ref="businessCheckProducer" />        
        </map>    
    </property>    
    <property name="commonExecutor" ref="asyncTaskThreadPoolTaskExecutor"/>
</bean>

其中，
messageProducerMap型別為Map<String, Producer>，用于指定topic對應的Producer；
commonExecutor用于指定異步發送訊息時用到的執行緒池（建議自行創建執行緒池）；

4.業務監控訊息發送
場景一：
簡單場景下可使用自定義注解來發送訊息，如下所示

業務監控型別 = "100"
訊息主題 = "gx_bussiness_check"
業務方 = "ws"
訊息體中的業務資料data = https://www.cnblogs.com/jingdongkeji/archive/2023/05/16/req

場景二：
復雜場景下，可在服務中注入sdk中的訊息發送服務，如下所示

場景二與場景一發送的訊息內容一致，

5.業務監控降級不發送訊息
sdk中的類BusinessCheckHandlerImpl中定義了控制降級的方法：

public static void setBusinessCheckSwitch(boolean businessCheckSwitch) {            
    BusinessCheckHandlerImpl.businessCheckSwitch = businessCheckSwitch;
}

此處給出了通過ducc控制降級的方法：

@LafValue("business.check.switch")
public void setBusinessCheckSwitch(boolean switch) {   
  BusinessCheckHandlerImpl.setBusinessCheckSwitch(b);
}

switch：true,開啟訊息發送；false，降級

作者：京東零售胡飛

內容來源：京東云開發者社區

轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/552536.html

標籤：其他

上一篇：基于Sentinel自研組件的系統限流、降級、負載保護最佳實踐探索

下一篇：返回列表

一種通用的業務監控觸發方案設計

一、背景

二、方案介紹

三、實戰介紹