Angular中Observable的observer.next为何会自动触发？

嘿，这个问题一点都不基础——RxJS的Observable订阅机制刚开始接触确实容易搞混，我来给你掰扯清楚！

首先你要明白：当你调用Observable的subscribe()方法时，Observable内部的执行函数（就是你传给new Observable()的那个回调函数）会立刻被触发执行。

拆解你的代码来看：

1. 你创建的data$是一个Observable对象，它的构造函数接收了一个回调函数，这个函数里包含了observer.next('message 1')这行代码。
2. 当你调用data$.subscribe(s => console.log(s))时，RxJS会立刻去执行这个回调函数，也就是把你定义的那个Observer（订阅时传入的回调其实会被包装成Observer实例）传给这个执行函数，然后执行函数里的observer.next()就会被调用，把'message 1'推送给订阅者，所以你立刻在控制台看到了输出。

这里还要提一个概念：你创建的这种是冷Observable——它的执行函数只会在有订阅者的时候才会运行，而且每个新的订阅都会重新触发一遍执行函数。比如如果你再写一次data$.subscribe(...)，控制台会再打印一次'message 1'，因为执行函数又被执行了一次。

举个异步的例子你会更清楚时机：

ngOnInit(): void { 
  let data$ = new Observable((observer: Observer<string>) => {
    // 把next放在异步操作里
    setTimeout(() => {
      observer.next('message 1');
    }, 1000);
    console.log('执行函数已经被触发');
  }); 
  data$.subscribe(s => console.log(s)); 
}

这个时候，你订阅后会立刻看到执行函数已经被触发，然后1秒后才会看到'message 1'——这说明执行函数是订阅时立刻运行的，只是里面的observer.next()是异步执行的而已。

总结一下核心点：

• Observable本身只是一个“蓝图”，描述了如何产生数据，但不会主动执行。
• 只有当调用subscribe()时，这个蓝图才会被激活（执行函数运行），里面的observer.next()才会按照你写的逻辑被调用。
• 你代码里的observer.next()是同步代码，所以订阅一发生就立刻执行了。

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