10分钟快速开始SkyWalking结合Springboot项目

10分钟快速开始SkyWalking结合Springboot项目

实习期间，公司让我去学习一下链路追踪如何集成到Springboot项目中。
为此有两个方案：
1.opentelementry+jaeger+prometheus
opentelementry 收集器收集线上的metrics和traces，然后发送给jaeger和prometheus去处理。jaeger确实好很多，在一个controller中用多线程调用另一个controller依然能显示一颗完整的调用过程。但是可视化做的不行，需要依赖于grafana。这就导致需要开很多服务，因此不太容易搭建。
2.SkyWalking+elasticsearch
skywalking集成了收集和分析的功能，所以只需要elasticsearch作为存储就行，简单，可视化好，适用于个人和中小公司使用。

依赖配置

		<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.2.0.RELEASE</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><version>2.2.0.RELEASE</version><exclusions><exclusion><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-logging</artifactId></exclusion></exclusions></dependency><dependency> <!-- 引入log4j2依赖 --><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-log4j2</artifactId><version>2.2.0.RELEASE</version></dependency><dependency><groupId>org.apache.skywalking</groupId><artifactId>apm-toolkit-log4j-2.x</artifactId><version>9.1.0</version></dependency><dependency><groupId>org.apache.skywalking</groupId><artifactId>apm-toolkit-trace</artifactId><version>9.1.0</version></dependency>

这边需要排除掉springboot自带的日志框架，很重要

Dockerfile文件编写

version: '3.3'
services:elasticsearch:image: elasticsearch:7.17.6container_name: elasticsearchrestart: alwaysports:- "9201:9200"environment:- "TAKE_FILE_OWNERSHIP=true" #volumes 挂载权限 如果不想要挂载es文件改配置可以删除- "discovery.type=single-node" #单机模式启动- "TZ=Asia/Shanghai" # 设置时区- "ES_JAVA_OPTS=-Xms512m -Xmx512m" # 设置jvm内存大小volumes:- ./elasticsearch/logs:/usr/share/elasticsearch/logs- ./elasticsearch/data:/usr/share/elasticsearch/data#- ./elasticsearch/conf/elasticsearch.yml:/usr/share/elasticsearch/config/elasticsearch.ymlulimits:memlock:soft: -1hard: -1skywalking-oap-server:image: apache/skywalking-oap-server:8.9.1container_name: skywalking-oap-serverdepends_on:- elasticsearchlinks:- elasticsearchrestart: alwaysports:- "11800:11800"- "12800:12800"environment:SW_STORAGE: elasticsearch  # 指定ES版本SW_STORAGE_ES_CLUSTER_NODES: elasticsearch:9200TZ: Asia/Shanghai#volumes:#- ./oap/conf/alarm-settings.yml:/skywalking/config/alarm-settings.ymlskywalking-ui:image: apache/skywalking-ui:8.9.1container_name: skywalking-uidepends_on:- skywalking-oap-serverlinks:- skywalking-oap-serverrestart: alwaysports:- "9090:8080"environment:SW_OAP_ADDRESS: http://skywalking-oap-server:12800TZ: Asia/Shanghai

dockerfile如何运行，自行查询即可
启动完成之后，打开http://127.0.0.1:9090,会出现Skywalking的UI界面。

配置日志文件

在/src/main/resources下创建log4j2.xml文件

<?xml version="1.0" encoding="UTF-8"?><Configuration status="INFO"><Appenders><!-- 控制台输出 --><Console name="Console" target="SYSTEM_OUT"><PatternLayout pattern="%d [%traceId] %-5p %c{1}:%L - %m%n"/></Console><!-- skywalking grpc 日志收集 8.4.0版本开始支持 --><GRPCLogClientAppender name="grpc-log"><PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %logger{36} - %msg%n"/></GRPCLogClientAppender></Appenders><Loggers><Root level="INFO"><AppenderRef ref="Console"/><AppenderRef ref="grpc-log"/></Root></Loggers></Configuration>

接下来，只需要写一个简单的测试项目，我这边主要用了我老的influxdb项目。可以参考一下，就不能cv大法了。

