SpringBoot+Grafana+Prometheus+Docker-Compose 快速部署与JVM监控的快速入门的简单案例

news2025/1/12 1:11:15

1. Java项目

1.1 项目结构

在这里插入图片描述

1.2 pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>3.3.3</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>info.liberx</groupId>
    <artifactId>Prometheus</artifactId>
    <version>0.0.1-SNAPSHOT</version>

    <properties>
        <java.version>17</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
        <dependency>
            <groupId>io.micrometer</groupId>
            <artifactId>micrometer-registry-prometheus</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>

</project>

说明:

spring-boot-starter-actuator:主要用于提供内置的监控和管理端点,帮助你实时查看和管理应用的健康状态和性能。

micrometer-registry-prometheus:用于将这些监控指标导出到Prometheus,让你可以通过Prometheus和Grafana对应用进行全面的监控和分析。

1.3 application.properties

spring.application.name=Prometheus
management.endpoints.web.exposure.include=health,info,prometheus
management.endpoint.prometheus.enabled=true

说明:

  • 可以通过/actuator/health端点查看应用的健康状态,返回的信息可以包括数据库连接、队列状态等。

  • 可以通过/actuator/metrics端点,可以查看应用程序的各种性能指标,如内存使用、CPU使用、线程数、GC等。

  • 可以通过/actuator/info端点获取应用的基本信息,如版本号、描述等,这些信息可以通过配置文件或其他手段提供

  • 可以通过/actuator/prometheus端点,Prometheus服务器可以通过这个端点抓取并存储这些监控指标。

1.4 PrometheusApplication.java

package info.liberx.prometheus;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class PrometheusApplication {

    public static void main(String[] args) {
        SpringApplication.run(PrometheusApplication.class, args);
    }

}

1.5 PrometheusController.java

package info.liberx.prometheus.controller;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.Arrays;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

@RestController
public class PrometheusController {

    private static final Logger logger = LoggerFactory.getLogger(PrometheusController.class);

    // 创建一个线程池用于CPU测试
    private final ExecutorService cpuThreadPool = Executors.newFixedThreadPool(8);

    @GetMapping("/memory-usage")
    public String memoryUsage() {
        // 创建一个1GB大小的数组来消耗内存
        int size = 1024 * 1024 * 1024; // 1 GB
        byte[] memoryBlock = new byte[size];

        // 模拟内存使用,通过填充数组
        Arrays.fill(memoryBlock, (byte) 1);

        logger.info("内存已分配,保持10秒...");

        try {
            // 保持程序运行,以便监控内存使用
            Thread.sleep(10000); // 10秒
        } catch (InterruptedException e) {
            logger.error("线程被中断", e);
            Thread.currentThread().interrupt();
        }

        return "内存使用模拟完成";
    }

    @GetMapping("/high-cpu-usage")
    public String highCpuUsage() {
        // 指定运行时间,单位为秒
        int duration = 10;

        for (int i = 0; i < 8; i++) { // 启动8个线程来消耗CPU
            cpuThreadPool.submit(() -> {
                long endTime = System.currentTimeMillis() + TimeUnit.SECONDS.toMillis(duration);
                while (System.currentTimeMillis() < endTime) {
                    Math.pow(Math.random(), Math.random()); // 持续执行计算
                }
                logger.info("CPU密集型线程已运行{}秒后结束。", duration);
            });
        }

        logger.info("高CPU使用测试已启动,持续{}秒。", duration);

        // 等待任务完成,防止请求过早返回
        cpuThreadPool.shutdown();
        try {
            if (!cpuThreadPool.awaitTermination(duration + 5, TimeUnit.SECONDS)) {
                cpuThreadPool.shutdownNow(); // 超时后强制关闭
            }
        } catch (InterruptedException e) {
            cpuThreadPool.shutdownNow();
            Thread.currentThread().interrupt();
        }

        return "高CPU使用模拟完成,持续时间:" + duration + "秒。";
    }

    @GetMapping("/gc")
    public String gc() {
        for (int i = 0; i < 1000; i++) {
            if (i % 100 == 0) {
                System.gc(); // 手动触发GC
                logger.info("手动GC触发。");
            }
            try {
                Thread.sleep(50); // 让JVM有时间处理
            } catch (InterruptedException e) {
                logger.error("线程被中断", e);
                Thread.currentThread().interrupt();
            }
        }
        return "GC模拟完成";
    }

