项目运行状况不断，怎么办？看看企业级监控项目Skywalking吧

一. Skywalking概述

一个优秀的项目，除了具有高拓展的架构、高性能的方案、高质量的代码之外，还应该在上线后具备多角度的监控功能。现在企业中的监控服务也有很多，Skywalking除了提供多维度、多粒度的监控之外，也提供了良好的图形化界面以及性能剖析、服务报警等多种功能，备受很多企业的青睐。因此侯哥今天给大家通过一篇文章，来详细地给大家介绍Skywalking。

1.1 什么是Skywalking?

Skywalking是一款分布式的系统性能监视工具，专为微服务、云原生架构和基于容器(Docker、K8s、Mesos)架构而设计。SkyWalking是一款观察性的分析平台和应用性能管理系统，提供了分布式追踪、性能指标分析、应用服务依赖分析、可视化一体化等解决方案。

1.2 官网地址

https://skywalking.apache.org/

1.3 Skywalking功能特点

Skywalking功能非常丰富，侯哥简单地给大家总结一下。

• 监控手段丰富

• 多语言自动探针

• 优秀的可视化方案

• 分布式链路跟踪和上下文传播

• 数据库访问指标

• 告警

1.4 Skywalking架构图

这是官网提供的Skywalking架构图，可以分成几个部分，简单来说，可以分成oap、webapp和agent三部分：

• oap是skywalking最核心的部分，主要用于汇总数据、存储数据、提供对外的相关接口；

• webapp主要提供了ui界面，并且从oap获取数据并且展示(通常和oap部署在服务端，相当于skywalking服务的后台监控管理程序)；

• agent是探针，部署在需要收集数据的应用服务器上，并将数据同步到Skywalking平台。

二. Skywalking的安装与使用

2.1 Skywalking服务端安装步骤

2.1.1 前置环境

首先需要安装JDK，并确保以下端口可用：

11800：探针和Skywalking通讯的gRPC端口 12800：UI视图程序和Skywalking通讯的HTTP端口 8080：可视化视图UI服务的启动端口

2.1.2 官网下载SkyWalking包

2.1.3 上传到Linux服务器并解压

#解压skywalking
tar -zxf apache-skywalking-apm-8.9.1.tar.gz
#修改解压后的文件夹
mv apache-skywalking-apm-8.9.1 skywalking
#进入skywalking文件夹
cd skywalking

2.1.4 直接启动Skywalking服务(默认单机模式)

bin/startup.sh
#运行结果
SkyWalking OAP started successfully!
SkyWalking Web Application started successfully!
#查看运行结果
JPS
#结果
11569 skywalking-webapp.jar
11668 Jps
11549 OAPServerStartUp

2.1.5 访问Skywalking管理端页面

http://ip:8080

2.2 Skywalking服务端Docker安装

准备docker-compose文件

version: "3.1"
services:  
  skywalking-oap:
    image: apache/skywalking-oap-server:8.9.1
    container_name: skywalking-oap
    restart: always
    volumes:
      - ./skywalking/alarm-settings.yml:/skywalking/config/alarm-settings.yml
      - ./skywalking/application.yml:/skywalking/config/application.yml
      - ./skywalking/service-apdex-threshold.yml:/skywalking/config/service-apdex-threshold.yml
      - ./skywalking/libs:/skywalking/ext-libs
    environment:
      - TZ=Asia/Shanghai
      - JAVA_OPTS=-Xms2048m -Xmx2048m
    ports:
      - 11800:11800
      - 12800:12800
  skywalking-ui:
    image: apache/skywalking-ui:8.9.1
    container_name: skywalking-ui
    restart: always
    ports:
      - 8080:8080
    environment:
      - SW_OAP_ADDRESS=http://skywalking-oap:12800

2.3 微服务整合Skywalking

2.3.1 下载java-agent(Java探针)

2.3.2 将探针解压，放入工程中(或任意位置都可以)

2.3.3 修改agent配置文件

2.3.4 修改微服务的启动VM option

-javaagent:./agent/skywalkingagent.jar

