Node.js使用RxJS时try块执行后finally块未执行，程序以0码退出

嘿，我之前也踩过这个坑！你遇到的这个情况，核心原因是Node.js的事件循环机制加上RxJS订阅不属于Node.js的“活跃异步资源”，再加上你没有等待异步函数执行完成导致的。

先把你的复现代码整理出来，方便大家理解：

const { BehaviorSubject } = require('rxjs');
const { first, share } = require('rxjs/operators');

async function test() {
  try {
    const subject = new BehaviorSubject('test');
    // 用share()把Observable转为多播
    const obs = subject.asObservable().pipe(share());
    // 创建一个无处理逻辑的订阅
    obs.subscribe();
    // 等待第一个值转为Promise
    const result = await obs.pipe(first()).toPromise();
    console.log('Result:', result);
  } catch (err) {
    console.error('Error:', err);
  } finally {
    console.log('Finally block executed'); // 这段代码没执行！
  }
}

// 直接调用异步函数，但没有等待它完成
test();

问题原因拆解 #

• 异步函数未被等待：你调用了test()这个异步函数，但没有用await或者.then()等待它的Promise完成。Node.js的事件循环会在当前同步任务和微任务处理完后，检查是否还有活跃的异步资源（比如定时器、网络连接、文件句柄等），如果没有就直接退出进程。
• RxJS订阅不算“活跃资源”：你创建的obs.subscribe()订阅虽然存在，但RxJS的订阅是基于内存的逻辑订阅，不属于Node.js会跟踪的活跃异步资源。所以当await obs.first().toPromise()完成后，test()函数剩下的代码（包括finally块）虽然在微任务队列里，但Node.js可能在处理微任务前就判断没有活跃资源，直接退出了。
• share()的间接影响：share()让Observable变成多播，但它本身不是导致问题的直接原因——就算你去掉share()，只要不等待异步函数完成，还是会出现同样的情况。只不过share()的多播特性让订阅的生命周期更隐蔽，容易让你误以为有活跃订阅会阻止进程退出。

解决方案 #

这里有两个最直接的解决办法：

1. 等待异步函数执行完成

最简单的方式是确保Node.js等待test()的Promise完成，这样finally块就能正常执行。你可以用IIFE（立即执行异步函数）来包裹调用：

(async () => {
  await test();
})().catch(err => {
  console.error('Unhandled error:', err);
});

或者直接在调用时监听Promise的完成：

test().then(() => {
  console.log('Test function completed');
}).catch(err => {
  console.error('Error occurred:', err);
});

这样Node.js会等待异步函数的所有逻辑（包括finally块）执行完毕后再退出。

2. 手动保持进程活跃（如果需要长期运行）

如果你需要程序因为RxJS的订阅保持长期运行（比如一个后台服务），可以用Node.js的process.stdin.resume()来阻止进程退出，在finally块里再暂停：

async function test() {
  try {
    const subject = new BehaviorSubject('test');
    const obs = subject.asObservable().pipe(share());
    obs.subscribe();
    // 保持进程活跃
    process.stdin.resume();
    const result = await obs.pipe(first()).toPromise();
    console.log('Result:', result);
  } catch (err) {
    console.error('Error:', err);
  } finally {
    console.log('Finally block executed');
    // 允许进程退出
    process.stdin.pause();
  }
}

test();

这样Node.js会因为有活跃的stdin资源而保持运行，直到finally块里暂停stdin，进程才会退出。

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