import { Injectable } from '@angular/core'; import { webSocket } from 'rxjs/webSocket';
@Injectable() export class WebSocketService { socket;
constructor() {
this.socket = webSocket('ws://localhost:8080/ws'); //连接服务端WebSocket
}
// 订阅WebSocket数据
subscribe(topic: string) {
return this.socket.asObservable().filter(message => message.topic === topic);
}
// 发送WebSocket数据
send(message: any) {
this.socket.next(message);
}
}