-Dskywalking.agent.service_name=qphone-student

三. Java Agent配置

3.1 Java Agent配置属性详解

示例：设置Skywalking采样率

配置属性:agent.sample_n_per_3_secs=${SW_AGENT_SAMPLE:-1}

-1 表示全部采样，改为大于0的数即可

示例：设置数据库采集SQL执行参数

配置属性：plugin.jdbc.trace_sql_parameters=${SW_JDBC_TRACE_SQL_PARAMETERS:false}该属性设置为true即可，配套属性还有：

plugin.jdbc.sql_parameters_max_length=${SW_PLUGIN_JDBC_SQL_PARAMETERS_MAX_LENGTH:512}

3.2 Java Agent配置方式

3.2.1 直接修改配置文件

3.2.2 在服务VM 启动参数项中配置

-Dskywalking.配置名称=配置的值

 //或者 

-javaagent:agent路径/skywalking-agent.jar=[配置名称]=[配置的值],[配置名称2]=[配置的值2]

3.2.3 系统环境变量

#例如这样的配置，表示会去读取SW_AGENT_NAME的环境变量，如果没有再去获取:后面的值 agent.service_name=${SW_AGENT_NAME:Your_ApplicationName}

3.3 Java Agent相关插件介绍

相关插件介绍

四. Skywalking仪表盘

Skywalking最主要的功能就是APM，监控维度与指标都非常丰富，为了让大家能更好的掌握Skywalkig的使用，接下来侯哥就把Skywalking的每个指标都给大家进行详细地解释。

4.1 APM参数详解

APM（Application Performance Monitor） -应用性能监视器

Global - 全局指标

Service - 当前服务指标

Instance - 当前服务实例指标

Endpoint - 端点（接口）指标

4.2 Database参数详解

4.3 什么是Apdex?

Apdex是衡量一个服务器性能的指标，这个值越高越好，满分为1。Apdex有三个指标：

• 正常：服务请求的响应时间 <= T

• 可容忍：T < 服务请求响应时间 <= 4T

• 慢调用：服务请求响应时间 > 4T

• T是自定义的一个响应阈值，比如500ms

Apdex = （正常请求数 + 可容忍请求数 / 2）/ 请求总数。示例如下：

服务A定义T=200ms，在100个采样中，有20个请求小于200ms，有60个请求在200ms到800ms之间，有20个请求大于800ms。计算apdex = (20 + 60/2)/100 = 0.5。

4.4 Skywalking自定义T

#配置文件config/service-apdex-threshold.yml
# default threshold is 500ms
default: 500
# example:
# the threshold of service "tomcat" is 1s
# tomcat: 1000
# the threshold of service "springboot1" is 50ms
# springboot1: 50

五. Skywalking拓扑图

六. Skywalking追踪

6.1 追踪面板参数详解

6.2 在代码中获取当前业务请求的TraceId

6.2.1 添加依赖

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

6.2.2 在代码上标记@Trace注解

@RequestMapping("/getById")
@Trace//在需要获取TraceId的代码上添加该注解
public R getById(Integer sId){
    .....
}

6.2.3 在代码中获取TraceId

...
//获取全局追踪Id
String traceId = TraceContext.traceId();   
...

6.3 Skywalking整合Log4j2在日志中打印TraceId

6.3.1 添加依赖

<dependency>
    <groupId>org.apache.skywalking</groupId>
    <artifactId>apm-toolkit-log4j-2.x</artifactId>
    <version>8.9.0</version>
</dependency>

6.3.2 在log4j2的配置文件中获得TraceId

1. 通过 -[%traceId]- 标签可获取全局TraceId 

2. 示例：%date{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} [%traceId] - %msg%n

七. Skywalking性能剖析

性能剖析主要的工作就是对不同的端点进行采样，然后提供一个更加详细的分析结果。

7.1 使用示例

7.1.1 先随机在业务代码中设置一个睡眠时间，模拟慢请求

7.1.2 在Skywalking控制台创建监控任务

7.1.3 给相应的端点发送请求，然后控制台查看监控结果