controller文件

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import top.warmheart.dao.DeviceDao;
import top.warmheart.pojo.Device;
import top.warmheart.service.impl.DeviceServiceImpl;
import top.warmheart.util.BaseResponse;
import java.time.Instant;
import java.time.LocalDateTime;/*** @author 滚~韬* @date 2024/1/29 13:00*/
@RestController
@RequestMapping("/influx")
public class InfluxDBController {@Autowiredprivate DeviceServiceImpl deviceServiceImpl;@Autowiredprivate DeviceDao dao;@GetMapping("/queryByTime")public BaseResponse Query(LocalDateTime start,LocalDateTime end){return dao.QueryByTime(start,end);}@GetMapping("/queryById")public BaseResponse Query(String Id){return dao.QueryById(Id);}@PostMapping("/DeleteByTime")public BaseResponse Delete(LocalDateTime start,LocalDateTime end){return dao.DeleteByTime(start,end);}@PostMapping("/insertByBlocking")public BaseResponse InsertByBlocking(Device device){device.setTime(Instant.now());return deviceServiceImpl.InsertDataByBlocking(device);}@PostMapping("/insert")public BaseResponse Insert(Device device){device.setTime(Instant.now());return deviceServiceImpl.InsertData(device);}
}

Service层

import com.influxdb.annotations.Measurement;
import com.influxdb.client.domain.InfluxQLQuery;
import com.influxdb.client.domain.WritePrecision;
import com.influxdb.exceptions.InfluxException;
import com.influxdb.query.InfluxQLQueryResult;
import com.influxdb.spring.influx.InfluxDB2Properties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import top.warmheart.core.Op;
import top.warmheart.core.Query;
import top.warmheart.enums.ErrorCode;
import top.warmheart.model.DeleteModel;
import top.warmheart.model.QueryModel;
import top.warmheart.pojo.Device;
import top.warmheart.service.DeviceService;
import top.warmheart.util.BaseResponse;
import top.warmheart.util.InfluxdbUtils;import java.time.OffsetDateTime;
import java.time.ZoneOffset;
import java.util.List;import static top.warmheart.decorator.InfluxApiDecorator.*;/*** @author 滚~韬* @date 2024/1/26 13:20*/@Service
public class DeviceServiceImpl implements DeviceService {@Autowiredprivate InfluxDB2Properties influxDB2Properties;protected static Logger log = LoggerFactory.getLogger(DeviceServiceImpl.class);public BaseResponse QueryData(Class<?> clazz, QueryModel queryModel) {Measurement annotation = clazz.getAnnotation(Measurement.class);if (annotation != null) {queryModel.setMeasurement(annotation.name()).setWhere(Op.where(queryModel));}String build = Query.build(queryModel);return QueryData(build);}public BaseResponse QueryData(String sql) {log.info("查询语句:" + sql);InfluxQLQueryResult result = getInfluxQLQueryApi().query(new InfluxQLQuery(sql, influxDB2Properties.getBucket()));return QueryData(result);}public BaseResponse QueryData(InfluxQLQueryResult result) {if (result == null) {return new BaseResponse(200, null, "获取成功,无数据");}List<Device> pojo = InfluxdbUtils.toPOJO(result, Device.class);log.info("查询数据数量为:" + pojo.size() + "--------------------------");return new BaseResponse(200, pojo, "获取成功");}public BaseResponse InsertData(Object o) {try {getWriteApi().writeMeasurement(WritePrecision.NS, o);} catch (Exception e) {return new BaseResponse(ErrorCode.SYSTEM_ERROR, "插入数据过程中异常");}return new BaseResponse(200, o, "插入成功");}public BaseResponse InsertDataByBlocking(Object o) {try {getWriteApiBlocking().writeMeasurement(WritePrecision.NS, o);} catch (Exception e) {return new BaseResponse(ErrorCode.SYSTEM_ERROR, "插入数据过程中异常");}return new BaseResponse(200, o, "插入成功");}/*** 批量写有问题** @param devices* @return*/@Deprecatedpublic BaseResponse InsertData(List<Device> devices) {try {getWriteApi().writeMeasurements(WritePrecision.NS, devices);} catch (Exception e) {return new BaseResponse(ErrorCode.SYSTEM_ERROR, "插入数据过程中异常");}return new BaseResponse(200, devices, "插入成功");}public BaseResponse DeleteData(DeleteModel deleteModel) {try {OffsetDateTime startOff = OffsetDateTime.of(deleteModel.getStart(), ZoneOffset.UTC);OffsetDateTime endOff = OffsetDateTime.of(deleteModel.getEnd(), ZoneOffset.UTC);getDeleteApi().delete(startOff, endOff, "", influxDB2Properties.getBucket(), influxDB2Properties.getOrg());} catch (InfluxException ie) {log.warn("InfluxException: " + ie);return new BaseResponse(ErrorCode.SYSTEM_ERROR, "删除错误");}return new BaseResponse(200, null, "删除成功");}}

