Rxjs 订阅触发不止一次

Question

我的订阅被多次触发非常神秘 - 我不知道我的错误是什么 - 我在另一个上采用了相同的方法，但它不会被触发多次

 @Injectable({
  providedIn: 'root'
})
export class CommonService {

  constructor() {
    this.getpatientId = this.bindPatientId.asObservable();
  }

  bindPatientId: Subject<number> = new Subject<number>();
  getpatientId: Observable<number>;

  setPatientId(patientId: number) {
    this.bindPatientId.next(patientId);
  }

  bindTabId: Subject<number> = new Subject<number>();
}

为Subject设置新值

 toggleProfile(patientId: number) {
    this.commonService.setPatientId(patientId);
    this.route.navigate(['/endrolPatient']);
  }

从另一个组件监听

ngOnInit() {
    this._common.getpatientId.subscribe(
      (res) => {
        this.patientID = res;
        console.log("console inside observable", this.patientID);
      });
}

在我的控制台中，当我通过 123 - 我得到 console inside observable 123 但在第一个观察者休息后，所有订阅都翻倍并在我的控制台中登录两次 - 请帮助我修复它

Answer 1

这可能是因为您的组件正在被销毁并再次创建。因此，当您的组件销毁时，您必须销毁所有订阅。你可以在ngOnDestroy生命周期方法中做到这一点

代码：

class MyComponent implements OnInit, OnDestroy {

private sub: Subscription;

ngOnInit() {
    this.sub = this._common.getpatientId.subscribe(
      (res) => {
        this.patientID = res;
        console.log("console inside observable", this.patientID);
      });
}

ngOnDestroy(){
   this.sub.unsubscribe():
}

Answer 2

每当您将主题用于所有事情时都使用行为主题！，我前段时间也遇到过这个问题，但这对我有用！

 bindPatientId: Subject<number> = new BehaviourSubject<number>();
 bindTabId: Subject<number> = new BehaviourSubject<number>();

订阅时，它返回主题的最后一个值。常规的 observable 只有在收到 onnext 时才会触发 你也可以使用

import { take } from 'rxjs/operators';

然后添加

.pipe(
  take(1)

在订阅之前

看这里 https://www.learnrxjs.io/operators/filtering/take.html

希望对你有帮助！