angular 发布订阅

import { Subject } from 'rxjs/Subject';
import { Observable } from 'rxjs/observable';

export class MessageService {
    private subject = new Subject<any>();

    send(message: any) {
        this.subject.next(message);
    }

    get(): Observable<any> {
        return this.subject.asObservable();
    }
}

import { Component, OnInit } from '@angular/core';
import { Subject } from 'rxjs/Subject';
import { MessageService } from '../../service/message.service';

@Component({
  selector: 'app-video-demo-home',
  templateUrl: './video-demo-home.component.html',
  styleUrls: ['./video-demo-home.component.sass']
})
export class VideoDemoHomeComponent implements OnInit {

  private _clickPoint: Subject<any> = new Subject<any>();
  public name = 'www';
  constructor(public srv: MessageService) { }


  ngOnInit() {
  }

  clickBtn() {
    this.srv.send(this.name);
  }

}

import { Component, OnInit } from '@angular/core';
import { MessageService } from '../../service/message.service';

@Component({
  selector: 'app-subscribe-home',
  templateUrl: './subscribe-home.component.html',
  styleUrls: ['./subscribe-home.component.sass']
})
export class SubscribeHomeComponent implements OnInit {

  constructor(public srv: MessageService) { }
  public message = '';
  ngOnInit() {

    this.srv.get().subscribe((result) => {
      console.log('111111111111111111');
      this.message = result;
      console.log(this.message);
    });
  }

}