dao层

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import top.warmheart.enums.ErrorCode;
import top.warmheart.model.DeleteModel;
import top.warmheart.model.QueryModel;
import top.warmheart.pojo.Device;
import top.warmheart.service.DeviceService;
import top.warmheart.util.BaseResponse;import java.time.LocalDateTime;
import java.util.Map;
import java.util.TreeMap;/*** @Author：滚韬* @Date：2024/1/30 14:28*/
@Component
public class DeviceDao {@Autowiredprivate DeviceService deviceService;/*** 根据给定时间范围查询数据** @param start 开始时间* @param end   结束时间，可选参数，如果不传，则默认为当前时间* @return 查询结果的BaseResponse对象*/public BaseResponse QueryByTime(LocalDateTime start,LocalDateTime end){QueryModel queryModel = new QueryModel();if (start!=null){queryModel.setStart(start);if(end!=null){queryModel.setEnd(end);}else{queryModel.setEnd(LocalDateTime.now());}}else {return new BaseResponse(ErrorCode.SYSTEM_ERROR,"开始日期不能为空(检查是否格式正确)");}return deviceService.QueryData(Device.class, queryModel);}public BaseResponse QueryById(String Id){Map<String, Object> map = new TreeMap<>();map.put("device_no", Id);QueryModel queryModel = new QueryModel();queryModel.setMap(map);return deviceService.QueryData(Device.class, queryModel);}public BaseResponse DeleteByTime(LocalDateTime start,LocalDateTime end){DeleteModel deleteModel = new DeleteModel();if (start!=null){deleteModel.setStart(start);if(end!=null){deleteModel.setEnd(end);}else{deleteModel.setEnd(LocalDateTime.now());}}else {return new BaseResponse(ErrorCode.SYSTEM_ERROR,"开始日期不能为空(检查是否格式正确)");}return deviceService.DeleteData(deleteModel);}
}

启动

在虚拟机参数里加上这段，注意skywalking-agent.jar要去官网下载，jar包外面的文件也不能丢失，否则会报错
-javaagent:C:/skywalking/skywalking-agent/skywalking-agent.jar
-Dskywalking.agent.service_name=你自己的服务名字
-Dskywalking.collector.backend_service=127.0.0.1:11800

效果

请求查询接口，记得日志要打在service层里面
在这里插入图片描述
在这里插入图片描述

dashboard介绍

在这里插入图片描述
CPM/PPM:服务负荷
slow Services: 慢服务
Un-Health Services (Apdex): Apdex性能指标(1是满分)
Slow Endpoints: 慢请求点
Global Response Latency:百分比响应延时，不同百分比的延时时间，单位ms

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://xiahunao.cn/news/2812133.html

如若内容造成侵权/违法违规/事实不符，请联系瞎胡闹网进行投诉反馈，一经查实，立即删除！

相关文章

Pytest教程：一种利用 Python Pytest Hook 机制的软件自动化测试网络数据抓包方法

Pytest教程：一种利用 Python Pytest Hook 机制的软件自动化测试网络数据抓包方法

随着计算机技术的发展&#xff0c;使得网络应用的数量不断增加&#xff0c;因此网络数据抓包成为了网络应用开发和测试中非常重要的一部分。目前&#xff0c;已有许多网络数据抓包工具可供使用&#xff0c;例如 Wireshark、Tcpdump、Fiddler 等&#xff0c;但这些工具需要手动配…
阅读更多...
Nodejs 第四十二章（jwt）

Nodejs 第四十二章（jwt）

什么是jwt? JWT&#xff08;JSON Web Token&#xff09;是一种开放的标准&#xff08;RFC 7519&#xff09;&#xff0c;用于在网络应用间传递信息的一种方式。它是一种基于JSON的安全令牌&#xff0c;用于在客户端和服务器之间传输信息。 https://jwt.io/ JWT由三部分组成&…
阅读更多...
VUE基础知识九 ElementUI项目

