微服务链路追踪组件 SkyWalking

skywalking 是一个国产开源框架，2015年开源，2017年加入 Apache 孵化器。skywalking 是分布式系统的应用程序性能监视工具，转为微服务、云原生架构和基于容器（Docker、k8s、Mesos）架构而设计的。它是一款优秀的 APM（Application Performance Management）工具，包括了分布式追踪、性能指标分析、应用和服务依赖分析等Copy

vim webapp/webapp.yml

server:
  port: 8868Copy

$ bash startup.sh 
SkyWalking OAP started successfully!
SkyWalking Web Application started successfully!Copy

logs/
├── oap.log
├── skywalking-oap-server.log
└── webapp-console.logCopy

#! /bin/bash
# SkyWalking Agent 配置
# Agent 名字，一般使用`spring.application.name`
export SW_AGENT_NAME=springboot-skywalking-demo
# 配置 Collector 地址
export SW_AGENT_COLLECTOR_BACKEND_SERVICERS=127.0.0.1:11800
export JAVA_AGENT=-javaagent:skywalking-agent.java 地址
# jar 启动
java $JAVA_AGENT -jar spring-boot-skywalking-demo.jarCopy

java -javaagent:skywalking-agent.jar 地址 -DSW_AGENT_COLLECTOR_BACKEND_SERVICERS=127.0.0.1:11800 -DSW_AGENT_NAME=springboot-skywalking-demo -jar spring-boot-skywalking-demo.jarCopy

# The service name in UI
agent.service_name=${SW_AGENT_NAME:Your_ApplicationName}
# Backend service addresses
collector.backend_sercvice=${SW_AGENT_COLLECTOR_BACKEND_SERVICES:127.0.0.1:11800}Copy

# 指定 agent.jar 所在位置
-javaagent:/Users/hudu/Environment/skywalking/skywalking-agent/skywalking-agent.jar
# 指定服务名字
-DSW_AGENT_NAME=服务名称
# 指定 skywalking 的 collector 服务的 IP 及端口
-DSW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800Copy

-javaagent:/Users/hudu/Environment/skywalking/skywalking-agent/skywalking-agent.jar
-DSW_AGENT_NAME=服务名称
-DSW_AGENT_COLLECTOR_BACKEND_SERVICES=127.0.0.1:11800Copy

storage:
  selector: ${SW_STORAGE:mysql}
  mysql:
    properties:
    jdbcUrl: ${SW_JDBC_URL:"jdbc:mysql://localhost:3306/swtest?rewriteBatchedStatements=true"}
    dataSource.user: ${SW_DATA_SOURCE_USER:root}
    dataSource.password: ${SW_DATA_SOURCE_PASSWORD:root@1234}Copy

<!--SkyWalking 工具类-->
<dependency>
  <groupId>org.apache.skywalking</groupId>
 <artifactId>apm-toolkit-trace</artifactId>
 <version>8.11.0</version>
</dependency>Copy

@GetMapping("/get/{id}")
@Trace
@Tags({@Tag(key="result",value = "returnedObj"),
  @Tag(key="param",value = "arg[0]")})
public Order get(@PathVariable Integer id) {
  return orderService.get(id);
}Copy

<!--配置-->
<dependency>
  <groupId>org.apache.skywalking</groupId>
 <artifactId>apm-toolkit-logback-1.x</artifactId>
 <version>8.11.0</version>
</dependency>Copy

<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <include resource="org/springframework/boot/logging/logback/defaults.xml"/>

    <!-- 控制台输出 -->
    <appender name="console" 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.TraceIdPatternLogbackLayout">
                <Pattern>${CONSOLE_LOG_PATTERN}</Pattern>
            </layout>
        </encoder>
    </appender>
    <root level="INFO">
        <appender-ref ref="console" />
    </root>
</configuration>Copy

<!--日志配置-->
<appender name="grpc-log" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
  <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
  <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
  <Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%X{tid}] [%thread] %-5level %logger{36} -%msg%n</Pattern>
  </layout>
  </encoder>
</appender>

<root level="INFO">
  <appender-ref ref="console" />
 <appender-ref ref="grpc-log" />
</root>Copy

