当前位置： 首页 > news >正文

【SkyWalking】分布式服务追踪与调用链系统

news 2025/8/12 9:41:33

1、基本介绍

SkyWalking是一个开源的观测平台，官网：Apache SkyWalking；

可监控：分布式追踪调用链 、jvm内存变化、监控报警、查看服务器基本配置信息。

2、SkyWalking架构原理

在整个skywalking的系统中，有三个角色：
1.skywalking agent 和业务系统(jar)关联在一起，负责收集各种监控数据；
2.skywalking oapservice负责处理监控数据，比如接受skywalking agent的监控数据，并存储在数据库中（例如elasticsearch、mysql中等）;接受skywalking webapp的前端请求，从数据库查询数据，并返回数据给前端。，Skywalking oapservice通常以集群的形式存在；
3.skywalking webapp 前端界面，用于展示数据。

2.1、skywalking 底层原理流程

1.springboot项目启动的时候 是不需要引入任何的jar包，

2.启动springboot项目时被skywalking skywalking-agent.jar 代理拦截，

        -- agent代理拦截是jdk提供的一种技术；可以使启动jar包时不需要引入任何依赖，agent就可以对java程序做业务增强，类似AOP技术，但是比AOP级别更高，agent属于监控整个java进程。

3.将rpc请求数据 发送给我们的skywalking oapservice接口项目，

4.连接到我们的skywalking webapp项目展示数据，

5.数据最终是可以持久化存放在 db或者es中。

        -- SkyWalking 默认是将数据存入在内存中，如果重启SkyWalking 数据则都会丢失。

3、skywalking 环境安装

1. 下载apache-skywalking-apm-6.5.0.tar安装包，下载链接：百度网盘 skywalking.tar  

1.1. 下载数据库链接：百度网盘 mysql-connector-java-8.0.16.jar  后续做数据持久化会用到。

2. 进入到bin目录（Windows直接双击启动startup.bat / Linix则执行startup.sh）

    注：启动startup.bat = 同时启动oapService.bat 和 webappService.bat

3. 查看webapp管理界面 http://127.0.0.1:8080

4、skywalking-agent监控springboot.jar包

1. 创建一个springboot项目，并打成jar包

2. 启动springboot.jar包时指定agent目录下的skywalking-agent.jar，注意skywalking-agent.jar要写绝对路径

启动jar包命令： java -javaagent:skywalking-agent.jar -jar springboot.jar

 启动jar包命令，同时设置服务名称为server-member： 

java -javaagent:skywalking-agent.jar 

-Dskywalking.agent.service_name=server-member  -jar springboot.jar

4、测试访问几次接口，然后去SkyWalking控制台 http://127.0.0.1:8080/ 查看效果。

4.1、如何在IDEA中使用skywalking

IDEA启动配置：

-javaagent:D:\java\dev-tool\skywalking\apache-skywalking-apm-6.5.0\apache-skywalking-apm-bin\agent\skywalking-agent.jar
-Dskywalking.agent.service_name=server-member
-Dskywalking.collector.backend_service=127.0.0.1:11800

IDEA启动服务后，调用接口，然后进入WEB页面查看效果：

5、SkyWalking获取全局追踪id

  1.         <dependency>
  2.             <groupId>org.apache.skywalking</groupId>
  3.             <artifactId>apm-toolkit-trace</artifactId>
  4.             <version>6.5.0</version>
  5.         </dependency>

获取 TraceContext.traceId();

  1.  
  2.     @RequestMapping("/member")
  3.     public String orderToMember(@RequestParam("id") Integer id) {
  4.         // 获取request对象
  5.         HttpServletRequest request = ((ServletRequestAttributes)
  6. RequestContextHolder.getRequestAttributes()).getRequest();
  7. getHeders(request);
  8.         // 获取traceId
  9.         String traceId = TraceContext.traceId();
  10. log.info(">>traceId:{}<<", traceId);
  11.         Integer j = 1 / id;
  12.         return "我是会员服务:" + traceId + "," + j;
  13. }
  14.  
  15.     public static void getHeders(HttpServletRequest request) {
  16.         //2.获得所有头的名称
  17. Enumeration<String> headerNames = request.getHeaderNames();
  18.         while (headerNames.hasMoreElements()) {//判断是否还有下一个元素
  19.             String nextElement = headerNames.nextElement();//获取headerNames集合中的请求头
  20.             String header2 = request.getHeader(nextElement);//通过请求头得到请求内容
  21. log.info("请求头=========={}" + nextElement + "VALUE:" + header2);
  22.             //System.out.println(nextElement+":"+header2);
  23. }
  24. }

