skywalking實(shí)現(xiàn)分布式系統(tǒng)鏈路追蹤

一、背景

????隨著微服務(wù)的越來越流行,我們服務(wù)之間的調(diào)用關(guān)系就顯得越來越復(fù)雜,我們急需一個(gè)APM工具來分析系統(tǒng)中存在的各種性能指標(biāo)問題以及調(diào)用關(guān)系。目前主流的APM工具有CATZipkin、Pinpoint以及SkyWalking,本文主要簡(jiǎn)單介紹一下SkyWalking的搭建。

二、SkyWalking的組成

SkyWalking主要的幾個(gè)組成模塊。
1、Agent 主要負(fù)責(zé)從系統(tǒng)中采集各種指標(biāo),鏈路數(shù)據(jù),發(fā)送給 oap服務(wù)。
2、oap服務(wù)接收Agent發(fā)送過來的數(shù)據(jù),存儲(chǔ),執(zhí)行分析,提供查詢和報(bào)警功能。
3、StorageUI負(fù)責(zé)存儲(chǔ)數(shù)據(jù)以及查看數(shù)據(jù)。

三、使用 docker-compose 搭建一個(gè) oap 和 ui 服務(wù)

version: '3'
services:
  elasticsearch7:
    image: docker.elastic.co/elasticsearch/elasticsearch:7.5.0
    container_name: elasticsearch7
    restart: always
    ports:
      - 9023:9200
    environment:
      - discovery.type=single-node
      - bootstrap.memory_lock=true
      - "ES_JAVA_OPTS=-Xms512m -Xmx512m"
      - TZ=Asia/Shanghai
    ulimits:
      memlock:
        soft: -1
        hard: -1
    networks:
      - skywalking
    volumes:
      - elasticsearch7:/usr/share/elasticsearch/data
  oap:
    image: apache/skywalking-oap-server:8.0.1-es7
    container_name: oap
    depends_on:
      - elasticsearch7
    links:
      - elasticsearch7
    restart: always
    ports:
      - 9022:11800
      - 9021:12800
    networks:
      - skywalking
    volumes:
      - ./ext-config:/skywalking/ext-config
  ui:
    image: apache/skywalking-ui:8.0.1
    container_name: ui
    depends_on:
      - oap
    links:
      - oap
    restart: always
    ports:
      - 9020:8080
    environment:
      SW_OAP_ADDRESS: oap:12800
    networks:
      - skywalking

networks:
  skywalking:
    driver: bridge

volumes:
  elasticsearch7:
    driver: local

1、docker-compose文件的目錄

skywalking
├── ext-config
│   └── application.yml
├── ext-libs
├── skywalking.yml
└── temp.txt

2、訪問

http://localhost:9020

3、注意事項(xiàng)

1、如果我們想覆蓋oap鏡像中的/skywalking/config 目錄下的配置文件,我們可以在 docker 中掛載一個(gè)/skywalking/ext-config目錄,將配置文件丟到此目錄中即可。
2、如果我們想覆蓋oap鏡像中的/skywalking/oap-libs 目錄下的jar,我們可以在 docker 中掛載一個(gè)/skywalking/ext-libs目錄,將新的jar包丟到此目錄中即可,但是已經(jīng)存在的jar包無法被覆蓋。
3、使用的版本是 8.0.1,數(shù)據(jù)持久化到 es7

四、全局日志追蹤 traceId 的使用

方案一:

1、引入依賴

<dependency>
    <groupId>org.apache.skywalking</groupId>
    <artifactId>apm-toolkit-logback-1.x</artifactId>
    <version>8.0.1</version>
</dependency>

2、修改 logback.xml 文件


<?xml version="1.0" encoding="UTF-8"?>
<!-- Logback Configuration.  -->
<configuration debug="false">

    <!-- ConsoleAppender:把日志輸出到控制臺(tái) -->
    <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
        <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
            <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
                <Pattern><![CDATA[
%clr(%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}}){faint} [%X{tid}] %clr(${LOG_LEVEL_PATTERN:-%5p}) %clr(${PID:- }){magenta} %clr(---){faint} %clr([%15.15t]){faint} %clr(%-40.40logger{39}){cyan} %clr(:){faint} %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}
            ]]></Pattern>
            </layout>
        </encoder>
    </appender>

    <root level="INFO">
        <appender-ref ref="STDOUT"/>
    </root>
</configuration>

方案二

參考如下鏈接 https://github.com/apache/skywalking/blob/master/docs/en/setup/service-agent/java-agent/Application-toolkit-trace.md

五、idea 或 jar 中使用

使用如下命令,需要折成一行
java 
-javaagent:(agentjar包的位置)(eg: /Users/huan/soft/apache-skywalking-apm-bin-es7/agent/skywalking-agent.jar )
-Dskywalking.agent.service_name=xxxxx-service 
-Dskywalking.collector.backend_service=127.0.0.1:9022  -jar xxxx.jar

-javaagent 指定 agent jar 包的位置
-Dskywalking.agent.service_name 指定服務(wù)名
-Dskywalking.collector.backend_service 指定 oap 服務(wù)的地址

idea中使用

六、skywalking的目錄解釋

