Spring Boot 集成 CAT 全链路监控

监控

发布日期: 2021-11-26

更新日期: 2023-07-04

文章字数: 595

阅读时长: 2 分

阅读次数:

一、编写一个 springboot 与 cat 整合的案例

将 cat-client 通过源码安装到本地仓库

cat-client的源码路径：cat/lib/java
进入源码路径后，执行命令：
```
mvn clean install -DskipTests
```

安装成功后，在本地仓库就存在 cat-client-3.0.0.jar 包了

CAT客户端 Demo

maven 引入 cat 客户端包，在 pom.xml 加入

<dependency>
    <groupId>com.dianping.cat</groupId>
    <artifactId>cat-client</artifactId>
    <version>3.0.0</version>
</dependency>

配置domain

在资源文件中新建app.properties文件

在resources资源文件META-INF下，注意是src/main/resources/META-INF/文件夹，加上domain配置，如：app.name=spring-boot-cat-simple

接着我们以一个简单的接口测试演练下，项目结构如下：

HelloController 类

package com.zq.controller;

import com.zq.service.CatService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import javax.servlet.http.HttpServletRequest;

// @RestController 的意思是 Controller 里面的方法都以 json 格式输出
@RestController
public class HelloController {

    @Autowired
    private CatService catServiceImpl;

    @RequestMapping("/hello")
    public String index(HttpServletRequest request) {
        String url = request.getRequestURL().toString();

        return catServiceImpl.hello(url);
    }

    @RequestMapping("/error")
    public String error(HttpServletRequest request) {
        String url = request.getRequestURL().toString();

        return catServiceImpl.error(url);
    }
}

Service 类

package com.zq.service.impl;

import com.dianping.cat.Cat;
import com.dianping.cat.message.Transaction;
import com.zq.service.CatService;
import org.springframework.stereotype.Service;

@Service
public class CatServiceImpl implements CatService {

    @Override
    public String hello(String url) {

        // 创建一个 Transaction
        Transaction transaction = Cat.newTransaction("URL", url);
        try {
            // 处理业务
            myBusiness();
            // 设置成功状态
            transaction.setStatus(Transaction.SUCCESS);
        } catch (Exception e) {
            // 设置错误状态
            transaction.setStatus(e);
            // 记录错误信息
            Cat.logError(e);
        } finally {
            // 结束 Transaction
            transaction.complete();
        }

        return "hello";
    }

    @Override
    public String error(String url) {
        // 创建一个 Transaction
        Transaction transaction = Cat.newTransaction("URL", url);
        try {
            // 处理业务
            int i = 1 / 0;
            // 设置成功状态
            transaction.setStatus(Transaction.SUCCESS);
        } catch (Exception e) {
            // 设置错误状态
            transaction.setStatus(e);
            // 记录错误信息
            Cat.logError(e);
        } finally {
            // 结束 Transaction
            transaction.complete();
        }

        return "error";
    }

    private void myBusiness() {
        // 模拟业务处理时间
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}