    @GetMapping("/thread")
    public String thread() {
        ExecutorService threadPool = Executors.newFixedThreadPool(100); // 使用线程池管理线程

        for (int i = 0; i < 100; i++) { // 启动100个线程
            threadPool.submit(() -> {
                try {
                    Thread.sleep(10000); // 每个线程运行10秒
                } catch (InterruptedException e) {
                    logger.error("线程被中断", e);
                    Thread.currentThread().interrupt();
                }
            });
        }

        logger.info("已启动100个线程。");

        // 等待主线程结束后关闭线程池
        threadPool.shutdown();
        try {
            Thread.sleep(15000); // 主线程等待,防止程序过早退出
        } catch (InterruptedException e) {
            logger.error("主线程被中断", e);
            Thread.currentThread().interrupt();
        }
        return "线程模拟完成";
    }
}

说明:

API 功能请求路径描述
内存使用模拟/memory-usage模拟并监控1GB内存的分配和使用
高CPU使用模拟/high-cpu-usage模拟高CPU使用的场景
手动触发GC/gc手动触发垃圾回收操作
线程模拟/thread启动并模拟100个线程运行

2. Docker-Compose 项目

2.1 项目结构

在这里插入图片描述

2.2 docker-compose.yml

version: '3.7'

services:
  prometheus:
    image: prom/prometheus:latest
    container_name: prometheus
    volumes:
      - ./prometheus.yml:/etc/prometheus/prometheus.yml  # 配置文件挂载
      - prometheus_data:/prometheus  # 数据持久化卷挂载
    ports:
      - "9090:9090"
    networks:
      - monitoring

  grafana:
    image: grafana/grafana:latest
    container_name: grafana
    volumes:
      - ./grafana.ini:/etc/grafana/grafana.ini  # 配置文件挂载
    ports:
      - "3000:3000"
    networks:
      - monitoring

networks:
  monitoring:
    driver: bridge

volumes:
  prometheus_data:

2.3 grafana.ini

[smtp]
enabled = true
host = smtp.qq.com:465
user = xxx@qq.com
password = xxx
from_address = xxx@qq.com
from_name = Grafana

说明:这是邮箱验证的配置,如果你不需要也可以把docker-compose.yml对应的挂载路径删除。

2.4 prometheus.yml

global:
  scrape_interval: 15s  # 定义全局抓取间隔

scrape_configs:
  - job_name: 'example-service'
    metrics_path: '/actuator/prometheus'  # 指定要抓取的路径
    scheme: 'http'  # 或 'https',指定协议
    static_configs:
      - targets: ['192.168.186.137:8080']  # 目标主机和端口

说明:192.168.186.137:8080替换成为Java项目的访问地址。

3. 镜像源失效

如果Docker镜像源失效,可以尝试切换以下镜像源:

sudo nano /etc/docker/daemon.json
{
  "registry-mirrors": ["https://register.liberx.info"]
}
sudo systemctl restart docker

4. 测试验证

4.1 启动Docker-Compose项目

docker-compose up -d

启动后,你可以通过以下地址访问:

  • Prometheus: http://localhost:9090
  • Grafana: http://localhost:3000(默认用户名和密码均为 admin

在这里插入图片描述

在这里插入图片描述

4.2 设置中文(可选)

操作:点击右上角头像->Profile->Language->中文简体->Save。

在这里插入图片描述

在这里插入图片描述

4.3 添加数据源

在这里插入图片描述

4.4 添加案例和测试

监控项PromQL 查询语句
JVM 堆内存使用情况jvm_memory_used_bytes{area="heap"}
JVM 进程的 CPU 使用率rate(process_cpu_time_ns_total[$__rate_interval])
GC 停顿次数rate(jvm_gc_pause_seconds_count[$__rate_interval])
JVM 活动线程数量jvm_threads_live_threads

在这里插入图片描述

API 功能请求路径描述
内存使用模拟/memory-usage模拟并监控1GB内存的分配和使用
高CPU使用模拟/high-cpu-usage模拟高CPU使用的场景
手动触发GC/gc手动触发垃圾回收操作
线程模拟/thread启动并模拟100个线程运行

说明:说明:需要覆盖然后设置不同的单位,我只是模拟了一个线程的变化添加100个,还有其他接口可以自行测试感受变化,等待时间有点长,所以我就不进行测试了。

