《springcloud alibaba》六微服务链路跟踪skywalking

准备
- 调整配置
- 接入多个微服务
- - 网关项目调整
  - order-seata项目
  - stock-seata项目
  - 测试
- 接入网关微服务
skywalking持续化到mysql
自定义链路跟踪
- pom .xml
- orderController
- OrderService
- OrderDao
- OrderTblMapper.xml
- 测试
性能剖析
日志
- tid打印
- - pom.xml
  - logback-spring.xml
  - 日志收集
  - 启动项目

随着业务规模的不断的增大, 系统的复杂度也越来越高, 我们的软件架构也进入到了分布式的阶段, 服务按照不同的维度进入到了分布式的阶段, 服务按照不同的维度进行拆分, 每一次的请求可能跨越多个微服务, 这样就导致我们每一次请求都有可能出现异常. 传统的日志监控方式无法满足调用链路追踪, 这就导致定位/诊断服务异常变得异常复杂.

准备

下载
在这里插入图片描述

webapp: Ul 前端(web 监控页面)的jar 包和配置文件;
oap-libs: 后台应用的 jar 包，以及它的依赖 jar 包，里边有一个 server-starter-.jar 就是启动程序;
config: 启动后台应用程序的配置文件，是使用的各种配置
。bin: 各种启动脚本，一般使用脚本 startup.来启动 web 页面和对应的后台应用
。oapService.“:默认使用的后台程序的启动脚本;(使用的是默认模式启动，还支持其他模式，各模式区别见启动模式)。oapservicelnit.”:使用 init 模式启动;在此模式下，OAP服务器启动以执行初始化工作，然后退出oapServiceNolnit,:使用 no init模式启动;在此模式下，OAP服务器不进行初始化。
webappService.:Ul 前端的启动脚本:
。startup.:组合脚本，同时启动 oapService.:、webappService.* 脚本;
’agent:
。skywalking-agent.jar: 代理服务jar 包
config: 代理服务启动时使用的配置文件
。plugins:包含多个插件，代理服务启动时会加载改目录下的所有插件(实际是各种 jar 包)，比-SiringCloud Gateway，则需要把对应的 jar 包拷贝到 plugins

调整配置

在这里插入图片描述

修改webapp.yml

启动成功后会启动两个服务，一个是skywalking-oap·server，一个是skywalking-web·ui: 8868skywalking-oap-sen2服务启动后会暴露11800 和 12800 两个端口，分别为收集监控数据的端口11800和接受前端请求的端口12800，修改端口可以修改config/applicaiton.yml

接入多个微服务

输入localhost:8868,可以接入skywalking管理界面，
在这里插入图片描述

在这三个项目上改造

网关项目调整

在这里插入图片描述

改为order-seata项目的服务名

order-seata项目

下载客户端收集的jar

注意: 很多文章没有说明

idea启动调整

-javaagent:D:\system\apache-skywalking-java-agent-8.10.0\skywalking-agent/skywalking-agent.jar -Dskywalking.agent.service_name=OrderSeata -Dskywalking.collector.backend_service=127.0.0.1:11800

Dskywalking.agent.service_name 服务名
-Dskywalking.collector.backend_service 暴露的端口
-javaagent:D:\system\apache-skywalking-java-agent-8.10.0\skywalking-agent/skywalking-agent.jar 是上面解压后的路径

stock-seata项目

idea启动调整

-javaagent:D:\system\apache-skywalking-java-agent-8.10.0\skywalking-agent/skywalking-agent.jar -Dskywalking.agent.service_name=StockSeata -Dskywalking.collector.backend_service=127.0.0.1:11800

测试

记得启动nacos、seata、sentinel服务端
访问项目http://127.0.0.1:8088/order-service/order/add
在这里插入图片描述

到这里说明，skywalking集成微服务算成功咯

接入网关微服务

在这里插入图片描述

在网关上新增配置

-javaagent:D:\system\apache-skywalking-java-agent-8.10.0\skywalking-agent/skywalking-agent.jar -Dskywalking.agent.service_name=api-service -Dskywalking.collector.backend_service=127.0.0.1:11800

先访问http://127.0.0.1:8088/order-service/order/add接口
在这里插入图片描述

就显示了一个api-service得服务，但是对应的请求日志没有显示， why？什么情况
api-service这个服务我都是刷新几次后，才显示，估计是有延迟。

找到下载解压后agent包
在这里插入图片描述
移动到如下目录下
再重新启动我们在测试的三个项目

现在显示访问记录，gateway的一个小问题，需要这样特殊处理一下

skywalking持续化到mysql

默认使用h2存储，也就是所谓的存在内存中，服务重启后，记录就会丢失
在这里插入图片描述

在这里插入图片描述
修改成mysql

修改mysql的账号和密码，以及url地址

在这里插入图片描述

创建数据库，表会自动创建
D:\system\apache-skywalking-apm-9.0.0\apache-skywalking-apm-bin\bin
启动startup.bat，正常启动成功后，skywalking是有两个窗口的，但是这里启动后，会关闭skywalking-collector，说明这个服务报错咯

来到log日志查看原因
有没有看着很熟悉的感觉？
初步定位，感觉就是缺少mysql驱动导致的。

在这里插入图片描述

