SpringBoot2集成日志以及復(fù)雜業(yè)務(wù)下的自定義實(shí)現(xiàn)是怎樣的

這期內(nèi)容當(dāng)中小編將會(huì)給大家?guī)碛嘘P(guān)SpringBoot2集成日志以及復(fù)雜業(yè)務(wù)下的自定義實(shí)現(xiàn)是怎樣的，文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述，閱讀完這篇文章希望大家可以有所收獲。

成都創(chuàng)新互聯(lián)公司專注于民權(quán)企業(yè)網(wǎng)站建設(shè),響應(yīng)式網(wǎng)站設(shè)計(jì),電子商務(wù)商城網(wǎng)站建設(shè)。民權(quán)網(wǎng)站建設(shè)公司,為民權(quán)等地區(qū)提供建站服務(wù)。全流程按需網(wǎng)站設(shè)計(jì)，專業(yè)設(shè)計(jì)，全程項(xiàng)目跟蹤，成都創(chuàng)新互聯(lián)公司專業(yè)和態(tài)度為您提供的服務(wù)

一、日志體系集成

1、日志管理

在系統(tǒng)的開發(fā)中，最關(guān)鍵的一個(gè)組件工具就是日志，日志打印方便問題排查，或者生產(chǎn)事故回溯，日志記錄用來監(jiān)控并分析系統(tǒng)性能點(diǎn)，并以此為依據(jù)，不斷對(duì)系統(tǒng)進(jìn)行優(yōu)化；同時(shí)基于用戶的操作日志，對(duì)用戶行為進(jìn)行分析，開發(fā)智能推薦的功能，或者進(jìn)行營(yíng)銷投放，這在系統(tǒng)中都是常見且關(guān)鍵的業(yè)務(wù)流程。

2、ELK日志體系

在大型系統(tǒng)架構(gòu)中，ELK的日志管理系統(tǒng)是系統(tǒng)必備功能，ELK-Stack是Elasticsearch、Logstash、Kiban三個(gè)開源軟件的組合，通常用來做日志分析，實(shí)時(shí)數(shù)據(jù)檢索?；贚ogstash做數(shù)據(jù)流動(dòng)通道，使日志數(shù)據(jù)不斷的流入搜索組件，基于Elasticsearch做數(shù)據(jù)實(shí)時(shí)查詢，基于Kiban的ES可視化界面，以此實(shí)現(xiàn)日志數(shù)據(jù)的搜集、存儲(chǔ)、分析等核心功能，且該體系方便擴(kuò)展。

基于ELK體系的核心操作，有關(guān)于ElasticSearch其他文章可以自行查閱之前的內(nèi)容，這里不在陳列，好像很多東西都是這樣一點(diǎn)點(diǎn)積累出來的。

二、集成環(huán)境

1、項(xiàng)目結(jié)構(gòu)

SpringBoot2集成日志以及復(fù)雜業(yè)務(wù)下的自定義實(shí)現(xiàn)是怎樣的

defined-log-api：測(cè)試工程；

defined-log-config：日志核心模塊，依賴之后使用該模塊下注解即可；

2、數(shù)據(jù)表結(jié)構(gòu)

CREATE TABLE dt_defined_log (
	id INT ( 11 ) NOT NULL AUTO_INCREMENT COMMENT '主鍵',
	class_name VARCHAR ( 200 ) DEFAULT NULL COMMENT '請(qǐng)求類名',
	method_name VARCHAR ( 100 ) DEFAULT NULL COMMENT '請(qǐng)求方法名',
	method_desc VARCHAR ( 100 ) DEFAULT NULL COMMENT '請(qǐng)求方法描述',
	api_type INT ( 1 ) DEFAULT 0 COMMENT 'API類型',
	biz_nature INT ( 1 ) DEFAULT 0 COMMENT '業(yè)務(wù)性質(zhì)類型',
	data_flow_type INT ( 1 ) DEFAULT 0 COMMENT '日志數(shù)據(jù)流向',
	req_param VARCHAR ( 200 ) DEFAULT NULL COMMENT '請(qǐng)求報(bào)文',
	res_param VARCHAR ( 200 ) DEFAULT NULL COMMENT '響應(yīng)報(bào)文',
	PRIMARY KEY ( `id` ) 
) ENGINE = INNODB DEFAULT CHARSET = utf8 COMMENT = '日志記錄表';

這里完全基于業(yè)務(wù)需求自定義即可。

三、核心代碼說明

1、注解參數(shù)

@Retention(RetentionPolicy.RUNTIME)
@Target(ElementType.METHOD)
@Documented
public @interface DefinedLog {

    /**
     * 操作類型
     */
    ApiTypeEnum apiType () ;

    /**
     * 方法描述
     */
    String methodDesc();

    /**
     * 業(yè)務(wù)性質(zhì)
     */
    BizNatureEnum bizNature() ;

    /**
     * 數(shù)據(jù)流向,與業(yè)務(wù)性質(zhì)關(guān)聯(lián)
     */
    DataFlowEnum dataFlow() ;

    /**
     * 存儲(chǔ)入?yún)?
     */
    boolean isSaveReqParam () default true ;

    /**
     * 存儲(chǔ)出參
     */
    boolean isSaveResParam() default true ;

    /**
     * 是否需要異步處理
     */
    boolean isAsync () default false ;
}

這里描述一下如下幾個(gè)參數(shù)的意思：

bizNature：業(yè)務(wù)性質(zhì)，即該日志是否有分析，或者營(yíng)銷推廣操作，例如在在電商業(yè)務(wù)中，瀏覽系列商品后是否推送廣告；

