使用Docker-Java监听Docker容器的信息

使用Docker-Java监听Docker容器的信息

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

什么是Docker-Java?

Docker-Java是一个开源的Java库,旨在通过Java程序与Docker守护进程进行通信。它提供了丰富的API,可以用于管理Docker容器、镜像、网络等各种资源。

安装Docker-Java

在开始之前,确保你已经安装了Docker,并且可以正常运行Docker命令,还需要开放23752376。然后,你需要在你的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来实现容器的监控与管理。

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

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

相关文章

[qt][报错】[Makefile:1293: moc_widget.cpp] Error 1

我的qt出现如下报错 [Makefile:1293: moc_widget.cpp] Error 1 出现问题的原因是变量放在slot或者signals里面了 放在public或者private就好了 具体细节看下面的两个文章 第一遍我没看懂 后来才理解 Qt学习笔记 [moc_***.cpp] Error 1_qt error1 moc-CSDN博客 Qt Error:…

2024年程序员接私活渠道大全,月入30k不是梦!

在专业的程序员私活接单平台出现之前&#xff0c;大多数程序员会选择通过技术论坛或是自身的人脉圈子捞单子&#xff0c;由于自身的资源有限且没有安全保障&#xff0c;程序员私活一般很难开张&#xff0c;而现在大量的互联网私活平台兴起&#xff0c;有了平台的资源和监管&…

Cohere reranker 一致的排序器

这本notebook展示了如何在检索器中使用 Cohere 的重排端点。这是在 ContextualCompressionRetriever 的想法基础上构建的。 %pip install --upgrade --quiet cohere %pip install --upgrade --quiet faiss# OR (depending on Python version)%pip install --upgrade --quiet…

vue.js有哪几种甘特图库?Vue.js的5大甘特图库分享!

vue.js有哪几种甘特图库?Vue.js的5大甘特图库分享&#xff01; 如今&#xff0c;软件市场为任何复杂程度的项目提供了各种现成的计划和调度工具&#xff0c;但这些解决方案可能包含过多的功能或缺乏一些必要的功能。这就是为什么许多公司更愿意投资开发基于网络的定制解决方案…

下载elasticsearch-7.10.2教程

1、ES官网下载地址 Elasticsearch&#xff1a;官方分布式搜索和分析引擎 | Elastic 2、点击下载Elasticsearch 3、点击 View past releases&#xff0c;查看过去的版本 4、选择版本 Elasticsearch 7.10.2&#xff0c;点击 Download&#xff0c;进入下载详情 5、点击 LINUX X8…

基于jeecgboot-vue3的Flowable流程-流程处理(二)

因为这个项目license问题无法开源&#xff0c;更多技术支持与服务请加入我的知识星球。 对应VForm3&#xff0c;原先的后端解析也要做调整 1、获取历史任务的表单信息 // 获取历史任务节点表单数据值List<HistoricVariableInstance> listHistoricVariableInstance his…

Flask快速入门(路由、CBV、请求和响应、session)

Flask快速入门&#xff08;路由、CBV、请求和响应、session&#xff09; 目录 Flask快速入门&#xff08;路由、CBV、请求和响应、session&#xff09;安装创建页面Debug模式快速使用Werkzeug介绍watchdog介绍快速体验 路由系统源码分析手动配置路由动态路由-转换器 Flask的CBV…

meilisearch的索引(index)的最佳实践

官网的第一手资料学新技术&#xff1a;meilisearch官方文档 安装的官网地址&#xff1a;meilisearch安装的官网 部署在生产环境的指导&#xff1a;meilisearch部署在生产环境的指导 Elasticsearch 做为老牌搜索引擎&#xff0c;功能基本满足&#xff0c;但复杂&#xff0c;重…

CentOS系统自带Python2无法使用pip命令

Linux运维工具-ywtool 目录 一. 系统环境二.解决三.验证四.备注(1)输入"yum install -y python-pip",提示没有可用 python-pip包(2)安装完pip后进行升级 一. 系统环境 centos7系统自带的python2.7无法使用pip命令 二.解决 yum install python-pip -y三.验证 pip…

供应链初学者手册——第五部分:信息技术在供应链中的应用

供应链初学者手册 文章目录 供应链初学者手册第五部分&#xff1a;信息技术在供应链中的应用10. 供应链信息系统10.1 SCM 系统的介绍10.2 ERP 系统在供应链中的应用 11. 物联网和区块链技术11.1 物联网在供应链中的应用11.2 区块链技术的潜在应用 总结 第五部分&#xff1a;信息…

华为鸿蒙HarmonyOS应用开发者高级认证题库

判断题 1、云函数打包完成后&#xff0c;需要到AppGallery Connect创建对应函数的触发器才可以在端侧中调用 错 2、在column和Row容器组件中&#xff0c;aligntems用于设置子组件在主轴方向上的对齐格式&#xff0c;justifycontent用于设置子组件在交叉轴方向上的对齐格式 错…

Roboflow 图片分类打标

今天准备找个图片标注工具&#xff0c;在网上搜了一下&#xff0c;看 Yolo 的视频中都是用 Roboflow 工具去尝试了一下&#xff0c;标注确实挺好用的&#xff0c;可以先用一些图片训练一个模型&#xff0c;随后用模型进行智能标注。我主要是做标注然后到处到本地进行模型的训练…

RK3588开发笔记-100M网口自协商成1000M网口

目录 前言 一、问题描述 二、原理图连接 三、解决方法 总结 前言 在进行RK3588开发过程中,遇到一个令人困惑的问题:在使用RTL8211F-CG phy芯片出来的100M网口在自协商后连接速率变成了1000M。这篇博客将详细记录这个问题的产生、排查过程以及最终的解决方案,希望能对遇到…

java 中动态数组向下转型

介绍 接的上面的&#xff0c;现在我们在两个子类student 和teacher中分别添加study 和teacher方法&#xff0c;但父类中没有该方法。那么就需要用到我们的向下转型了 代码 student package hansunping;public class student extends person {private String name;public in…

上心师傅的思路分享(三)--Nacos渗透

目录 1. 前言 2. Nacos 2.1 Nacos介绍 2.2 鹰图语法 2.3 fofa语法 2.3 漏洞列表 未授权API接口漏洞 3 环境搭建 3.1 方式一: 3.2 方式二: 3.3 访问方式 4. 工具监测 5. 漏洞复现 5.1 弱口令 5.2 未授权接口 5.3.1 用户信息 API 5.3.2 集群信息 API 5.3.3 配置…

Android基础-运行时权限

一、引言 随着智能手机和移动互联网的普及&#xff0c;Android操作系统作为其中的佼佼者&#xff0c;其安全性问题日益受到关注。为了保障用户数据的安全和隐私&#xff0c;Android系统引入了权限机制来管理和控制应用程序对系统资源和用户数据的访问。特别是在Android 6.0&am…

借力AI,助力网络钓鱼(邮件)检测

引言 互联网时代&#xff0c;邮件系统依然是人们工作、生活中的很重要的一部分&#xff0c;与此同时&#xff0c;邮件系统的发展带来的钓鱼邮件问题也成为网络中的最大的安全隐患之一。本文将为大家解开网络钓鱼&#xff08;邮件&#xff09;的神秘面纱&#xff0c;一探究竟&a…

Unity3D Shader数据传递语法详解

在Unity3D中&#xff0c;Shader是用于渲染图形的一种程序&#xff0c;它定义了物体在屏幕上的外观。Shader通过接收输入数据&#xff08;如顶点位置、纹理坐标、光照信息等&#xff09;并计算像素颜色来工作。为了使得Shader能够正确运行并产生期望的视觉效果&#xff0c;我们需…

和利时DCS数据采集对接安监平台

在工业互联网日益繁荣的今天&#xff0c;工业数据的采集、传输与利用变得至关重要。特别是在工业自动化领域&#xff0c;数据的实时性和准确性直接关系到生产效率和安全性。和利时DCS&#xff08;分布式控制系统&#xff09;以其卓越的稳定性和可靠性&#xff0c;在工业自动化领…

Ubuntu 24.04 屏蔽snap包

Ubuntu 24.04 屏蔽snap包 屏蔽 这里所说的屏蔽指的是&#xff1a;禁止sudo apt install firefox时安装snap版本的包。 如需卸载snap&#xff0c;请使用关键词搜索。 命令行 cat <<EOF | sudo tee /etc/apt/preferences.d/snap-apps-disable Package: chromium* firef…