Angular RxJS Subject先发射值后订阅仍收到值的原因是什么？

问题解答 #

普通Subject的特性确实是仅向订阅完成后的观察者推送新产生的事件，订阅之前已经发射的事件会直接丢失，这和你看到的文章描述完全一致，你遇到的现象和文章结论不冲突，本质是两段代码的执行顺序完全不同。

两段代码的执行顺序对比

文章示例的执行流：

1. 初始化Subject实例
2. 同步调用subject.next('test')发射事件
3. 调用subscribe方法注册观察者
   第二步的next是同步执行，第三步订阅时事件已经推送完毕，自然不会有输出。

你的代码的实际执行流：

1. 应用启动时，根注入的AuthService率先实例化，完成user Subject的初始化
2. 页面加载阶段HeaderComponent初始化，ngOnInit钩子执行，先完成了对user Subject的订阅
3. 后续用户触发登录操作，才会调用login方法发起异步HTTP请求
4. 后端返回响应后，才会执行handleAuthentication中的this.user.next(user)逻辑发射用户事件
   此时订阅逻辑早已执行完成，观察者处于监听状态，自然可以正常收到推送的值，你贴出的运行日志也能验证这个时间顺序。

如何复现文章中的问题

如果你想复现文章里的“订阅后拿不到之前发射的值”的现象，只需要在AuthService构造函数中同步发射一个测试值即可：

constructor(private httpClient:HttpClient){
  // 实例化阶段同步发射测试值，此时Header组件还未完成订阅
  this.user.next(new User('test@test.com', '1', 'test-token', new Date()));
}

这个同步发射的值会在订阅逻辑执行前推送完成，你的订阅回调不会收到这个值，完全符合文章的描述。

拓展最佳实践

如果你的业务场景需要支持“晚订阅的观察者也能获取到最近一次的用户状态”，可以把普通Subject替换为BehaviorSubject，它会自动缓存最新的发射值，新订阅注册时会主动把缓存值推送给观察者：

// 替换Subject定义，设置初始值为null（表示未登录状态）
user = new BehaviorSubject<User | null>(null);

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