6、SkyWalking告警功能

SkyWalking 告警功能是在6.x版本新增的，其核心由一组规则驱动，这些规则定义在SkyWalking目录的config/alarm-settings.yml文件中。

SkyWalking告警后会调用开发者自己定义的接口，

注：自定义的接口地址配置到alarm-settings.yml的webhooks下，当SkyWalking产生告警后会调用webhooks下的URL地址传入告警信息；

alarm-settings.yml文件预先定义了一些常用的告警规则。如下：

1.过去3分钟内服务平均响应时间超过1秒

2.服务成功率在过去2分钟内低于80%

3.服务90%响应时间在过去3分钟内低于1000毫秒

4.服务实例在过去2分钟内的平均响应时间超过1秒

5.端点平均响应时间过去2分钟超过1秒

6.1、自定义告警接口接收数据格式

  1. [{
  2.     "scopeId": 1,
  3.     "scope": "SERVICE",
  4.     "name": "serviceA",
  5.     "id0": 12,
  6.     "id1": 0,
  7.     "ruleName": "service_resp_time_rule",
  8.     "alarmMessage": "alarmMessage xxxx",
  9.     "startTime": 1560524171000
  10. }, {
  11.     "scopeId": 1,
  12.     "scope": "SERVICE",
  13.     "name": "serviceB",
  14.     "id0": 23,
  15.     "id1": 0,
  16.     "ruleName": "service_resp_time_rule",
  17.     "alarmMessage": "alarmMessage yyy",
  18.     "startTime": 1560524171000
  19. }]

scopeId、scope：所有可用的 Scope 详见

org.apache.skywalking.oap.server.core.source.DefaultScopeDefine

name：目标 Scope 的实体名称

id0：Scope 实体的 ID

id1：保留字段，目前暂未使用

ruleName：告警规则名称

alarmMessage：告警消息内容

startTime：告警时间，格式为时间戳

6.2、 编写告警接口

6.2.1、封装报警参数的对象

  1. /**
  2.  * 封装报警参数的对象
  3.  */
  4.  
  5. public class AlarmMessageDto {
  6.     private int scopeId;
  7.     private String name;
  8.     private int id0;
  9.     private int id1;
  10.     private String alarmMessage;
  11.     private long startTime;
  12.  
  13.     public int getScopeId() {
  14.         return scopeId;
  15. }
  16.  
  17.     public String getName() {
  18.         return name;
  19. }
  20.  
  21.     public int getId0() {
  22.         return id0;
  23. }
  24.  
  25.     public int getId1() {
  26.         return id1;
  27. }
  28.  
  29.     public String getAlarmMessage() {
  30.         return alarmMessage;
  31. }
  32.  
  33.     public long getStartTime() {
  34.         return startTime;
  35. }
  36.  
  37.     public void setScopeId(int scopeId) {
  38.         this.scopeId = scopeId;
  39. }
  40.  
  41.     public void setName(String name) {
  42.         this.name = name;
  43. }
  44.  
  45.     public void setId0(int id0) {
  46.         this.id0 = id0;
  47. }
  48.  
  49.     public void setId1(int id1) {
  50.         this.id1 = id1;
  51. }
  52.  
  53.     public void setAlarmMessage(String alarmMessage) {
  54.         this.alarmMessage = alarmMessage;
  55. }
  56.  
  57.     public void setStartTime(long startTime) {
  58.         this.startTime = startTime;
  59. }
  60. }