plugin.toolkit.log.grpc.reporter.server_host=$[SW_GRPC_LOG_SERVER_HOST:192.168.33.62]
plugin.toolkit.log.grpc.reporter.server_port=$[SW_GRPC_LOG_ SERVER_PORT:11800]
plugin.toolkit.log.grpc.reporter.max_message_size=$[SW_GRPC_LOG_MAX_MESSAGE_SIZE:10485760]
plugin.toolkit.log.grpc.reporter.upstream_timeout=$[SW_GRPC_LOG_GRPC_UPSTREAM_TIMEOUT:30]Copy

rules:
  # Rule unique name, must be ended with `_rule`.
  service_resp_time_rule:
    metrics-name: service_resp_time
    op: ">"
    threshold: 1000
    period: 10
    count: 3
    silence-period: 5
    message: Response time of service {name} is more than 1000ms in 3 minutes of last 10 minutes.Copy

[{
  "scopeId": 1, 
  "scope": "SERVICE",
  "name": "serviceA", 
  "id0": "12",  
  "id1": "",  
    "ruleName": "service_resp_time_rule",
  "alarmMessage": "alarmMessage xxxx",
  "startTime": 1560524171000,
    "tags": [{
        "key": "level",
        "value": "WARNING"
     }]
}, {
  "scopeId": 1,
  "scope": "SERVICE",
  "name": "serviceB",
  "id0": "23",
  "id1": "",
    "ruleName": "service_resp_time_rule",
  "alarmMessage": "alarmMessage yyy",
  "startTime": 1560524171000,
    "tags": [{
        "key": "level",
        "value": "CRITICAL"
    }]
}]Copy

webhooks:
  - http://127.0.0.1:8088/alarm/notifyCopy

import lombok.Data;
//import org.apache.skywalking.oap.server.core.analysis.manual.searchtag.Tag;

import java.util.List;

@Data
public class SwAlarmMessage {
    private int scopeId;
    private String scope;
    private String name;
    private String id0;
    private String id1;
    private String ruleName;
    private String alarmMessage;
    private List<Tag> tags;
    private long startTime;
    private transient int period;
    private transient boolean onlyAsCondition;

    @Data
    public static class Tag {
        private String key;
        private String value;
    }
}
Copy

@RestController
@RequiredArgsConstructor
@RequestMapping("/alarm")
public class SwAlarmController {

    Logger log = LoggerFactory.getLogger(this.getClass());

    /**
     * 接收Skywalking服务的告警通知并发送至邮箱
     * 必须是post请求
     * @param alarmList
     */
    @PostMapping("/notify")
    public void receive(@RequestBody List<SwAlarmMessage> alarmList){
//        SimpleMailMessage mailMessage = new SimpleMailMessage();
//        // 发送者邮箱
//        mailMessage.setFrom("from");
//        // 接收者邮箱
//        mailMessage.setTo("to");
//        // 主题
//        mailMessage.setSubject("主题");
//        // 邮件内容
//        String content = getContent(alarmList);
//        mailMessage.setText("content");
//        sender.send(mailMessage);

        String content = getContent(alarmList);
        log.info("告警邮箱已发送..."+content);

    }

    private String getContent(List<SwAlarmMessage> alarmList){
        StringBuilder sb = new StringBuilder();
        alarmList.forEach(message -> sb.append("scopeId: ").append(message.getScopeId())
                .append("\nscope: ").append(message.getScope())
                .append("\n目标 Scope 的实体类名称: ").append(message.getName())
                .append("\nScope 实体类的 ID: ").append(message.getId0())
                .append("\nid1: ").append(message.getId1())
                .append("\n告警规则名称: ").append(message.getRuleName())
                .append("\n告警消息内容: ").append(message.getAlarmMessage())
                .append("\n告警时间: ").append(message.getStartTime())
                .append("\n标签: ").append(message.getTags())
                .append("\n\n-----------------\n\n "));

        return sb.toString();
    }
}Copy

spring:
    gateway:
      # 路由规则
      routes:
        - id: alarm_route
          uri: lb://sw-alarm-server
          predicates:
            - Path=/alarm/**Copy

-DSW_AGENT_COLLECTOR_BACKEND_SERVICES=192.168.33.61:11800,192.168.33.62:11800Copy