ng g service event 

import { Injectable } from '@angular/core';import { Subject } from 'rxjs';@Injectable({  providedIn: 'root'})export class EventService {  // 構(gòu)建Subject的實(shí)例，用來(lái)完成事件的發(fā)布和訂閱  private subject = new Subject < any > ();  constructor() {}  publish(value: any, err: any) {    if (value !== undefined) {      // 將新的事件放入next隊(duì)列中      this.subject.next(value);    }    if (err !== undefined) {      // 將錯(cuò)誤放入error隊(duì)列      this.subject.error(err);    }    // 表示當(dāng)前事件結(jié)束    this.subject.complete();  }  subcribe(handler: {   next: (value) => void,   error: (err) => void,   complete: () => void  }) {    this.subject.asObservable().subcribe(handler);  }}

@NgModule({ declarations: [], imports: [], providers: [EventService], bootstrap: [AppComponent]})export class AppModule { }

export class AComponent implements OnInit { constructor(  private event: EventService ) { } ngOnInit() { } someThingChanged(data) {  // 發(fā)布事件  this.event.publish({   // 可以定義一個(gè)事件類(lèi)型，實(shí)現(xiàn)多個(gè)不同類(lèi)型事件的發(fā)布   type: 'event_type_you_want_define',   // 可以攜帶任何數(shù)據(jù)，并通過(guò)事件發(fā)布出去   data: data,   ohter: 'ohter things you want to pass out'  }, err); }}

export BComponent implements OnInit { constructor(  private event: EventService ) { } ngOnInit() {   // 在初始化方法中，可以完成對(duì)事件的訂閱工作  this.event.subject({   next: value => {    // 可以通過(guò)約定事件類(lèi)型，在這里進(jìn)行檢查，從而完成不同的邏輯    // do something with value   },   error: err => {    // handle err   },   complete: () => {    // handle complete   }  }) }}