4.5 添加警告规则

4.5.1 发送预警(可选)

配置警告规则之前:先设置联系方式,如果你需要开启邮箱发送预警信息,不需要留空即可。

在这里插入图片描述

4.5.2 添加警告规则

在这里插入图片描述

5. 总结

​ 通过SpringBoot+Grafana+Prometheus+Docker-Compose快速部署和JVM监控的简单入门案例。

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

ThingsGateway:一款基于.NET8开源的跨平台高性能边缘采集网关

前言 今天大姚给大家分享一款基于.NET8开源的跨平台高性能边缘采集网关&#xff0c;提供底层PLC通讯库&#xff0c;通讯调试软件等&#xff0c;单机采集数据点位可达百万&#xff1a;ThingsGateway。 项目技术栈 后端技术栈&#xff1a;支持.NET 6/7/8&#xff0c;Sqlsugar&am…

爬虫使用优质代理:确保高效稳定的数据采集之道

爬虫使用优质代理的最佳实践 在进行网络爬虫时&#xff0c;使用优质代理就像是为你的爬虫装上了强劲的发动机&#xff0c;能够大幅提升数据抓取的效率和成功率。然而&#xff0c;选择和使用优质代理并非易事&#xff0c;今天我们就来探讨如何在爬虫中有效使用优质代理。 1. 什…

vue3组件封装系列-表格及分页-第二弹

第二弹来了&#xff0c;不知道有多少人是看过我的第一篇文章的&#xff0c;今天本来是没想更新的&#xff0c;但是现在项目正在验收期准备上线&#xff0c;闲着还不如来发发文。虽然这两天可能会高产&#xff0c;下一次高产就不知道是什么时候了。话不多说&#xff0c;先上图。…

OpenGuass under Ubuntu_22.04 install tutorial

今天开始短学期课程&#xff1a;数据库课程设计。今天9点左右在SL1108开课&#xff0c;听陈老师讲授了本次短学期课程的要求以及任务安排&#xff0c;随后讲解了国产数据库的三层架构的逻辑。配置了大半天才弄好&#xff0c;放一张成功的图片&#xff0c;下面开始记录成功的步骤…

数据融合的超速引擎——SeaTunnel

概览 SeaTunnel是一个由Apache软件基金会孵化的数据集成工具&#xff0c;专为应对大规模数据的快速处理而设计。它以高效的数据处理能力和简洁的架构&#xff0c;帮助企业在数据仓库构建、实时数据处理和数据迁移等场景下&#xff0c;实现数据流的无缝整合。SeaTunnel的设计理…

LDO工作原理与仿真

LDO工作原理与仿真 目录 LDO工作原理与仿真一、LDO内部电路组成1. 基准电压源&#xff08;Reference Voltage Source&#xff09;2. 误差放大器&#xff08;Error Amplifier&#xff09;3. 功率调整元件&#xff08;Power Adjustment Element&#xff09;4. 分压取样电路&#…

用于不平衡分类的 Bagging 和随机森林

用于不平衡分类的 Bagging 和随机森林 Bagging 是一种集成算法&#xff0c;它在训练数据集的不同子集上拟合多个模型&#xff0c;然后结合所有模型的预测。 [随机森林]是 bagging 的扩展&#xff0c;它也会随机选择每个数据样本中使用的特征子集。bagging 和随机森林都已被证…

【Word与WPS如何冻结首行首列及窗口】

1.Word如何冻结首行首列及窗口 microsoft word 中锁定表头是一项实用的功能&#xff0c;可让您在滚动文档时保持表头可见。这在处理大型文档或包含大量数据的表格时非常有用。php小编柚子将为您详细介绍 word 锁定表头位置的方法&#xff0c;帮助您轻松掌握这项实用技巧。 1.…

实体书商城小程序的设计

管理员账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;用户管理&#xff0c;小说分类管理&#xff0c;小说信息管理&#xff0c;订单管理&#xff0c;系统管理 微信端账号功能包括&#xff1a;系统首页&#xff0c;小说信息&#xff0c;小说资讯&#xff0…

Qt_两种创建组件的方式-通过图形化-通过代码

