如何解决@aws-sdk/client-sqs的MaxListenersExceededWarning内存泄漏警告？

环境信息 #

• @aws-sdk/client-sqs: ^3.377.0
• Node.js: 18.20.2

问题重现 #

服务突然抛出如下警告并频繁重启：

(node:1) MaxListenersExceededWarning: Possible EventTarget memory leak detected. 11 abort listeners added to [AbortSignal]. Use events.setMaxListeners() to increase limit

解决方案 #

1. 停止复用全局AbortSignal实例 #

这个警告核心原因是同一个AbortSignal被绑定了超过默认上限（10个）的监听器，大多是因为全局复用信号实例导致的。每个请求要创建独立的AbortController，用完后及时清理：

// 错误示例：复用全局信号
const globalController = new AbortController();

// 正确示例：每个请求独立创建信号
const sendSqsMessage = async (messageParams) => {
  const controller = new AbortController();
  try {
    const command = new SendMessageCommand(messageParams);
    return await sqsClient.send(command, { signal: controller.signal });
  } finally {
    controller.abort(); // 及时释放资源
  }
};

2. 临时调高监听器上限（治标方案） #

如果暂时无法定位复用问题，可以先调高监听器上限缓解警告，但务必配合后续根因排查：

// 全局调整所有EventEmitter的默认上限
const { EventEmitter } = require('events');
EventEmitter.defaultMaxListeners = 20; // 根据实际情况调整数值

// 或针对单个AbortSignal实例调整
const controller = new AbortController();
controller.signal.setMaxListeners(20);

3. 确保SQS客户端单例复用 #

不要在每次请求时重复创建SQSClient实例，全局初始化一个单例即可，避免频繁创建客户端导致的资源泄漏：

// 全局初始化单例客户端
const { SQSClient } = require('@aws-sdk/client-sqs');
const sqsClient = new SQSClient({ region: 'your-region' });

// 所有请求复用该客户端
const sendMessage = async (params) => {
  const command = new SendMessageCommand(params);
  return await sqsClient.send(command);
};

4. 升级AWS SDK版本 #

3.377.0版本存在已知的AbortSignal资源泄漏问题，建议升级到3.400+的稳定版本，官方已修复相关漏洞。

5. 排查Pod内存泄漏与资源限制 #

频繁重启大概率是内存泄漏导致OOM被K8s杀死，可通过以下方式排查：

• 执行kubectl top pod <pod-name>查看实时内存占用
• 检查Pod的resources.requests和resources.limits配置，确保内存配额足够服务运行

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