Try Catch无法捕获Uncaught Exception？bee-queue连接异常问题

问题根源 #

你的代码捕获逻辑本身没有问题，异常无法被捕获的核心原因是：bee-queue的connect方法或其依赖的Redis客户端在处理连接失败时，错误未被正确包裹进Promise链，或是存在同步抛出的异常（异步捕获逻辑无法覆盖这类场景）。

可行修复方案 #

1. 补充监听unhandledRejection事件

Node中未处理的Promise拒绝会触发unhandledRejection事件，而非uncaughtException（后者主要处理同步错误）。你当前只监听了uncaughtException，先补上这个监听定位错误：

process.on("uncaughtException", err => console.error('未捕获同步错误:', err));
process.on("unhandledRejection", (reason, promise) => {
  console.error('未处理的Promise拒绝:', reason);
  // 按需执行清理逻辑后退出
  process.exit(1);
});

2. 手动包裹bee-queue的连接逻辑

强制将bee-queue的连接操作放入自定义Promise中，覆盖同步和异步错误场景：

async function safeQueueConnect(queue) {
  return new Promise((resolve, reject) => {
    try {
      queue.connect()
        .then(resolve)
        .catch(reject);
    } catch (err) {
      // 捕获同步抛出的错误
      reject(err);
    }
  });
}

// 在start中替换原调用
async function start() {
  try {
    await safeQueueConnect(queue);
  } catch (err) {
    console.error('Some Error:', err.message);
  }
}

3. 绕过bee-queue，手动管理Redis连接

直接操作bee-queue底层的Redis客户端，确保连接逻辑完全在自己的Promise控制下：

// 假设bee-queue使用ioredis作为Redis客户端
const Redis = require('ioredis');

// 手动创建Redis客户端
const redisClient = new Redis({
  host: '127.0.0.1',
  port: 6090,
  // 匹配bee-queue的其他Redis配置
});

async function manualConnect() {
  try {
    await redisClient.connect();
    console.log('Redis连接成功');
    // 将手动创建的客户端传入bee-queue
    const queue = require('bee-queue')('my-queue', {
      redis: redisClient
    });
    return queue;
  } catch (err) {
    console.error('Redis连接失败:', err);
    throw err;
  }
}

// 启动逻辑
start().catch(console.error);
async function start() {
  try {
    const queue = await manualConnect();
    // 后续队列操作
  } catch (err) {
    console.error('启动失败:', err.message);
  }
}

4. 调整依赖版本

当前Node v20.18.0与你使用的bee-queue版本可能存在兼容性问题：

• 升级bee-queue到最新稳定版，查看是否修复了Promise包裹问题
• 若升级无效，尝试降级到bee-queue v1.x版本（部分用户反馈v2.x在高Node版本下有异常捕获问题）

验证逻辑 #

替换client.connect()为模拟错误时捕获正常，说明你的代码逻辑本身没问题，问题出在bee-queue或其Redis客户端的底层实现。按上述方案逐一验证，优先补充unhandledRejection监听定位错误类型。

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