apache-skywalking-apm-bin-es7
├── LICENSE
├── NOTICE
├── README.txt
├── agent
                        ├── activations
                      ├── bootstrap-plugins
                      ├── config   -- agent 的配置文件,比如我們上一步使用 -Dskywalking.agent.service_name配置的這些
                      ├── logs
                      ├── optional-plugins     可選插件      (將optional-plugins目錄的jar包放到 plugins 目錄下即可啟動(dòng)這些插件)
                      ├── plugins                     啟用的插件
                     └── skywalking-agent.jar  我們自己的服務(wù)需要使用 -javaagent 指定到這個(gè)jar的位置
├── bin          oap/ui 的啟動(dòng)腳本
├── config    配置文件
├── licenses
├── oap-libs
├── tools
└── webapp   ui界面

七、訪問 skywalking 的界面

skywalking.jpg

八、實(shí)戰(zhàn)

1、忽略某些url不被追蹤

1、第一步將 apm-trace-ignore-plugin-8.0.1.jar 從optional-plugins 移動(dòng)到 plugins 目錄中

引入忽略u(píng)rl插件

2、配置忽略u(píng)rl

方法一:agent/config 目錄下創(chuàng)建 apm-trace-ignore-plugin.config文件

trace.ignore_path=${SW_AGENT_TRACE_IGNORE_PATH:需要忽略的url}
eg:trace.ignore_path=${SW_AGENT_TRACE_IGNORE_PATH:/xxx/**}

方法二: 直接使用環(huán)境變量
-Dskywalking.trace.ignore_path=需要忽略的url路徑

注意:
1、忽略路徑是支持 ant 風(fēng)格的。
2、忽略多個(gè)url使用英文的逗號(hào)分隔。

2、追蹤子線程的信息

1、引入依賴

<dependency>
        <groupId>org.apache.skywalking</groupId>
        <artifactId>apm-toolkit-trace</artifactId>
        <version>8.0.1</version>
</dependency>

2、使用@TraceCrossThread注解或使用SupplierWrapper/RunnableWrapper/TraceCrossThread

@GetMapping("tractThread")
    public String tractThread() {
        log.info("準(zhǔn)備自己線程信息");
        new Thread(RunnableWrapper.of(() -> log.info("子線程的信息"))).start();
        return "trace thread";
    }

此處演示RunnableWrapper.of包裝Runnable線程。

追蹤子線程

3、如果某個(gè)方法SkyWalking沒有追蹤,但是想追蹤并輸出一些額外的tag信息等

1、引入依賴

<dependency>
        <groupId>org.apache.skywalking</groupId>
        <artifactId>apm-toolkit-trace</artifactId>
        <version>8.0.1</version>
</dependency>

2、自己想加入的方法使用 @Trace 注解修飾

@GetMapping("tractAnnotation")
    public User traceAnnotation(
            @RequestParam("name") String name
    ) {
        log.info("從前端接收到的參數(shù):[{}]", name);
        User user = trace(name);
        ActiveSpan.tag("new-tag", user.toString());
        ActiveSpan.info("輸出信息");
        log.info("tractId:[{}]", TraceContext.traceId());
        return user;
    }

    @Trace(operationName = "添加自定義的方法")
    @Tags({
            @Tag(key = "從方法參數(shù)中獲取值", value = "arg[0]"),
            @Tag(key = "從返回值中獲取值", value = "returnedObj.name")
    })
    private User trace(String name) {
        log.info("如果此方法沒有被SkyWalking收集,但是又需要被收集到,可以加上@Trace注解");
        User user = new User();
        user.setName("創(chuàng)建的名字");
        return user;
    }
Trace注解的使用

4、自定義顯示服務(wù)實(shí)例

默認(rèn)服務(wù)實(shí)例的名字是 uuid@hostname,這個(gè)在某些時(shí)候不一定好區(qū)分,因?yàn)槲覀兿M远x一個(gè) instanceName 名字

1、默認(rèn)的實(shí)現(xiàn)

默認(rèn)的服務(wù)實(shí)例

2、自定義實(shí)現(xiàn)

使用 -Dskywalking.agent.instance_name=自定義的服務(wù)名即可。

自定義實(shí)例服務(wù)名

5、配置記錄的過期時(shí)間

修改記錄在skywalking中的保存的時(shí)間

修改 application.yml 配置文件中的信息。

6、和其它agent使用時(shí)候的處理

1、問題

當(dāng)我們和其它的agent一起使用時(shí),比如Arthas,其它的agent可能工作的不是那么好。

2、解決方案

jar程序啟動(dòng)命令增加如下JVM參數(shù)

-Dskywalking.agent.is_cache_enhanced_class=true -Dskywalking.agent.class_cache_mode=MEMORY

3、參考文檔

https://github.com/apache/skywalking/blob/master/docs/en/FAQ/Compatible-with-other-javaagent-bytecode-processing.md

九、項(xiàng)目源碼

docker-compose.yml文件 https://gitee.com/huan1993/configuration/blob/master/docker/compose/skywalking/skywalking.yml
java代碼 https://gitee.com/huan1993/skywalking

十、參考鏈接

SkyWalking官網(wǎng) http://skywalking.apache.org/zh/
SkyWalking的docker github地址 https://github.com/apache/skywalking-docker
elasticsearch https://www.elastic.co/guide/en/elasticsearch/reference/7.5/docker.html
skywalking中文文檔 https://skyapm.github.io/document-cn-translation-of-skywalking/
agent config https://github.com/apache/skywalking/blob/v8.0.1/docs/en/setup/service-agent/java-agent/README.md#table-of-agent-configuration-properties
skywalking和其它agent一起使用的處理

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

友情鏈接更多精彩內(nèi)容