Prom-client指标在Worker线程中始终显示0值的问题

Node.js Worker线程拥有独立的运行环境和内存空间，你在Worker中导入的gauge1是一个全新的实例，和主线程Metrics接口使用的Registry里的gauge1完全不是同一个对象。Worker里修改的是自己的实例值，主线程的Registry自然看不到变化，所以指标始终显示0。

因为Worker和主线程无法直接共享内存中的对象，所以需要通过postMessage将指标更新的指令或值传递给主线程，由主线程来更新共享的Gauge实例。

1. 修正主线程代码（Main.js） #

在主线程中监听Worker的消息，收到更新指令后直接操作共享的gauge1：

// Main.js file
import { router as metricApiRoute, register, gauge1 } from 'api/route/matrics';
import { Worker } from 'worker_threads';
import { router as metricRoutes } from '/api/route/mymatrics';

export const workerupdate = new Worker('/worker/myfile.js');

// 监听Worker发来的指标更新消息
workerupdate.on('message', (msg) => {
  if (msg.type === 'update_gauge') {
    gauge1.set(msg.value);
  }
});

2. 修改Worker的业务逻辑（processdata.ts） #

移除Worker中对gauge1的导入，改为业务完成后给主线程发更新通知：

// Src/worker/processdata.ts
import { parentPort } from 'worker_threads';

async function processData(){
  // 这里执行你的核心业务逻辑
  // 业务完成后，通知主线程更新指标
  parentPort?.postMessage({ type: 'update_gauge', value: 1 });
}

export default processData;

3. 调整Worker入口文件（myfile.ts） #

无需再导入指标实例，保持原有消息监听逻辑即可：

// myfile.ts file
import { parentPort } from 'worker_threads';
import processData from './processData';

if (parentPort !== null ) {
    parentPort.on('message', async (event: string) => {
        if (event === 'update') {
            await processData();
            parentPort.postMessage('update_completed'); 
        }
    });
}

4. 修正Metrics文件的语法错误（routes/api/metrics.ts） #

修复代码中的语法问题，确保Registry和Gauge实例正常导出：

// routes/api/metrics.ts file
import express from 'express'; 
import client from 'prom-client';

const register = new client.Registry();
client.collectDefaultMetrics({ register }); 

export const gauge1 = new client.Gauge({
   name:'testing',
   help:'testing gauge'
});
register.registerMetric(gauge1); // 修正方法名：registerMetric

export const router = express.Router();
router.get('/', async (req, res) => {
  res.setHeader('Content-Type', register.contentType); 
  res.send(await register.metrics());
});

• 不要在Worker中直接操作prom-client的指标实例，Worker实例与主线程完全隔离
• 线程间消息仅支持可序列化数据，不能直接传递对象实例
• 若需更新多个指标，可扩展消息格式，比如传递包含多组指标键值对的对象

内容的提问来源于stack exchange，提问作者Aks