Jest集成测试如何实现即发即忘事件的回调信号控制

核心场景矛盾 #

• 内存模拟的RPC连接的通知接口是即发即返的，调用sendNotification后不会等待服务端所有异步流程跑完
• 服务端注册的通知回调固定要求返回void，不能靠让框架自动await回调返回值的方式做流程同步，且明确要求不允许修改原有接口契约
• 测试不能靠写死的sleep固定等待时间，既要避免CI环境下调度延迟导致的偶发超时，也要精准等到「收到第5条符合预期的请求」的时间点再执行断言

落地实现步骤 #

1. 实现测试侧专用的信号同步工具 #

不需要引入第三方库，纯手写可控的Promise信号源即可，完全不侵入业务代码：

class TestSignal {
  private resolveCallback!: () => void;

  // 等待信号触发，默认带10s超时兜底，避免测试永久卡死
  waitAsync(timeoutMs = 10000): Promise<void> {
    return new Promise((resolve, reject) => {
      this.resolveCallback = resolve;
      setTimeout(() => {
        reject(new Error(`等待信号超时：未在${timeoutMs}ms内满足触发条件`))
      }, timeoutMs)
    })
  }

  // 满足测试条件时触发，放行测试流程
  release() {
    this.resolveCallback?.()
  }
}

2. 对齐异步时序的核心逻辑 #

服务端的handleNotification是异步方法，注册给连接的回调会直接丢弃这个方法返回的Promise，整个异步链路完全由事件循环调度：

• 当服务端执行到await this.connection.sendRequest(requestData)时，模拟RPC的连接会把消息投递到客户端连接的回调队列
• 我们在客户端的onRequest回调里做计数，只有累计收到5条请求时才触发信号release，这个触发点刚好对应服务端异步流程执行到对应节点的时刻，不存在时序错位
• 全程不需要修改业务侧的回调签名、连接接口，完全符合“不修改原有接口契约”的要求

3. 补全测试用例的细节问题 #

原有的测试逻辑框架已经正确，只需要补充独立初始化、回调判空的细节即可：

it('fire and forget with callback', async () => {
  // 每个用例独立初始化变量，避免跨用例状态污染
  const receivedRequests = [];
  const signal = new TestSignal();

  // 注册客户端的请求接收回调
  clientConnection.onRequest((requestData) => {
    receivedRequests.push(requestData);
    // 满足预设条件时触发信号
    if (receivedRequests.length === 5) {
      signal.release();
    }
  });

  // 触发首条通知，启动整条异步链路
  clientConnection.sendNotification(usefulTestData);

  // 等信号触发后再执行断言
  await signal.waitAsync();
  expect(receivedRequests).toEqual(expectedTestDataArrFromFile);
});

常见踩坑提醒 #

不要尝试修改业务侧的回调逻辑为async (notificationData) => { await this.handleNotification(notificationData) }后在外层等待返回值——连接的通知API本身就不处理回调的返回值，这么改既无法实现同步效果，还违反了不修改接口的约束，属于无效操作。

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