注意：

• 一个服务在监控持续时间内只能设置一个端点监控任务

• 剖析端点的响应时间必须大于监控间隔时间，如果响应时间小于监控间隔时间，则无法进行采集

八. Skywalking日志采集（Log4j2版）

Skywalking支持微服务间运行日志上传到Skywalking端，进行日志相关管理，并且可以将日志和相关服务节点关联起来。

8.1 配置方式

8.1.1 微服务添加依赖（同Log4j2获取TraceId的依赖）

<dependency>
    <groupId>org.apache.skywalking</groupId>
    <artifactId>apm-toolkit-log4j-2.x</artifactId>
    <version>8.9.0</version>
</dependency>

8.1.2 配置Log4j2输出器

<appenders>
  ......  
    
  
  <GRPCLogClientAppender name="SkywalkingLog">
    <ThresholdFilter level="debug" onMatch="ACCEPT" onMismatch="DENY"/>
    <PatternLayout pattern="${LOG_PATTERN}"/>
  </GRPCLogClientAppender>
</appenders>
<loggers>
    
    <root level="info">
      ......
      <appender-ref ref="SkywalkingLog"/>
    </root>
</loggers>

8.1.3 启动微服务，发送请求，查看Skywalking日志面板

九. Skywalking告警

Skywalking可以对指定参数设置阈值，当超过阈值时，就会触发告警，及时通知开发人员

9.1 告警配置方式

9.1.1 定义告警规则

Skywalking-OAP端 config/alarm-settings.yml

#配置告警规则
rule:
  #服务自带的告警规则
  ...
  #自定义告警规则
  #规则名称，必须全局唯一，并且以"_rule"结尾
  xxxxxx_rule:
    #告警的指标名称，具体值可以参考下图
    metrics-name: endpoint_sla
    #[可选] 指定告警的服务
    include-names:
      - serviceA
      - serviceB
    #[可选] 排除的服务将不触发告警  
    exclude-names:
      - serviceC
    #[可选] 匹配微服务的名称， 通过正则表达式  
    include-names-regex: instance\_\d+
    #阈值，对于不同的指标类型，可以设置不用类型的值，目前支持long, double or int  
    threshold: 9000  
    #操作符
    op: "<"
    #时间窗口长度，单位时间内，指标异常就会触发告警 （单位是分钟）
    period: 2
    #累计数量，指标符合告警条件达到累计数量后，才会触发告警
    count: 3
    #静默时间，当发生告警后，多长时间不再告警，默认和period值保持一致
    silence-period: 10
    #告警内容，触发告警时，显示的消息内容 {name} 表示告警的服务名称
    message: Successful rate of service {name} is lower than 90% in 2 minutes of last 10 minutes

9.1.2 重启Skywalking服务即可

9.2 动态配置告警

动态配置就是将相关配置信息，放入配置中心（比如nacos），然后修改nacos的配置，在无需重启skywalking服务的情况下达到刷新配置的目的

9.2.1 Skywalking支持动态配置的配置项

• 告警相关配置，会覆盖alarm-settings.yml配置内容

• apdex阈值相关配置，会覆盖service-apdex-threshold.yml配置内容

9.2.2 基于nacos实现动态配置

1）安装nacos服务器

2）修改Skywalking配置文件 - config/application.yml

428 configuration:
429   selector: ${SW_CONFIGURATION:nacos} #该选项改为nacos
430   none:
.....
#配置好nacos的相关属性
467   nacos:
468     # Nacos Server Host
469     serverAddr: ${SW_CONFIG_NACOS_SERVER_ADDR:nacos}
470     # Nacos Server Port
471     port: ${SW_CONFIG_NACOS_SERVER_PORT:8848}
472     # Nacos Configuration Group
473     group: ${SW_CONFIG_NACOS_SERVER_GROUP:skywalking}
474     # Nacos Configuration namespace
475     namespace: ${SW_CONFIG_NACOS_SERVER_NAMESPACE:skywalking}
476     # Unit seconds, sync period. Default fetch every 60 seconds.
477     period: ${SW_CONFIG_NACOS_PERIOD:60}
478     # Nacos auth username
479     username: ${SW_CONFIG_NACOS_USERNAME:"nacos"}
480     password: ${SW_CONFIG_NACOS_PASSWORD:"nacos"}
481     # Nacos auth accessKey
482     accessKey: ${SW_CONFIG_NACOS_ACCESSKEY:""}
483     secretKey: ${SW_CONFIG_NACOS_SECRETKEY:""}