VUE基础知识九 ElementUI项目

ElementUI官网 一 项目 最终完成的效果&#xff1a; 切换上边的不同按钮&#xff0c;下方显示不同的表格数据 在src/components下新建不同业务组件的文件夹 1.1 搭建项目 使用脚手架搭建项目后&#xff0c;引入ElementUI&#xff08;搭建、引入ElementUI步骤在第七节里已…
阅读更多...
现代信号处理学习笔记（二）参数估计理论

现代信号处理学习笔记（二）参数估计理论

参数估计理论为我们提供了一套系统性的工具和方法&#xff0c;使我们能够从样本数据中推断总体参数&#xff0c;并评估估计的准确性和可靠性。这些概念在统计学和数据分析中起着关键的作用。 目录 前言 一、估计子的性能 1、无偏估计与渐近无偏估计 2、估计子的有效性 两个…
阅读更多...
Vue-Cropper头像裁剪插件使用

Vue-Cropper头像裁剪插件使用

1. 效果预览 2. 插件介绍 官网地址&#xff1a;[GitHub - xyxiao001/vue-cropper: A simple picture clipping plugin for vue](https://github.com/xyxiao001/vue-cropper?fromthosefree.com) 3 . 插件使用 下载插件 npm install vue-croppernext3 . 封装好的代码&#x…
阅读更多...
FL Studio Fruity Edition2024中文入门版Win/Mac

FL Studio Fruity Edition2024中文入门版Win/Mac

FL Studio Fruity Edition2024是一款功能强大的音乐制作软件&#xff0c;适合初学者和音乐爱好者使用。它提供了丰富的音乐制作工具&#xff0c;包括音频录制、编辑、混音以及MIDI制作等功能&#xff0c;帮助用户轻松创作出动人的音乐作品。 FL Studio 21.2.3 Win-安装包下载如…
阅读更多...
使用Scrapy将数据提取到数据库中，进行处理

使用Scrapy将数据提取到数据库中，进行处理

我们将数据处理的方式&#xff0c;最开始csv文件 再到与数据库建立联系 代码&#xff1a; Spider: import scrapyclass ShuangseqiuSpider(scrapy.Spider):name "shuangseqiu"allowed_domains ["sina.com.cn"]start_urls ["https://view.lottery…
阅读更多...
[NOIP2011 普及组] 数字反转

[NOIP2011 普及组] 数字反转

AC代码&#xff1a; #include<iostream>using namespace std;int main() {long long n;cin >> n;long long temp n;long long sum 0;while(temp ! 0){int c temp % 10;sum sum * 10 c;temp temp / 10;}printf("%lld",sum);return 0; }
阅读更多...
vue3 + vite + ts 中使用less文件全局变量

vue3 + vite + ts 中使用less文件全局变量

文章目录 安装依赖新建css变量文件全局引入css变量文件使用css变量 一、安装依赖 npm install less less-loader --save-dev 二、新建CSS变量文件 (1) :在根目录下的src文件中 src-> asset -> css ->glibal.less // glibal.less :root{--public_background_font_Col…
阅读更多...
跟着cherno手搓游戏引擎【26】Profile和Profile网页可视化

跟着cherno手搓游戏引擎【26】Profile和Profile网页可视化

封装Profile&#xff1a; Sandbox2D.h:ProfileResult结构体和ProfileResult容器&#xff0c;存储相应的信息 #pragma once #include "YOTO.h" class Sandbox2D :public YOTO::Layer {public:Sandbox2D();virtual ~Sandbox2D() default;virtual void OnAttach()ove…
阅读更多...
python中的数字类型Number

python中的数字类型Number

Python 数字(Number) Python 数字数据类型用于存储数值。 数据类型是不允许改变的&#xff0c;这就意味着如果改变数字数据类型的值&#xff0c;将重新分配内存空间。 以下实例在变量赋值时 Number 对象将被创建&#xff1a; var1 1 var2 10Python 支持三种不同的数值类型…
阅读更多...
蜣螂优化算法DBO求解不闭合MD-MTSP，可以修改旅行商个数及起点（提供MATLAB代码）

蜣螂优化算法DBO求解不闭合MD-MTSP，可以修改旅行商个数及起点（提供MATLAB代码）

