RxJS：如何定义subscribe调用后执行的逻辑？

很棒的问题！针对你想要的「只定义一次逻辑，每次订阅Observable时自动执行，且遵循单一职责原则」的需求，有几个RxJS方案完美贴合你的场景：

1. RxJS 7+ 首选：带subscribe回调的tap操作符 #

从RxJS 7开始，tap操作符支持传入一个配置对象，其中的subscribe回调会在每次订阅发生时立即执行——刚好对应你“subscribe调用后执行逻辑”的要求。而且你只需要在Observable链里定义一次，所有后续的订阅都会自动触发这段逻辑，完全符合单一职责原则，比如拦截器里统一处理缓存、服务层只负责订阅的场景。

示例代码：

import { of, tap } from 'rxjs';

const source = of(1);
const example = source.pipe(
  tap({
    next: val => console.log('do called'), // 保留原do操作符的逻辑
    subscribe: () => console.log('subscribe调用后执行的统一逻辑')
  })
);

example.subscribe(val => console.log('subscribe called'));
// 输出顺序：
// subscribe调用后执行的统一逻辑
// do called
// subscribe called

如果你的需求是让这段统一逻辑在订阅者的回调执行之后运行，可以结合微任务调度调整顺序：

const example = source.pipe(
  tap({
    next: val => {
      console.log('do called');
      // 用微任务让逻辑在订阅者回调之后执行
      queueMicrotask(() => console.log('订阅者回调执行完后触发的逻辑'));
    }
  })
);

example.subscribe(val => console.log('subscribe called'));
// 输出顺序：
// do called
// subscribe called
// 订阅者回调执行完后触发的逻辑

2. RxJS 7之前版本：用defer创建Observable #

如果你还在使用RxJS 7之前的版本，defer操作符是另一个好选择。它会在每次订阅时重新创建Observable实例，你可以把统一逻辑放在defer的工厂函数里，这样每次调用subscribe时都会触发这段逻辑：

import { of, defer } from 'rxjs';
import { tap } from 'rxjs/operators';

const source = of(1);
const example = defer(() => {
  console.log('subscribe调用后执行的统一逻辑');
  return source.pipe(
    tap(val => console.log('do called'))
  );
});

example.subscribe(val => console.log('subscribe called'));
// 输出顺序和第一个示例一致

为什么这些方案符合你的需求？ #

• 只定义一次：统一逻辑写在Observable链中，所有订阅者共享，不用在每个subscribe里重复代码
• 每次订阅都执行：tap的subscribe回调或defer的工厂函数，会在每次调用subscribe时触发
• 遵循单一职责原则：缓存等通用逻辑集中在拦截器/Observable链里，服务层只负责业务相关的订阅，职责清晰分离

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