### 在 Node.js 中获取当前运行的 Docker 容器的实时内存和 CPU 使用情况 为了在 Node.js 程序中监控其所在的 Docker 容器的实时内存和 CPU 占用情况，可以采取两种主要方法：一种是直接读取 Linux 控制组（cgroups）文件系统的数据；另一种是通过 Docker 的标准 API 获取容器的统计数据。 --- #### 1. **通过 cgroups 文件系统读取** Linux 的控制组（Control Groups, cgroups）允许开发者直接访问容器的资源使用情况。以下是如何从 `/sys/fs/cgroup/` 路径下读取内存和 CPU 数据的方法。 ##### （1）获取内存使用情况 可以通过读取 `memory.usage_in_bytes` 和 `memory.limit_in_bytes` 来计算容器的实际内存使用率。 ```javascript const fs = require('fs'); function getMemoryUsage() { const memoryUsagePath = '/sys/fs/cgroup/memory/memory.usage_in_bytes'; const memoryLimitPath = '/sys/fs/cgroup/memory/memory.limit_in_bytes'; try { const memoryUsage = parseInt(fs.readFileSync(memoryUsagePath, 'utf8'), 10); const memoryLimit = parseInt(fs.readFileSync(memoryLimitPath, 'utf8'), 10); return { used: memoryUsage, limit: memoryLimit, percentage: (memoryUsage / memoryLimit) * 100 }; } catch (error) { console.error("Error reading memory stats:", error.message); throw error; } } console.log(getMemoryUsage()); ``` 这段代码会返回一个对象，其中包含已使用的内存、总限制以及百分比 [^1]。 ##### （2）获取 CPU 使用情况 CPU 统计信息存储在 `cpuacct.stat` 文件中，记录了用户态和内核态的时间片数量。 ```javascript function getCpuStats() { const cpuStatPath = '/sys/fs/cgroup/cpuacct/cpuacct.stat'; try { const content = fs.readFileSync(cpuStatPath, 'utf8'); const lines = content.trim().split('\n'); const userCpuTicks = parseInt(lines[0].split(/\s+/)[1], 10); const systemCpuTicks = parseInt(lines[1].split(/\s+/)[1], 10); return { userCpuTicks, systemCpuTicks, totalCpuTicks: userCpuTicks + systemCpuTicks }; } catch (error) { console.error("Error reading CPU stats:", error.message); throw error; } } console.log(getCpuStats()); ``` 此函数返回的是自容器启动以来累积的 CPU 时间片数 [^2]。 需要注意的是，仅靠这些原始数据无法直接得到 CPU 利用率，还需要结合宿主机的整体 CPU 核心数和其他上下文信息进行进一步计算。 --- #### 2. **通过 Docker API 获取** 如果希望以更加抽象的方式获取容器的资源使用情况，可以使用 Docker 提供的标准 RESTful API 或者第三方库如 `dockerode`。 ##### （1）安装依赖 首先需要安装 `dockerode` 库： ```bash npm install dockerode ``` ##### （2）实现代码 以下是一个完整的示例，展示如何通过 `dockerode` 获取当前容器的实时资源使用情况。 ```javascript const Docker = require('dockerode'); const docker = new Docker({ socketPath: '/var/run/docker.sock' }); async function getContainerStats(containerId) { try { const container = docker.getContainer(containerId); const statsStream = await container.stats({ stream: false }); // 设置为非流模式 const statsData = await new Promise((resolve, reject) => { let body = ''; statsStream.on('data', chunk => (body += chunk)); statsStream.on('end', () => resolve(JSON.parse(body))); statsStream.on('error', err => reject(err)); }); const { memory_stats, precpu_stats, cpu_stats } = statsData; // 计算内存使用率 const memoryUsed = memory_stats.usage; const memoryLimit = memory_stats.limit; const memoryPercentage = (memoryUsed / memoryLimit) * 100; // 计算 CPU 使用率 const cpuDelta = cpu_stats.cpu_usage.total_usage - precpu_stats.cpu_usage.total_usage; const systemDelta = cpu_stats.system_cpu_usage - precpu_stats.system_cpu_usage; const numCpus = cpu_stats.online_cpus || Object.keys(cpu_stats.cpu_usage.percpu_usage).length; const cpuPercentage = (cpuDelta / systemDelta) * numCpus * 100; return { memory: { used: memoryUsed, limit: memoryLimit, percentage: memoryPercentage.toFixed(2) }, cpu: { percentage: cpuPercentage.toFixed(2) } }; } catch (error) { console.error("Error fetching container stats:", error.message); throw error; } } // 替换为实际的容器 ID 或名称 getContainerStats(process.env.HOSTNAME).then(stats => console.log(stats)).catch(console.error); ``` 上述代码实现了以下几个功能： - 连接到本地 Docker Daemon。 - 请求目标容器的统计信息。 - 解析 JSON 数据并计算内存和 CPU 的利用率 [^3]。 --- #### 注意事项 1. 默认情况下，只有 root 用户有权访问 `/var/run/docker.sock`，因此需要确保程序有足够的权限。 2. 如果是在 Kubernetes 环境中运行，则可能需要额外配置服务账户或其他授权机制。 3. 对于大规模集群环境，建议集成 Prometheus 和 Grafana 等工具来进行集中化的性能监控。 --- ###