文章目录 一、通过图形化的方式&#xff0c;在界面上创建一个控件&#xff0c;显示hello world1.打开UI设计界⾯2.拖拽控件⾄ ui 界⾯窗⼝并修改内容3.构建并运行 二、通过代码的方式&#xff0c;通过编写代码&#xff0c;在界面上创建控件&#xff0c;显示hello world在Widget…

手撕python之基本数据类型以及变量

​​​​​​1.基础概念 python就是将不同的数据划分成了不同的类型 就像我们生活中的数据有数字、字符等数据一样 小知识点&#xff1a; 注释&#xff1a;# 全体注释&#xff1a;AltF3 取消注释&#xff1a;AltF4 2.数值类型 数值类型概括 数值类型分为三种&#xff…

Cesium 展示——动态洪水淹没效果

文章目录 需求分析1. 引入插件2. 定义变量3. 开始绘制3.1 绘制点3.2 绘制线3.3 绘制面3.4 开始分析(第一种)3.5 开始分析(第二种)3.6 方法调用4. 整体代码其他需求 从低处到高处实现洪水淹没效果 分析 本篇文章对方法进行单独抽离,因此支持拿来即用,注意传参就可 1. …

宠物系统小程序的设计

管理员账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;用户管理&#xff0c;商品信息管理&#xff0c;店主管理&#xff0c;猫狗查询管理&#xff0c;猫狗宠物社区&#xff0c;管理员管理&#xff0c;系统管理 微信端账号功能包括&#xff1a;系统首页&…

宝塔 出现 请使用正确的入口登录面板

目录 前言1. 问题所示2. 原理分析3. 解决方法 前言 记录实战中所有的问题导向、原理分析以及解决方法 1. 问题所示 在登录宝塔的时候&#xff0c;出现如下问题 请使用正确的入口登录面板 错误原因&#xff1a;当前新安装的已经开启了安全入口登录&#xff0c;新装机器都会随…

使用redis模拟cookie-session,例子:实现验证码功能

目录 在前后端分离架构中不建议使用cookie-session机制实现端状态识别 所以我们可以使用redis来模拟session-cookie机制 下面我们通过实现验证码的功能来举例 第一步&#xff1a;了解前端要我们返回的数据变量名字&#xff0c;变量类型 1.封装code,data成一个result类&…

多模态技术应用场景探析,景联文科技多模态数据测试平台推动多模态大模型技术突破

多模态技术应用场景探析&#xff0c;景联文科技多模态数据测试平台推动多模态大模型技术突破 在大语言模型背景下&#xff0c;多模态技术的发展已成为一个重要趋势。 Sora是OpenAI推出的多模态大模型&#xff0c;具备高级视频生成与编辑功能&#xff0c;支持长视频、多视角、多…

使用OpenCV库来捕获摄像头视频流,并按指定格式保存

今天我们来使用OpenCV库来捕获摄像头视频流&#xff0c;并将其保存为AVI格式的视频文件&#xff0c; 代码的主要功能包括&#xff1a; 初始化摄像头捕获对象。设置视频编解码器和输出文件路径。循环读取视频帧&#xff0c;处理并保存到文件中。显示处理后的视频帧。按下q键退…

Python | 处理海洋2C 数据 | 非标准时间格式

写在前面 最近&#xff0c;师弟在用Python读取某海洋2C数据时&#xff0c;突然冒出一个报错&#xff1a;“时间单位的参考日期无效&#xff0c;当前日期 00:00:00.0”。这让我回想起&#xff0c;似乎在很久很久以前&#xff0c;我处理SMAP和Argo数据时也遇到过类似的问题。为了…

JavaScript 模块化开发:ES6 模块与 CommonJS 的对比与应用

​ ​ 您好&#xff0c;我是程序员小羊&#xff01; 前言 随着前端项目规模的增长&#xff0c;代码组织和管理变得越来越复杂。模块化开发成为解决这一问题的有效手段&#xff0c;能够帮助开发者将代码进行分割、复用和维护。JavaScript 在发展过程中出现了多种模块化规范&…

【精通SDL之----使用PBO异步传输像素数据】

使用PBO异步传输像素数据 前言一、 一些GPU 分配的常用内存对象介绍二、 PBO 传输原理三、 PBO 使用方法 前言 书接上文【精通SDL之----SDL_RenderReadPixels截屏】&#xff0c;SDL_RenderReadPixels在GLES2上是一个非常耗时的操作&#xff0c;因为   1. OpenGL ES 是一个异步…