dataFlow：數(shù)據(jù)流向，即數(shù)據(jù)存儲(chǔ)后是否向其他數(shù)據(jù)源推送，常見可能推送到MQ或者redis或者分析引擎中，推薦類系統(tǒng)中對(duì)關(guān)鍵日志實(shí)時(shí)性要求極高，可以基于此做用戶行為實(shí)時(shí)分析；

isAsync：是否異步處理，在一些并發(fā)高的接口中，避免日志記錄成為性能問題的一個(gè)因素；

其他相關(guān)參數(shù)都是十分常見，例如接口類型增刪改查，入?yún)⒊鰠?bào)文存儲(chǔ)，方法模塊的描述等等，這些都可以基于業(yè)務(wù)的需求自定義，然后做相關(guān)業(yè)務(wù)處理開發(fā)，思路開闊即可。

2、切面攔截

基于切面編程是方式，做相關(guān)日志處理，獲取相應(yīng)參數(shù)，構(gòu)建日志模型即可。

@Component
@Aspect
public class LogAop {

    private static final Logger LOGGER = LoggerFactory.getLogger(LogAop.class);

    @Value("${spring.application.app-id}")
    private String appId ;
    @Resource
    private DefineLogService defineLogService ;

    /**
     * 日志切入點(diǎn)
     */
    @Pointcut("@annotation(com.defined.log.annotation.DefinedLog)")
    public void logPointCut() {

    }

    /**
     * 環(huán)繞切入
     */
    @Around("logPointCut()")
    public Object around (ProceedingJoinPoint proceedingJoinPoint) throws Throwable {
        Object result = null ;
        StopWatch stopWatch = new StopWatch();
        stopWatch.start();
        try{
            // 執(zhí)行方法
            result = proceedingJoinPoint.proceed();
            stopWatch.stop();
        } catch (Exception e){
            stopWatch.stop();
        } finally {
            // 保存日志
            LOGGER.info(" execute time: {} ms ", stopWatch.getTotalTimeMillis());
            DefineLogModel defineLogModel = buildLogParam (proceedingJoinPoint);
            defineLogModel.setResParam(JSONObject.toJSONString(result));
            defineLogService.saveLog(defineLogModel) ;
        }
        return result ;
    }

    private DefineLogModel buildLogParam (ProceedingJoinPoint point){

        DefineLogModel defineLogModel  = new DefineLogModel() ;

        MethodSignature signature = (MethodSignature) point.getSignature();
        Method reqMethod = signature.getMethod();
        String className = point.getTarget().getClass().getName();
        Object[] reqParam = point.getArgs();

        LOGGER.info("請(qǐng)求方法:"+reqMethod.getName());
        LOGGER.info("請(qǐng)求類名:"+className);
        LOGGER.info("請(qǐng)求參數(shù):"+ JSONObject.toJSONString(reqParam));
        // 獲取方法上注解
        reqMethod.getAnnotation(DefinedLog.class).getClass();
        DefinedLog definedLog = reqMethod.getAnnotation(DefinedLog.class);

        // 構(gòu)建參數(shù)
        String methodName = reqMethod.getName() ;
        Integer apiType = definedLog.apiType().getApiType();
        String apiTypeDesc = definedLog.apiType().getApiTypeDesc();
        String methodDesc = definedLog.methodDesc() ;
        Integer bizNature = definedLog.bizNature().getBizNature() ;
        Integer dataFlowType = definedLog.dataFlow().getDataFlowType();
        boolean isSaveReqParam = definedLog.isSaveReqParam();
        boolean isSaveResParam = definedLog.isSaveResParam();
        boolean isAsync = definedLog.isAsync() ;

        defineLogModel.setAppId(appId);
        defineLogModel.setClassName(className);
        defineLogModel.setMethodName(methodName);
        defineLogModel.setMethodDesc(methodDesc);
        defineLogModel.setApiType(apiType);
        defineLogModel.setApiTypeDesc(apiTypeDesc);
        defineLogModel.setBizNature(bizNature);
        defineLogModel.setDataFlowType(dataFlowType);
        defineLogModel.setSaveReqParam(isSaveReqParam);
        defineLogModel.setSaveResParam(isSaveResParam);
        defineLogModel.setAsync(isAsync);
        defineLogModel.setReqParam(JSONObject.toJSONString(reqParam));

        return defineLogModel ;
    }
}

3、使用方式

DefinedLog注解在接口方法上即可。

@RestController
public class LogController {

    @GetMapping("/logApi")
    @DefinedLog(apiType=ApiTypeEnum.COMPOSITE,
                methodDesc="測(cè)試日志",
                bizNature= BizNatureEnum.DEFAULT,
                dataFlow= DataFlowEnum.DEFAULT)
    public String logApi (@RequestParam("param") String param){
        return "success-re" ;
    }

}

4、記錄參數(shù)

SpringBoot2集成日志以及復(fù)雜業(yè)務(wù)下的自定義實(shí)現(xiàn)是怎樣的

這樣自定義日志流程就完成了。

上述就是小編為大家分享的SpringBoot2集成日志以及復(fù)雜業(yè)務(wù)下的自定義實(shí)現(xiàn)是怎樣的了，如果剛好有類似的疑惑，不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。

分享文章：SpringBoot2集成日志以及復(fù)雜業(yè)務(wù)下的自定義實(shí)現(xiàn)是怎樣的
標(biāo)題路徑：http://muchs.cn/article24/ghjice.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供域名注冊(cè)、企業(yè)建站、App設(shè)計(jì)、網(wǎng)站設(shè)計(jì)公司、云服務(wù)器、網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)

成都網(wǎng)頁設(shè)計(jì)公司