TypeScript定时任务发布Redis数据偶现超时问题求助

我用TypeScript实现了100个间隔100ms的定时器，每个定时器仅执行向本地Redis发布数据的操作。大部分发布耗时不足10ms，但偶尔会出现耗时超100ms的情况；相同逻辑用Golang实现则无此问题，且已确认Redis服务器正常。TS代码如下：

import Redis from 'ioredis';

const redis = new Redis('redis://127.0.0.1:6379/0');

const frameState = "111"

for (let i = 0; i < 100; i++) {
    setInterval(() => {
        publishData()
    }, 100);
}

async function publishData() {
    let startTime = new Date().getTime()
    await redis.publish("11111", frameState)
    let endTime = new Date().getTime()
    if (endTime - startTime > 100) {
        console.log("pub data time", endTime - startTime)
    }
}

核心原因：Node.js单线程事件循环特性 #

Node.js基于单线程事件循环模型，所有宏任务（包括setInterval回调、I/O操作回调）都在主线程排队执行：

• 100个setInterval同时触发时，回调会被加入事件循环队列等待执行。如果此时主线程被其他任务短暂阻塞，或者队列中有积压任务，后续回调的执行时间会被推迟，叠加redis.publish的异步等待时间后，总耗时就可能超过100ms。
• Golang采用多线程+goroutine模型，每个定时器逻辑可在独立goroutine中执行，不存在单线程排队阻塞的问题，因此不会出现超时。

此外还有两个次要影响因素：

• setInterval精度限制：Node.js的setInterval不保证精确调度，当回调执行时间超过间隔、或事件循环积压时，下一次回调会自动推迟。
• Redis连接池瓶颈：ioredis默认连接池大小为10，100个并发请求会导致部分publish操作等待空闲连接，进一步增加耗时。

解决方案 #

1. 优化定时器逻辑，避免并发积压
   不要创建100个独立setInterval，改用单个定时器批量处理，或用setTimeout递归实现更可控的定时：

   // 单个定时器批量处理100次发布
   setInterval(async () => {
       // 用Promise.all控制并发，避免瞬间压满连接池
       await Promise.all(Array.from({length:100}, () => redis.publish("11111", frameState)));
   }, 100);
   

   或递归setTimeout，确保每次回调执行完成后再调度下一次：

   async function schedulePublish() {
       await redis.publish("11111", frameState);
       setTimeout(schedulePublish, 100);
   }
   // 启动100个递归定时器
   for (let i=0; i<100; i++) {
       schedulePublish();
   }
   

2. 调整Redis连接池配置
   增大ioredis连接池大小，匹配并发请求量：

   const redis = new Redis({
       host: '127.0.0.1',
       port: 6379,
       db: 0,
       poolSize: 100, // 与并发数一致
   });
   

3. 用Worker Threads隔离I/O任务
   将Redis发布任务放到Worker线程执行，避免阻塞主线程事件循环：

   // main.ts
   import { Worker } from 'worker_threads';
   for (let i=0; i<100; i++) {
       new Worker('./publish-worker.ts');
   }
   
   // publish-worker.ts
   import Redis from 'ioredis';
   const redis = new Redis('redis://127.0.0.1:6379/0');
   const frameState = "111";
   
   setInterval(async () => {
       const startTime = Date.now();
       await redis.publish("11111", frameState);
       const endTime = Date.now();
       if (endTime - startTime > 100) {
           console.log("pub data time", endTime - startTime);
       }
   }, 100);
   

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