Node.js PostgreSQL客户端中实现通知监听与规则监控的问题

嘿，这个问题我之前也踩过坑！核心原因是你用process.nextTick(check)实现的循环，直接把Node.js的事件循环给“卡死”了，导致pg客户端的notification事件根本没机会执行。

为什么process.nextTick会阻塞事件？ #

Node.js的事件循环是分阶段运行的，process.nextTick属于微任务队列，这个队列会在每个宏任务阶段执行完毕后被彻底清空。当你递归调用process.nextTick(check)时，相当于在每次微任务队列处理时都塞一个新的check任务，事件循环永远跳不到处理IO事件的阶段（pg的通知是基于网络IO的，属于宏任务范畴），自然就没法触发notification回调了。

两种可行的解决方案 #

方案1：用setTimeout替代process.nextTick

把循环逻辑改成setTimeout，它属于宏任务，不会霸占事件循环：

function check() {
  // 这里写你的监控与时长累计逻辑
  // 比如遍历rules，计算每个对象的停留时长，判断是否触发告警

  // 用setTimeout替代process.nextTick，给事件循环留足处理IO的空间
  setTimeout(check, 100); // 可以根据需求调整间隔，不用死磕0毫秒
}
check();

这样每次check执行完后，事件循环会先处理其他宏任务（包括pg的通知），再执行下一次check，notification事件就能正常触发了。

方案2：基于事件驱动，避免轮询（更优）

其实你完全不需要持续轮询，结合notification事件维护对象生命周期，再用setInterval定期检查阈值就好：

var rules = {};
// 给每个规则维护加入时间，用于计算停留时长
const ruleTimestamps = {};

const pg_cli = new Client({ /* 你的数据库配置 */ });
pg_cli.connect();
pg_cli.query('LISTEN zone_rules');

pg_cli.on('notification', msg => {
  const payload = JSON.parse(msg.payload); // 假设payload是JSON格式的规则变更
  // 处理规则新增/更新
  if (payload.type === 'add' || payload.type === 'update') {
    rules[payload.id] = payload.data;
    // 记录当前时间，更新时可以重置时长起点
    ruleTimestamps[payload.id] = Date.now();
  }
  // 处理规则删除
  else if (payload.type === 'delete') {
    delete rules[payload.id];
    delete ruleTimestamps[payload.id];
  }
});

// 定期检查时长阈值
const CHECK_INTERVAL = 5000; // 比如每5秒检查一次
const THRESHOLD = 60000; // 阈值，比如1分钟
setInterval(() => {
  const now = Date.now();
  Object.keys(rules).forEach(ruleId => {
    const duration = now - ruleTimestamps[ruleId];
    if (duration > THRESHOLD) {
      // 这里写发送告警的逻辑
      console.log(`规则${ruleId}停留时长超过阈值，触发告警`);
      // 可选：告警后重置时间，避免重复发送
      // ruleTimestamps[ruleId] = now;
    }
  });
}, CHECK_INTERVAL);

这种方式更高效，只有在规则变更时才更新状态，定期检查也不会占用过多资源，同时完全不会阻塞事件循环，notification事件能正常工作。

总结 #

别用process.nextTick做无限循环，它会把事件循环锁死。优先选择基于事件驱动的方式，或者用setTimeout/setInterval来实现非阻塞的循环逻辑～

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