请给我写一个Angular WebSocket的示例程序

当然可以，下面是一个简单的 Angular WebSocket 示例程序：

首先，在你的 Angular 项目中安装 `rxjs` 和 `rxjs-compat` 库：

npm install rxjs rxjs-compat --save

然后，在你的 Angular 组件中引入 `WebSocketSubject` 类，它是 Angular WebSocket 库的核心：

import { WebSocketSubject } from 'rxjs/webSocket';

接下来，在你的组件类中定义一个 WebSocketSubject 对象，并使用它来创建 WebSocket 连接和发送/接收消息：

export class MyComponent implements OnInit {

  private socket$: WebSocketSubject<any>;

  ngOnInit() {
    // 创建 WebSocket 连接
    this.socket$ = new WebSocketSubject('ws://localhost:8080');

    // 发送消息
    this.socket$.next({ type: 'ping' }); // 发送一个 JSON 消息

    // 接收消息
    this.socket$.subscribe(
      (message) => console.log('Received message:', message), // 处理接收到的消息
      (error) => console.error('WebSocket error:', error), // 处理错误
      () => console.log('WebSocket connection closed') // 处理连接关闭事件
    );
  }

}

在这个示例中，我们创建了一个 `WebSocketSubject` 对象，它连接到了 `ws://localhost:8080` 地址。然后，我们使用 `next` 方法发送了一个 JSON 消息，并使用 `subscribe` 方法订阅了消息。当收到消息时，我们在控制台中输出它。

当然，这只是一个简单的示例，你可以根据自己的需求来使用 Angular WebSocket。需要注意的是，WebSocketSubject 是一个冷 Observable，它只有在被订阅时才会建立连接。如果你需要在应用程序的多个组件中使用相同的 WebSocket 连接，可以将 WebSocketSubject 对象定义为一个可注入的服务。