首頁>技術>

此元件解決的問題是:「誰」在「什麼時間」對「什麼」做了「什麼事」

本元件目前針對 Spring-boot 做了 Autoconfig,如果是 SpringMVC,也可自己在 xml 初始化 bean

使用方式

基本使用

maven依賴新增SDK依賴

        <dependency>            <groupId>io.github.mouzt</groupId>            <artifactId>bizlog-sdk</artifactId>            <version>1.0.1</version>        </dependency>

SpringBoot入口開啟開關,新增 @EnableLogRecord 註解

tenant是代表租戶的標識,一般一個服務或者一個業務下的多個服務都寫死一個 tenant 就可以

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)@EnableTransactionManagement@EnableLogRecord(tenant = "com.mzt.test")public class Main {    public static void main(String[] args) {        SpringApplication.run(Main.class, args);    }}
日誌埋點

1. 普通的記錄日誌

pefix:是拼接在 bizNo 上作為 log 的一個標識。避免 bizNo 都為整數 ID 的時候和其他的業務中的 ID 重複。比如訂單 ID、使用者 ID 等bizNo:就是業務的 ID,比如訂單ID,我們查詢的時候可以根據 bizNo 查詢和它相關的操作日誌success:方法呼叫成功後把 success 記錄在日誌的內容中SpEL 表示式:其中用雙大括號包圍起來的(例如:{{#order.purchaseName}})#order.purchaseName 是 SpEL表示式。Spring中支援的它都支援的。比如呼叫靜態方法,三目表示式。SpEL 可以使用方法中的任何引數
  @LogRecordAnnotation(success = "{{#order.purchaseName}}下了一個訂單,購買商品「{{#order.productName}}」,下單結果:{{#_ret}}",              prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}")  public boolean createOrder(Order order) {      log.info("【建立訂單】orderNo={}", order.getOrderNo());      // db insert order      return true;  }

此時會列印操作日誌 “張三下了一個訂單,購買商品「超值優惠紅燒肉套餐」,下單結果:true”

2. 期望記錄失敗的日誌, 如果丟擲異常則記錄fail的日誌,沒有丟擲記錄 success 的日誌

    @LogRecordAnnotation(            fail = "建立訂單失敗,失敗原因:「{{#_errorMsg}}」",            success = "{{#order.purchaseName}}下了一個訂單,購買商品「{{#order.productName}}」,下單結果:{{#_ret}}",            prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}")    public boolean createOrder(Order order) {        log.info("【建立訂單】orderNo={}", order.getOrderNo());        // db insert order        return true;    }

其中的 #_errorMsg 是取的方法丟擲異常後的異常的 errorMessage。

3. 日誌支援種類

比如一個訂單的操作日誌,有些操作日誌是使用者自己操作的,有些操作是系統運營人員做了修改產生的操作日誌,我們系統不希望把運營的操作日誌暴露給使用者看到, 但是運營期望可以看到使用者的日誌以及運營自己操作的日誌,這些操作日誌的bizNo都是訂單號,所以為了擴充套件添加了型別欄位,主要是為了對日誌做分類,查詢方便,支援更多的業務。

    @LogRecordAnnotation(            fail = "建立訂單失敗,失敗原因:「{{#_errorMsg}}」",            category = "MANAGER",            success = "{{#order.purchaseName}}下了一個訂單,購買商品「{{#order.productName}}」,下單結果:{{#_ret}}",            prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}")    public boolean createOrder(Order order) {        log.info("【建立訂單】orderNo={}", order.getOrderNo());        // db insert order        return true;    }

4. 支援記錄操作的詳情或者額外資訊

如果一個操作修改了很多欄位,但是success的日誌模版裡面防止過長不能把修改詳情全部展示出來,這時候需要把修改的詳情儲存到 detail 欄位, detail 是一個 String ,需要自己序列化。這裡的 #order.toString() 是呼叫了 Order 的 toString() 方法。如果儲存 JSON,自己重寫一下 Order 的 toString() 方法就可以。

 @LogRecordAnnotation(            fail = "建立訂單失敗,失敗原因:「{{#_errorMsg}}」",            category = "MANAGER_VIEW",            detail = "{{#order.toString()}}",            success = "{{#order.purchaseName}}下了一個訂單,購買商品「{{#order.productName}}」,下單結果:{{#_ret}}",            prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}")    public boolean createOrder(Order order) {        log.info("【建立訂單】orderNo={}", order.getOrderNo());        // db insert order        return true;    }

5. 如何指定操作日誌的操作人是什麼?框架提供了兩種方法

第一種:手工在LogRecord的註解上指定。這種需要方法引數上有operator
    @LogRecordAnnotation(            fail = "建立訂單失敗,失敗原因:「{{#_errorMsg}}」",            category = "MANAGER_VIEW",            detail = "{{#order.toString()}}",            operator = "{{#currentUser}}",            success = "{{#order.purchaseName}}下了一個訂單,購買商品「{{#order.productName}}」,下單結果:{{#_ret}}",            prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}")    public boolean createOrder(Order order, String currentUser) {        log.info("【建立訂單】orderNo={}", order.getOrderNo());        // db insert order        return true;    }

這種方法手工指定,需要方法引數上有 operator 引數,或者透過 SpEL 呼叫靜態方法獲取當前使用者。

第二種:透過預設實現類來自動的獲取操作人,由於在大部分web應用中當前的使用者都是儲存在一個執行緒上下文中的,所以每個註解都加一個operator獲取操作人顯得有些重複勞動,所以提供了一個擴充套件介面來獲取操作人 框架提供了一個擴充套件介面,使用框架的業務可以 implements 這個介面自己實現獲取當前使用者的邏輯, 對於使用 Springboot 的只需要實現 IOperatorGetService 介面,然後把這個 Service 作為一個單例放到 Spring 的上下文中。使用 Spring Mvc 的就需要自己手工裝配這些 bean 了。
@Configurationpublic class LogRecordConfiguration {    @Bean    public IOperatorGetService operatorGetService() {        return () -> Optional.of(OrgUserUtils.getCurrentUser())                .map(a -> new OperatorDO(a.getMisId()))                .orElseThrow(() -> new IllegalArgumentException("user is null"));    }}//也可以這麼搞:@Servicepublic class DefaultOperatorGetServiceImpl implements IOperatorGetService {    @Override    public OperatorDO getUser() {        OperatorDO operatorDO = new OperatorDO();        operatorDO.setOperatorId("SYSTEM");        return operatorDO;    }}

6. 日誌文案調整

對於更新等方法,方法的引數上大部分都是訂單ID、或者產品ID等, 比如下面的例子:日誌記錄的success內容是:“更新了訂單{{#orderId}},更新內容為…”,這種對於運營或者產品來說難以理解,所以引入了自定義函式的功能。使用方法是在原來的變數的兩個大括號之間加一個函式名稱 例如 “{ORDER{#orderId}}” 其中 ORDER 是一個函式名稱。只有一個函式名稱是不夠的,需要新增這個函式的定義和實現。可以看下面例子 自定義的函式需要實現框架裡面的IParseFunction的介面,需要實現兩個方法:

functionName() 方法就返回註解上面的函式名;apply()函式引數是 "{ORDER{#orderId}}"中SpEL解析的#orderId的值,這裡是一個數字1223110,接下來只需要在實現的類中把 ID 轉換為可讀懂的字串就可以了, 一般為了方便排查問題需要把名稱和ID都展示出來,例如:"訂單名稱(ID)"的形式。

這裡有個問題:加了自定義函式後,框架怎麼能呼叫到呢?答:對於Spring boot應用很簡單,只需要把它暴露在Spring的上下文中就可以了,可以加上Spring的 @Component 或者 @Service 很方便。Spring mvc 應用需要自己裝配 Bean。

    // 沒有使用自定義函式    @LogRecordAnnotation(success = "更新了訂單{{#orderId}},更新內容為....",            prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}",            detail = "{{#order.toString()}}")    public boolean update(Long orderId, Order order) {        return false;    }    //使用了自定義函式,主要是在 {{#orderId}} 的大括號中間加了 functionName    @LogRecordAnnotation(success = "更新了訂單ORDER{#orderId}},更新內容為...",            prefix = LogRecordType.ORDER, bizNo = "{{#order.orderNo}}",            detail = "{{#order.toString()}}")    public boolean update(Long orderId, Order order) {        return false;    }    // 還需要加上函式的實現    @Component    public class OrderParseFunction implements IParseFunction {        @Resource        @Lazy //為了避免類載入順序的問題 最好為Lazy,沒有問題也可以不加        private OrderQueryService orderQueryService;        @Override        public String functionName() {            //  函式名稱為 ORDER            return "ORDER";        }        @Override        //這裡的 value 可以吧 Order 的JSON物件的傳遞過來,然後反解析拼接一個定製的操作日誌內容        public String apply(String value) {            if(StringUtils.isEmpty(value)){                return value;            }            Order order = orderQueryService.queryOrder(Long.parseLong(value));            //把訂單產品名稱加上便於理解,加上 ID 便於查問題            return order.getProductName().concat("(").concat(value).concat(")");        }    }

7. 日誌文案調整 使用 SpEL 三目表示式

    @LogRecordAnnotation(prefix = LogRecordTypeConstant.CUSTOM_ATTRIBUTE, bizNo = "{{#businessLineId}}",            success = "{{#disable ? '停用' : '啟用'}}了自定義屬性{ATTRIBUTE{#attributeId}}")    public CustomAttributeVO disableAttribute(Long businessLineId, Long attributeId, boolean disable) {     return xxx;    }
框架的擴充套件點重寫OperatorGetServiceImpl透過上下文獲取使用者的擴充套件,例子如下
@Servicepublic class DefaultOperatorGetServiceImpl implements IOperatorGetService {    @Override    public Operator getUser() {         return Optional.ofNullable(UserUtils.getUser())                        .map(a -> new Operator(a.getName(), a.getLogin()))                        .orElseThrow(()->new IllegalArgumentException("user is null"));    }}
ILogRecordService 儲存/查詢日誌的例子,使用者可以根據資料量儲存到合適的儲存介質上,比如儲存在資料庫/或者ES。自己實現儲存和刪除就可以了

也可以只實現查詢的介面,畢竟已經儲存在業務的儲存上了,查詢業務可以自己實現,不走 ILogRecordService 這個介面,畢竟產品經理會提一些千奇百怪的查詢需求。

@Servicepublic class DbLogRecordServiceImpl implements ILogRecordService {    @Resource    private LogRecordMapper logRecordMapper;    @Override    @Transactional(propagation = Propagation.REQUIRES_NEW)    public void record(LogRecord logRecord) {        log.info("【logRecord】log={}", logRecord);        LogRecordPO logRecordPO = LogRecordPO.toPo(logRecord);        logRecordMapper.insert(logRecordPO);    }    @Override    public List<LogRecord> queryLog(String bizKey, Collection<String> types) {        return Lists.newArrayList();    }    @Override    public PageDO<LogRecord> queryLogByBizNo(String bizNo, Collection<String> types, PageRequestDO pageRequestDO) {        return logRecordMapper.selectByBizNoAndCategory(bizNo, types, pageRequestDO);    }}
IParseFunction 自定義轉換函式的介面,可以實現IParseFunction 實現對LogRecord註解中使用的函式擴充套件 例子:
@Componentpublic class UserParseFunction implements IParseFunction {    private final Splitter splitter = Splitter.on(",").trimResults();    @Resource    @Lazy    private UserQueryService userQueryService;    @Override    public String functionName() {        return "USER";    }    @Override    // 11,12 返回 11(小明),12(張三)    public String apply(String value) {        if (StringUtils.isEmpty(value)) {            return value;        }        List<String> userIds = Lists.newArrayList(splitter.split(value));        List<User> misDOList = userQueryService.getUserList(userIds);        Map<String, User> userMap = StreamUtil.extractMap(misDOList, User::getId);        StringBuilder stringBuilder = new StringBuilder();        for (String userId : userIds) {            stringBuilder.append(userId);            if (userMap.get(userId) != null) {                stringBuilder.append("(").append(userMap.get(userId).getUsername()).append(")");            }            stringBuilder.append(",");        }        return stringBuilder.toString().replaceAll(",$", "");    }}
變數相關

LogRecordAnnotation 可以使用的變量出了引數也可以使用返回值#_ret變數,以及異常的錯誤資訊#_errorMsg,也可以透過SpEL的 T 方式呼叫靜態方法噢

待擴充套件

實現一個 Log的 Context,可以解決方法引數中沒有的變數但是想使用的問題,初步想法是可以透過在方法中 add 變數的形式實現,很快就可以實現了

注意點:

整體日誌攔截是在方法執行之後記錄的,所以對於方法內部修改了方法引數之後,LogRecordAnnotation 的註解上的 SpEL 對變數的取值是修改後的值哦~

原始碼

https://github.com/mouzt/mzt-biz-log

連結:https://mp.weixin.qq.com/s/qGqamCIDJeoze-1GezPDRA

13
最新評論
  • BSA-TRITC(10mg/ml) TRITC-BSA 牛血清白蛋白改性標記羅丹明
  • C語言學習之-----(一) 變數