服务来通讯并监听

//新建服务 
import { Injectable } from &＃39;&＃64;angular/core&＃39;;
import { Subject } from &＃39;rxjs&＃39;;
&＃64;Injectable({providedIn: &＃39;root&＃39;
})
export class ChatMsgService {private msgSource&＃61;new Subject();msgSend$&＃61;this.msgSource.asObservable();chatMsg(msg:string){this.msgSource.next(msg);}
}


//引入服务并发送信息
import { Injectable } from &＃39;&＃64;angular/core&＃39;;
import {StorageService} from &＃39;../service/storage.service&＃39;;
import { Observable, of,Subject } from &＃39;rxjs&＃39;;
import {ChatMsg} from &＃39;../chat/class/chat-msg&＃39;;
import {ChatMsgService} from &＃39;./chat-msg.service&＃39;;
&＃64;Injectable({providedIn: &＃39;root&＃39;
})export class SocketService {ws:any;private chatMsg&＃61;new Subject();constructor(private storages:StorageService,private chatMsgService:ChatMsgService) {// let user&＃61;this.storage.getItem("user");this.ws&＃61;new WebSocket("ws://47.52.96.184:9502");let user&＃61;this.storages.getItem("user");this.ws.onclose &＃61; ()&＃61;>{// alert("连接已关闭...");}let obj1&＃61;{"id":user.id,"username":user.username,"type":1,};obj1&＃61;JSON.stringify(obj1);this.onSend(obj1);this.onMessage();}onSend(data:string){this.ws.onopen&＃61;()&＃61;>{// Web Socket 已连接上&＃xff0c;使用 send() 方法发送数据this.ws.send(data);}}onMessage(){this.ws.onmessage &＃61;(evt)&＃61;>{console.log(evt.data);this.chatMsgService.chatMsg(evt.data);}}}


//监听服务constructor(private socket:SocketService,private request:RequestService,private srv: ɵcd,private chatMsgService:ChatMsgService){}pages:Pages&＃61;new Pages(0,0,0,0);ngOnInit() {this.getFriendsList();this.chatMsgService.msgSend$.subscribe((msg)&＃61;>{console.log(msg);})}