6.2.2、提供报警接口

  1. import com.mayikt.entity.AlarmMessageDto;
  2. import org.springframework.web.bind.annotation.RequestBody;
  3. import org.springframework.web.bind.annotation.RequestMapping;
  4. import org.springframework.web.bind.annotation.RequestMethod;
  5. import org.springframework.web.bind.annotation.RestController;
  6.  
  7. import java.util.ArrayList;
  8. import java.util.List;
  9.  
  10. /**
  11.  * 报警接口
  12.  */
  13. @RestController
  14. public class PoliceService {
  15.  
  16.     private List<List<AlarmMessageDto>> listAlarmMessage = new ArrayList<>();
  17.  
  18.     /**
  19.      * 接收告警信息
  20.      *
  21.      * @param alarmMessageList
  22.      */
  23.     @RequestMapping(value = "/police", method = RequestMethod.POST)
  24.     public void alarm(@RequestBody List<AlarmMessageDto> alarmMessageList) {
  25. listAlarmMessage.add(alarmMessageList);
  26. }
  27.  
  28.     /**
  29.      * 打印告警信息
  30.      *
  31.      * @return
  32.      */
  33.     @RequestMapping("/getListAlarmMessageDto")
  34.     public List<List<AlarmMessageDto>> getListAlarmMessageDto() {
  35.         return listAlarmMessage;
  36. }
  37.  
  38. }

7、SkyWalking数据持久化

SkyWalking 默认是将数据存入在内存中，如果重启SkyWalking 数据则都会丢失。

我们可以选择将数据持久化存放在mysql、es中等。

1、打开SkyWalking目录config/application.yml，在里边配置Mysql的连接信息；

  1. storage:
  2. selector: ${SW_STORAGE:mysql} #默认使用的H2数据库存储,将h2改为mysql
  3. mysql: #修改mysql连接 IP端口号，数据库
  4. properties:
  5. jdbcUrl: ${SW_JDBC_URL:"jdbc:mysql://localhost:3306/swtest?serverTimezone=UTC&characterEncoding=utf-8"}
  6. dataSource.user: ${SW_DATA_SOURCE_USER:root}
  7. dataSource.password: ${SW_DATA_SOURCE_PASSWORD:root@1234}
  8. dataSource.cachePrepStmts: ${SW_DATA_SOURCE_CACHE_PREP_STMTS:true}
  9. dataSource.prepStmtCacheSize: ${SW_DATA_SOURCE_PREP_STMT_CACHE_SQL_SIZE:250}
  10. dataSource.prepStmtCacheSqlLimit: ${SW_DATA_SOURCE_PREP_STMT_CACHE_SQL_LIMIT:2048}
  11. dataSource.useServerPrepStmts: ${SW_DATA_SOURCE_USE_SERVER_PREP_STMTS:true}
  12. metadataQueryMaxSize: ${SW_STORAGE_MYSQL_QUERY_MAX_SIZE:5000}

2、在oap-libs/目录中放入 mysql-connector-java-8.0.16.jar 

百度网盘 点击下载

3、重启SkyWalking，会自动在配置的Mysql库中创建依赖的表结构。

 

http://www.lryc.cn/news/136999.html

相关文章：

  • Python“牵手”速卖通商品详情API接口运用场景及功能介绍
  • java调用python脚本的示例
  • 【C语言】柔性数组（可边长数组）
  • C++信息学奥赛1131：基因相关性
  • 如何保证分布式系统中服务的高可用性：应对 ZooKeeper Leader 节点故障的注册处理策略
  • SQL注入之延时注入
  • 运维高级学习--Docker（二）
  • QT的核心——信号与槽
  • 【业务功能篇73】web系统架构演变-单体-集群-垂直化-服务化-微服务化
  • MyCAT命令行监控
  • 【python】正则表达式匹配数据
  • 【C++】用Windows API在控制台实现选择选项
  • Golang 批量执行/并发执行
  • 使用go语言、Python脚本搭建一个简单的chatgpt服务网站。
  • 基于java会议室预约系统设计与实现
  • Ubuntu18.04 交叉编译curl-7.61.0
  • Android相机-HAL子系统
  • PostgreSQL-研究学习-介绍与安装
  • 【Unity细节】Unity制作汽车时，为什么汽车会被弹飞？为什么汽车会一直抖动？
  • Android初学之android studio运行java/kotlin程序
  • 使用自定义 C ++类扩展 TorchScript
  • UITableView自定义TableHeader和TableFooter
  • 【TA 挖坑03】雾效 | 透光材质 | Impostor | 厚度转球谐
  • 案例-基于MVC和三层架构实现商品表的增删改查
  • Java——一个简单的计算器程序
  • 自定义滑动到底部触发指令，elementUI实现分页下拉框
  • 【Windows 常用工具系列 10 -- linux ssh登录脚本输入密码】
  • C#的索引器
  • 软件配置安装（破解）--- maven下载配置
  • python解析小说