angular websocket

Angular提供了一个名为`WebSocketSubject`的类，它允许我们使用WebSocket与服务器进行双向通信。

首先，需要导入WebSocketSubject：

import { WebSocketSubject } from 'rxjs/webSocket';

接下来，可以在组件的构造函数中创建一个WebSocketSubject对象：

constructor() {
  this.socket$ = new WebSocketSubject('ws://localhost:8080');
}

这里创建了一个WebSocketSubject对象，它使用ws://localhost:8080地址与服务器进行通信。

接下来，可以使用WebSocketSubject的方法与服务器进行通信。例如，发送数据可以使用`next()`方法：

this.socket$.next({ type: 'message', data: 'Hello server' });

接收来自服务器的数据可以订阅WebSocketSubject对象：

this.socket$.subscribe(
  (message) => console.log('Received message:', message),
  (error) => console.error('Error:', error),
  () => console.log('WebSocket closed')
);

这里订阅了WebSocketSubject对象，当从服务器接收到消息时将打印消息，当发生错误时将打印错误，当WebSocket关闭时将打印消息。

最后，不要忘记在组件销毁时关闭WebSocket连接：

ngOnDestroy() {
  this.socket$.complete();
}

这里使用`complete()`方法关闭WebSocket连接。

以上是使用Angular的WebSocketSubject与服务器进行通信的基本步骤。