RxJS中Subscriber.unsubscribe()与complete()的区别解析

嘿，刚好对RxJS里这俩方法的区别挺熟的，结合你提到的多订阅者场景给你掰扯清楚～

先给你划个重点：这俩一个是单个订阅者的“主动离场操作”，一个是整个Observable数据流的“全局终止信号”，完全不是一个维度的东西，结合你的例子来看就更清晰了：

一、Subscriber.unsubscribe()：只关乎自己的“退订” #

• 这是某个订阅者专属的操作，只影响调用它的那个订阅者，和Observable本身、其他订阅者半毛钱关系都没有。
• 就像你说的，subscriber1调用unsubscribe()后，它自己就彻底切断了和这个Observable的连接，再也收不到任何next/error/complete通知，但subscriber2会继续正常接收数据，Observable也会该怎么运行还怎么运行。
• 本质上是这个订阅者主动释放自己持有的资源（比如定时器、网络请求连接），不会触发Observable的任何终止逻辑。

二、complete()：整个数据流的“落幕信号” #

首先得明确：complete()有两个身份——它既是Observer接口里的回调函数（用来接收Observable发来的终止通知），也是Observable可以调用的方法（用来向所有订阅者发送终止信号）。

• 当Observable调用subscriber.complete()时，这是整个数据流的终止指令：所有订阅这个Observable的订阅者都会收到complete通知，之后这个Observable会停止发射任何数据，并且所有订阅者都会自动触发自身的unsubscribe逻辑（释放资源）。
• 举个反例：如果你的Observable触发了complete，那不管是subscriber1还是subscriber2，之后都再也收不到任何数据了，整个数据流直接结束。

三、代码示例直观对比 #

给你写个简单的代码片段，一看就懂：

import { Observable } from 'rxjs';

// 创建一个每隔1秒发射递增数字的Observable
const numObservable = new Observable(subscriber => {
  let count = 0;
  const timer = setInterval(() => {
    subscriber.next(count++);
  }, 1000);

  // 退订时清理定时器
  return () => {
    clearInterval(timer);
    console.log('Observable资源已清理');
  };
});

// 订阅者1
const sub1 = numObservable.subscribe(val => console.log('sub1收到:', val));
// 订阅者2
const sub2 = numObservable.subscribe(val => console.log('sub2收到:', val));

// 3秒后，sub1主动退订
setTimeout(() => {
  sub1.unsubscribe();
  console.log('sub1已退订');
}, 3000);

// 8秒后，手动触发Observable的complete（实际场景会由内部逻辑触发）
setTimeout(() => {
  // 这里通过临时订阅触发complete，仅作示例
  numObservable.subscribe(subscriber => subscriber.complete());
  console.log('Observable已触发complete');
}, 8000);

运行这段代码你会看到：

• 前3秒，sub1和sub2都能收到数字0、1、2；
• 3秒后sub1退订，之后只有sub2继续收到3、4、5、6、7；
• 8秒后Observable触发complete，sub2收到终止通知，之后不再接收数据，同时Observable的定时器被清理。

最后再总结核心差异 #

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