使用Docker-Java监听Docker容器的信息
使用Docker-Java监听Docker容器的信息
Docker作为一种轻量级的容器化平台,极大地方便了应用的部署与管理。然而,在实际使用过程中,我们常常需要对运行中的容器进行监控,以确保其健康状态,并能及时响应各种异常情况。本文将介绍如何使用Docker-Java这个库来监听Docker容器的信息。
什么是Docker-Java?
Docker-Java是一个开源的Java库,旨在通过Java程序与Docker守护进程进行通信。它提供了丰富的API,可以用于管理Docker容器、镜像、网络等各种资源。
安装Docker-Java
在开始之前,确保你已经安装了Docker,并且可以正常运行Docker命令,还需要开放2375
和2376
。然后,你需要在你的Java项目中添加Docker-Java的依赖。对于Maven项目,可以在pom.xml
中添加以下依赖:
<!-- https://mvnrepository.com/artifact/com.github.docker-java/docker-java-api -->
<dependency><groupId>com.github.docker-java</groupId><artifactId>docker-java-api</artifactId><version>3.3.4</version>
</dependency>
初始化Docker客户端
首先,我们需要创建一个Docker客户端实例,用于与Docker守护进程进行通信。以下是初始化Docker客户端的示例代码:
publi static DockerClient buildDockerClient(String dockerHost) {DefaultDockerClientConfig config = DefaultDockerClientConfig.createDefaultConfigBuilder()// 这里填最上面填的ip端口号,ip换成服务器ip.withDockerHost("tcp://" + dockerHost + ":" + PORT)// 这里也可以用另一种配置的// .withDockerHost("unix://var/run/docker.sock").build();/*** 创建一个ApacheDockerHttpClient实例,用于与Docker服务器进行通信。* 这里使用了Apache HTTP客户端作为HTTP通信的实现,通过配置各种参数来优化通信效果。** @param config 提供Docker主机信息、SSL配置等必要信息的配置对象。* @return DockerHttpClient 一个配置好的HTTP客户端,用于与Docker服务进行通信。*/DockerHttpClient httpClient = new ApacheDockerHttpClient.Builder().dockerHost(config.getDockerHost()).sslConfig(config.getSSLConfig()).maxConnections(100).connectionTimeout(Duration.ofSeconds(30)).responseTimeout(Duration.ofSeconds(45)).build();return DockerClientImpl.getInstance(config, httpClient);}
监听Docker事件
Docker支持通过事件流(Event Stream)来监听容器的各种状态变化,例如启动、停止、删除等。我们可以使用Docker-Java提供的API来监听这些事件。
以下是监听Docker容器事件的示例代码:
/*** @param containerId 容器ID* @Description: 获取容器的基本信息*/public static Map<String, String> getContainerInfo(DockerClient dockerClient, String containerId) {HashMap<String, String> map = new HashMap<>();// 获取容器信息InspectContainerResponse containerInfo = dockerClient.inspectContainerCmd(containerId).exec();// 获取容器的名称map.put("containerName", containerInfo.getName());// 获取容器的镜像名称String image = containerInfo.getConfig().getImage();map.put("dockerImage", image);// 获取容器的端口信息Ports ports = containerInfo.getNetworkSettings().getPorts();map.put("ports", StrUtil.join(",", ports.getBindings().keySet()));// 获取容器的运行状态String containerState = containerInfo.getState().getStatus();map.put("dockerState", containerState);// 获取容器的创建时间戳(以毫秒为单位)String createdTimeMillis = containerInfo.getCreated();map.put("created", formattedTimeZone(createdTimeMillis));// 获取容器的运行状态Boolean running = containerInfo.getState().getRunning();map.put("state", Boolean.TRUE.equals(running) ? "1" : "2");return map;}/*** 获取容器内存占用** @param containerId 容器ID* @return 占用内存(MB)*/public static double getMemoryStats(DockerClient dockerClient, String containerId) {Statistics containerStats = dockerClient.statsCmd(containerId).exec(new InvocationBuilder.AsyncResultCallback<>()).awaitResult();long memoryUsageInBytes = 0;if (containerStats != null && containerStats.getMemoryStats() != null) {memoryUsageInBytes = containerStats.getMemoryStats().getUsage();}// 将字节数转换为 MBreturn NumberUtil.div(memoryUsageInBytes, 1024.0 * 1024.0, 1);}/*** @param isoTimeMillis ISO8601格式的时间* @return {@code String } 时间* @Description: 格式化时间*/private static String formattedTimeZone(String isoTimeMillis) {// 解析ISO 8601格式的字符串为Instant对象Instant instant = Instant.parse(isoTimeMillis);// 将Instant对象转换为ZonedDateTime对象(UTC时区)ZonedDateTime zonedDateTime = ZonedDateTime.ofInstant(instant, ZoneId.of("UTC"));// 转换为本地时区(如果需要)ZonedDateTime localZonedDateTime = zonedDateTime.withZoneSameInstant(ZoneId.systemDefault());// 定义时间格式DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");// 格式化时间return localZonedDateTime.format(formatter);}
处理具体事件
根据项目需求,我们可以进一步对不同类型的事件进行分类处理。例如,如果我们只关心容器的启动和停止事件,可以这样处理:
/*** @return {@code List<Container> }* @Description: 获取所有容器列表*/public static List<Container> getAllContainers(DockerClient dockerClient) {return dockerClient.listContainersCmd().exec();}/*** @param containerId 容器ID* @Description: 启动容器*/public static void startContainer(DockerClient dockerClient, String containerId) {dockerClient.startContainerCmd(containerId).exec();}/*** @param containerId 容器ID* @Description: 停止容器*/public static void stopContainer(DockerClient dockerClient, String containerId) {dockerClient.stopContainerCmd(containerId).exec();}/*** @param containerId 容器ID* @Description: 重启容器*/public static void restartContainer(DockerClient dockerClient, String containerId) {dockerClient.restartContainerCmd(containerId).exec();}
结论
通过Docker-Java库,我们可以轻松地在Java应用中与Docker进行交互,并实时监听Docker容器的状态变化。这对于需要动态监控和管理容器的项目来说,非常实用。希望本文的介绍能帮助你更好地利用Docker-Java来实现容器的监控与管理。
相关文章:

使用Docker-Java监听Docker容器的信息
使用Docker-Java监听Docker容器的信息 Docker作为一种轻量级的容器化平台,极大地方便了应用的部署与管理。然而,在实际使用过程中,我们常常需要对运行中的容器进行监控,以确保其健康状态,并能及时响应各种异常情况。本…...

Spring Boot + Mybatis Plus实现登录注册
Spring Boot 实现登录注册 1. 注册 业务逻辑 客户端输入注册时需要的用户参数,比如:账户名、密码、确认密码、其他服务端接收到客户端的请求参数进行校验,然后判断是否有误,有误的地方就将错误信息抛出将密码进行加密之后存储到…...

IDEA创建web项目
IDEA创建web项目 第一步:创建一个空项目 第二步:在刚刚创建的项目下创建一个子模块 第三步:在子模块中引入web 创建结果如下: 这里我们需要把这个目录移到main目录下,并改名为webapp,结果如下 将pom文件…...

二手物品交易系统的设计
管理员账户功能包括:系统首页,个人中心,管理员管理,商家管理,用户管理,商品管理,用户咨询管理 商家账户功能包括:系统首页,个人中心,商品管理,用…...

探索大数据在信用评估中的独特价值
随着我国的信用体系越来越完善,信用将影响越来越多的人。现在新兴的大数据信用和传统信用,形成了互补的优势,大数据信用变得越来越重要,那大数据信用风险检测的重要性主要体现在什么地方呢?本文将详细为大家介绍一下,…...

MFC基础学习应用
MFC基础学习应用 1.基于对话框的使用 左上角为菜单键(其下的关于MFC主要功能由IDD_ABOUTBOX决定) 附图 右下角为按钮(基本功能由IDD_DIALOG决定,添加按钮使用由左上角的工具箱完成) 附图 2.自行添加功能与按钮//功能代码 void CMFCApplication4Dlg:…...

Gradle实现类似Maven的profiles功能
版本说明 GraalVM JDK 21.0.3Gradle 8.7Spring Boot 3.2.5 目录结构 指定环境打包 application.yml/yaml/properties 执行 bootJar 打包命令前要先执行 clean【其它和 processResources 相关的命令也要先执行 clean】,否则 active 值不会变! spring…...

【强化学习】gymnasium自定义环境并封装学习笔记
【强化学习】gymnasium自定义环境并封装学习笔记 gym与gymnasium简介gymgymnasium gymnasium的基本使用方法使用gymnasium封装自定义环境官方示例及代码编写环境文件__init__()方法reset()方法step()方法render()方法close()方法 注册环境创建包 Package(最后一步&a…...

TLE9879的基于Arduino调试板SWD刷写接口
官方的Arduino评估板,如下图所示: 如果你有官方的调试器,应该不用关注本文章,如下图连接就是: 如果,您和博主一样需要自己飞线的话,如下图所示:PCB的名称在右边整理,SWD的…...

基于 Delphi 的前后端分离:之五,使用 HTMX 让页面元素组件化之面向对象的Delphi代码封装
前情提要 本博客上一篇文章,描述了使用 Delphi 作为后端的 Web Server,前端使用 HTMX 框架,把一个开源的前端图表 JS 库,进行了组件化。 上一篇文章仅仅是描述了简单的前端代码组件化的可能性,依然是基于前端库的 JS…...

讲透计算机网络知识(实战篇)01——计算机网络和协议
一、计算机网络和协议 1、网络和互联网络 1.1 网络、互联网、Internet 用交换机、集线器连接在一起的计算机构成一个网络。 用路由器连接多个网络,形成互联网。 全球最大的互联网:Internet。 1.2 网络举例 家庭互联网 图中的无线拨号路由器既是路由…...

8个宝藏APP,个个都牛逼哈拉!
AI视频生成:小说文案智能分镜智能识别角色和场景批量Ai绘图自动配音添加音乐一键合成视频https://aitools.jurilu.com/ 目前win7已经逐渐淡出人们的视野,大部分人都开始使用win10,在日常工作和使用中,创客们下载神奇的软件能大幅提…...

使用docker构建java应用
1、docker简介 Docker是一个开源的容器化平台,可以帮助开发人员将应用程序及其依赖项打包成一个可移植的容器。容器化是一种轻量级的虚拟化技术,可以使应用程序在不同的操作系统和环境中具有一致的运行方式。 使用Docker带来的好处包括: 简…...

Oracle 存储过程
Oracle存储过程 创建存储过程 CREATE OR REPLACE PROCEDURE UPDATE_EMPLOYEE_SALARY(p_employee_id IN NUMBER,p_employee_salary IN NUMBER )AS BEGINUPDATE employeesSET salary p_employee_salaryWHERE employee_id p_employee_id;COMMIT;EXCEPTIONWHEN NO_DATA_FOUND T…...

下载站名文件
自学python如何成为大佬(目录):https://blog.csdn.net/weixin_67859959/article/details/139049996?spm1001.2014.3001.5501 得到了请求地址与请求参数后,可以发现请求参数中的出发地与目的地均为车站名的英文缩写。而这个英文缩写的字母是通过输入中文车站名转换…...

345453
38744...

Java操作redis
目录 一:Jedis 二:使用Spring Data Redis Redis 的 Java 客户端很多,官方推荐的有三种: 1.Jedis 2.Lettuce 3.Redisson 同时,Spring 对 Redis 客户端进行了整合,提供了 Spring Data Redis,在S…...

【数据结构(邓俊辉)学习笔记】图03——拓扑排序
文章目录 0. 概述1. 零入度算法1. 1 拓扑排序1. 2 算法 2. 零出度算法2.1 算法2.2 实现2.3. 复杂度 0. 概述 学习下拓扑排序 1. 零入度算法 1. 1 拓扑排序 首先理解下拓扑排序 其实老师经常干这事,如编讲义,将已经知道的知识点串起来变成讲课序列。那…...

C#参数使用场景简要说明
C#参数使用场景简要说明 1、传值参数 方法、类成员的初始化 2、输出参数 方法返回值不能满足,需要多个返回值时; 3、引用参数 方法需要修改变量需带回原变量时; 4、具名参数 代码可读性高,参数可交换位置 5、方法扩展(…...

线性代数|机器学习-P10最小二乘法的四种方案
文章目录 1. 概述2. SVD奇异值分解3. 最小二乘法方程解4. 最小二乘法图像解释5. Gram-Schmidt 1. 概述 当我们需要根据一堆数据点去拟合出一条近似的直线的时候,就会用到 最小二乘法 .根据矩阵A的情况,有如下四种方法 在r n m 时,SVD奇异…...

【Android面试八股文】你能描述一下JVM中的类加载过程吗?
文章目录 一、Java类的生命周期二、JVM类加载过程1. 加载(Loading)2. 链接(Linking)a. 验证(Verification)b. 准备(Preparation)b.1 准备阶段的初始值b.2 用户定义的初值b.3 常量的初始化c. 解析(Resolution)3. 初始化(Initialization)3.1 什么是 `<clinit>`…...

MYSQL八、MYSQL的SQL优化
一、SQL优化 sql优化是指:通过对sql语句和数据库结构的调整,来提高数据库查询、插入、更新和删除等操作的性能和效率。 1、插入数据优化 要一次性往数据库表中插入多条记录: insert into tb_test values(1,tom); insert into tb_tes…...

鸿蒙轻内核M核源码分析系列二一 02 文件系统LittleFS
1、LFS文件系统结构体介绍 会分2部分来介绍结构体部分,先介绍LittleFS文件系统的结构体,然后介绍LiteOS-M内核中提供的和LittleFS相关的一些结构体。 1.1 LittleFS的枚举结构体 在openharmony/third_party/littlefs/lfs.h头文件中定义LittleFS的枚举、…...

【ARMv8/ARMv9 硬件加速系列 3 -- SVE 指令语法及编译参数详细介绍】
文章目录 SVE 汇编语法SVE 单通道谓词SVE 测试代码 SVE 软件和库支持SVE 编译参数配置-marcharmv8-alseprofilememtagsve2-aessve2-bitpermcryptosve2sve2-sha3sve2-sm4 SVE 汇编语法 在介绍 SVE 汇编指令语法之前,先介绍下如何判断自己所使用的芯片是否实现了SVE功…...

Java版+ SaaS应用+接口技术RESTful API 技术开发的智慧医院HIS系统源码 专注医院管理系统研发 支持二开
Java版 SaaS应用接口技术RESTful API WebSocket WebService技术开发的智慧医院HIS系统源码 专注医院管理系统研发 支持二开 医院住院管理系统(Hospital Information System简称HIS)是一门医学、信息、管理、计算机等多种学科为一体的边缘科学ÿ…...

工业机器人远程运维,增强智慧工厂运营管理
1、需求背景 随着工业自动化技术的普及和工业机器人应用的增加,制造业对于生产线稳定性和效率的要求不断提高。然而,传统的现场监控方式存在着地理位置限制、实时监控难度大以及诊断能力有限等问题,迫切需要一种更具灵活性和效率的监控方式。…...

理解Python的元类
1.type()函数 type 函数是一个内置函数,用来获取一个对象的类型。它可以接受一个参数,返回这个参数的数据类型。type也可以用来创建类,type就是元类 x333 list["ab"] tuple (1, "a", True, 3.14) dict {name: Alice,…...

web前端黑马下载:探索学习资源的海洋
web前端黑马下载:探索学习资源的海洋 在数字化时代,Web前端技术日益成为互联网行业的核心驱动力。为了跟上这一趋势,众多学习者纷纷投身于Web前端的学习之中。而在这个过程中,“黑马”作为一个备受瞩目的品牌,其Web前…...

最新版jd-gui下载
对于java开发的工程师来说,jd-gui应该是经常会用到的工具了 官网的jd-gui目前只支持到JAVA13,更新版本JAVA编译出来的JAR包就反编译不出来了 此版本支持到了JAVA23 如果需要win以外的其他版本,可以查看我的其他上传 如果不想花积分&#…...

(051)FPGA时钟--->(001)时钟介绍
(001)时钟介绍 1 目录 (a)FPGA简介 (b)Verilog简介 (c)时钟简介 (d)时钟介绍 (e)结束 1 FPGA简介 (a)FPGA(Field Programmable Gate Array)是在PAL (可编程阵列逻辑)、GAL(通用阵列逻辑)等可编程器件的基础上进一步发展的产物。它是作为专用集成电…...