3）在nacos上创建配置信息

注意：配置的dataId必须为 - alarm.default.alarm-settings

9.3 告警通知

Skywalking并没有提供告警通知的功能（发短信、发邮件等方式），但是提供了一个webhook（网络钩子），开发者可以通过webhook自定义通知接口，然后再自己实现告警通知的方式

9.3.1 配置webhook

webhooks: 

- 通知接收地址

9.3.2 接收告警消息

自定义的webhook接口将接收到类似如下的消息，只需要解析并且按照自己的需求发送即可

[
 {
    "scopeId": 1,
    "scope": "SERVICE",
    "name": "qphone-gateway",
    "id0": "cXBob25lLWdhdGV3YXk\u003d.1",
    "id1": "",
    "ruleName": "service_sla_rule",
    "alarmMessage": "警告,服务qphone-gateway处于响应请求过慢!",
    "tags": [],
    "startTime": 1655046016465
 },
 ...... 
]

十. Skywalking数据持久化

Skywalking数据持久化的方式比较多，常见的有基于mysql和es的方式，这里我们选择mysql的方式持久化数据

10.1 基于Mysql配置Skywalking数据持久化

10.1.1 修改配置文件config/application.yml

storage:
  selector: ${SW_STORAGE:mysql} #修改配置存储方式为mysql
...
  #配置mysql的相关属性
  mysql:
    properties:
      jdbcUrl: ${SW_JDBC_URL:"jdbc:mysql://mysql:3306/skywalking?useUnicode=true&characterEncoding=utf8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=GMT%2b8&useSSL=true&allowMultiQueries=true&autoReconnect=true&nullCatalogMeansCurrent=true&nullCatalogMeansCurrent=true"}
      dataSource.user: ${SW_DATA_SOURCE_USER:root}
      dataSource.password: ${SW_DATA_SOURCE_PASSWORD:root}
      dataSource.cachePrepStmts: ${SW_DATA_SOURCE_CACHE_PREP_STMTS:true}
      dataSource.prepStmtCacheSize: ${SW_DATA_SOURCE_PREP_STMT_CACHE_SQL_SIZE:250}
      dataSource.prepStmtCacheSqlLimit: ${SW_DATA_SOURCE_PREP_STMT_CACHE_SQL_LIMIT:2048}
      dataSource.useServerPrepStmts: ${SW_DATA_SOURCE_USE_SERVER_PREP_STMTS:true}
    metadataQueryMaxSize: ${SW_STORAGE_MYSQL_QUERY_MAX_SIZE:5000}
    maxSizeOfArrayColumn: ${SW_STORAGE_MAX_SIZE_OF_ARRAY_COLUMN:20}
    numOfSearchableValuesPerTag: ${SW_STORAGE_NUM_OF_SEARCHABLE_VALUES_PER_TAG:2}
    maxSizeOfBatchSql: ${SW_STORAGE_MAX_SIZE_OF_BATCH_SQL:2000}
    asyncBatchPersistentPoolSize: ${SW_STORAGE_ASYNC_BATCH_PERSISTENT_POOL_SIZE:4}

10.1.2 提前在数据库中创建好skywalking库

create database skywalking;

10.1.3 在Skywalking-oap服务下放入mysql驱动包

10.1.4 重启skywalking服务，查看数据库是否自动创建相关表

十一. 结语

Skywalking是一款很好的APM服务，希望通过这篇使用指南，能让大家更好地掌握学习Skywalking的服务运用。大家记得一定要自己上手实操，才能真正的掌握Skywalking的魅力哦。