一、蜣螂优化算法&#xff08;Dung beetle optimizer&#xff0c;DBO&#xff09; 蜣螂优化算法&#xff08;Dung beetle optimizer&#xff0c;DBO&#xff09;由Jiankai Xue和Bo Shen于2022年提出&#xff0c;该算法主要受蜣螂的滚球、跳舞、觅食、偷窃和繁殖行为的启发所得…
阅读更多...
kubectl使用及源码阅读

kubectl使用及源码阅读

目录 概述实践样例yaml 中的必须字段 kubectl 代码原理kubectl 命令行设置pprof 抓取火焰图kubectl 中的 cobra 七大分组命令kubectl createcreateCmd中的builder模式createCmd中的visitor访问者模式外层VisitorFunc分析 结束 概述 k8s 版本 v1.24.16 kubectl的职责 1.主要的…
阅读更多...
SQL注入之order by脚本盲注

SQL注入之order by脚本盲注

一、环境 还是用上次搭建的sql-labs靶机环境 搭建sql注入环境 二、什么是order by盲注 在有的时候我们进行sql注入时&#xff0c;源码的查询语句后面为order by&#xff1b; 众所周知&#xff0c;order by 后面接的字段或者数字不一样&#xff0c;那么这个数据表的排序就会…
阅读更多...
嵌入式学习第二十一天！（线程）

嵌入式学习第二十一天！（线程）

线程&#xff1a; 1. 基本概念&#xff1a; 线程&#xff1a;线程是一个轻量级的进程&#xff0c;位于进程空间内部&#xff0c;一个进程中可以创建多个线程 2. 线程创建&#xff1a; 线程独占栈空间&#xff0c;文本段、数据段和堆区与进程共享 3. 线程调度&#xff1a; 与进程…
阅读更多...
探索比特币现货 ETF 对加密货币价格的潜在影响

探索比特币现货 ETF 对加密货币价格的潜在影响

撰文&#xff1a;Sean&#xff0c;Techub News 文章来源Techub News&#xff0c;搜Tehub News下载查看更多Web3资讯。 自美国比特币现货交易所交易基金&#xff08;ETF&#xff09;上市以来&#xff0c;比特币现货 ETF 的相关信息无疑成为了影响比特币价格及加密货币市场走向…
阅读更多...
Java四大引用详解：强引用、软引用、弱引用、虚引用

Java四大引用详解：强引用、软引用、弱引用、虚引用

在JDK1.2以前的版本中&#xff0c;当一个对象不被任何变量引用&#xff0c;那么程序就无法再使用这个对象。也就是说&#xff0c;只有对象处于可触及状态&#xff0c;程序才能使用它。这就像在商店购买了某样物品后&#xff0c;如果有用就一直保留它&#xff0c;否则就把它扔到…
阅读更多...
Spring Boot项目中不使用@RequestMapping相关注解，如何动态发布自定义URL路径

Spring Boot项目中不使用@RequestMapping相关注解，如何动态发布自定义URL路径

一、前言 在Spring Boot项目开发过程中&#xff0c;对于接口API发布URL访问路径&#xff0c;一般都是在类上标识RestController或者Controller注解&#xff0c;然后在方法上标识RequestMapping相关注解&#xff0c;比如&#xff1a;PostMapping、GetMapping注解&#xff0c;通…
阅读更多...
【UnityShader入门精要学习笔记】第六章（1）Unity中的基础光照

【UnityShader入门精要学习笔记】第六章（1）Unity中的基础光照

本系列为作者学习UnityShader入门精要而作的笔记&#xff0c;内容将包括&#xff1a; 书本中句子照抄 个人批注项目源码一堆新手会犯的错误潜在的太监断更&#xff0c;有始无终 总之适用于同样开始学习Shader的同学们进行有取舍的参考。 文章目录 光照的原理光源吸收和散射着…
阅读更多...
LinkedList的使用（Java）

LinkedList的使用（Java）

目录 一、介绍二、LinkedList的使用1、LinkedList的构造2、 LinkedList的其他常用方法介绍3、LinkedList的遍历 三、ArrayList和LinkedList的区别 一、介绍 LinkedList的底层是双向链表结构&#xff0c;由于链表没有将元素存储在连续的空间中&#xff0c;元素存储在单独的节点…
阅读更多...
最新文章

Copyright @ 2022~2023