随机找一个幸运儿项目，找到mysql驱动
把对应的jar，放到该目录下面，重启bin
对应的数据库会自动创建很多的表
记得这三个项目也要重新启动，不然，不会加载到skywalking里面去

访问http://127.0.0.1:8088/order-service/order/add，出现请求路径。
这时，我们再重启一下服务，看看，数据是否存在，如果存在，则说明mysql持久化成功

自定义链路跟踪

在这里插入图片描述

在order-seata项目上，新增链路跟踪代码

pom .xml

  <!--skywalking自定义链路跟踪--><dependency><groupId>org.apache.skywalking</groupId><artifactId>apm-toolkit-trace</artifactId><version>9.0.0</version></dependency>

注意跟下载的skywalking版本一直，我下载的是9.0.0版本的，所以，写这个版本，不然，会有一些奇奇怪怪的问题

orderController

 /*** 获取id获取数据* @param id* @return*/@RequestMapping("/get")public OrderTbl get(Integer id){return  orderService.get(id);}

OrderService

package com.lcs.springcloud.service;import com.lcs.springcloud.dao.OrderDao;
import com.lcs.springcloud.entity.OrderTbl;
import org.apache.skywalking.apm.toolkit.trace.Tag;
import org.apache.skywalking.apm.toolkit.trace.Tags;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class OrderService {@AutowiredOrderDao orderDao;public void insert(OrderTbl orderTbl) {orderDao.insert(orderTbl);}/*** 获取id获取数据* @param id* @return*/@Trace@Tags({@Tag(key = "id", value = "arg[0]"),@Tag(key = "order", value = "returnedObj")})public OrderTbl get(Integer id) {return orderDao.get(id);}
}

OrderDao

package com.lcs.springcloud.dao;import com.lcs.springcloud.entity.OrderTbl;
import org.springframework.stereotype.Repository;@Repository
public interface OrderDao {void insert(OrderTbl orderTbl);/*** 根据id获取数据* @param id* @return*/OrderTbl get(Integer id);
}

OrderTblMapper.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.lcs.springcloud.dao.OrderDao"><!-- 主键自增长的插入 --><insert id="insert" parameterType="com.lcs.springcloud.entity.OrderTbl" useGeneratedKeys="true" keyProperty="id">insert into order_tbl(product_id,total_amount,statu) values(#{product_id},#{total_amount},#{statu});</insert><select id="get" resultType="com.lcs.springcloud.entity.OrderTbl">select * from order_tbl where id = #{id}</select>
</mapper>

测试

访问http://127.0.0.1:8088/order-service/order/get?id=12
在这里插入图片描述

id和order就是我们定义的名称，通过这里可以看到对应的传参以及返回值

性能剖析

controller的代码调整

    /*** 获取id获取数据* @param id* @return*/@RequestMapping("/get")public OrderTbl get(Integer id) throws InterruptedException {//延迟2秒TimeUnit.SECONDS.sleep(2);return  orderService.get(id);}

新增一个延迟2秒的代码，重新启动项目
trace 是看界面
profile 是分析
新建一个任务
奇葩问题，一直没有分析报告生成，搞不懂为什么
还没有删除的入口，服了

日志

tid打印

pom.xml

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

logback-spring.xml

<?xml version="1.0" encoding="UTF-8"?>
<configuration><!-- 日志输出格式 --><property name="FILE_LOG_PATTERN" value="[%d{yyyy-MM-dd HH:mm:ss.SSS}] %green(%-5level) [%thread] %yellow([%tid]) %cyan(%logger{50}) : %msg%n" /><appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"><!-- 默认日志打印的格式 --><!--<encoder><pattern>${CONSOLE_LOG_PATTERN}</pattern><charset>utf-8</charset></encoder>--><!-- 配置了skywalking的traceId的日志打印的格式 --><encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder"><layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout"><Pattern>${FILE_LOG_PATTERN}</Pattern></layout></encoder></appender><!-- 异步输出 控制台 --><appender name="ASYNC_STDOUT" class="ch.qos.logback.classic.AsyncAppender"><discardingThreshold>0</discardingThreshold><queueSize>256</queueSize><appender-ref ref="STDOUT"/></appender><root level="info"><appender-ref ref="ASYNC_STDOUT"/></root>
</configuration>

配置logback并在日志中打印traceId，在日志输出格式中添加%tid即可
启动项目

日志收集

最后配置日志收集，需要在logback的配置文件中再添加一个appender

<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true" scanPeriod=" 5 seconds"><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>%d{yyyy-MM-dd HH:mm:ss.SSS} [%X{tid}] [%thread] %-5level %logger{36} -%msg%n</Pattern></layout></encoder></appender><appender name="ASYNC" class="ch.qos.logback.classic.AsyncAppender"><discardingThreshold>0</discardingThreshold><queueSize>1024</queueSize><neverBlock>true</neverBlock><appender-ref ref="STDOUT"/></appender><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="grpc-log" /><appender-ref ref="ASYNC"/></root>
</configuration>

启动项目

在这里插入图片描述

-javaagent:D:\system\apache-skywalking-java-agent-9.0.0\skywalking-agent/skywalking-agent.jar -Dskywalking.agent.service_name=OrderSeata -Dskywalking.collector.backend_service=127.0.0.1:11800