技术问询：如何在RxJS 6.x中使用WebSocketSubject？

我来帮你把RxJS v5.5.6的WebSocket代码适配到v6.x版本，主要是导入方式和实例创建的API有变化，下面直接给你修改后的可运行代码，再拆解关键变化点：

<html>
<head>
  <script src="https://unpkg.com/@reactivex/rxjs@6.0.0/dist/global/rxjs.umd.js"></script>
  <script>
    // 正确的导入方式：从rxjs.webSocket模块中获取WebSocketSubject
    const { WebSocketSubject } = rxjs.webSocket;
    
    // 创建WebSocketSubject实例
    const socket$ = WebSocketSubject.create('ws://localhost:8080');
    
    // 订阅WebSocket流
    socket$.subscribe(
      (data) => console.log('收到消息:', data),
      (err) => console.error('连接错误:', err),
      () => console.warn('连接已关闭!')
    );
    
    // 发送消息（后端需要JSON字符串的话，依然要手动stringify，和v5逻辑一致）
    socket$.next(JSON.stringify({ event: 'events', data: 'test' }));
    
    console.log('代码执行到这里啦')
  </script>
</head>
<body></body>
</html>

关键变化点说明： #

• 导入路径调整：RxJS v6将WebSocket功能拆分到了独立的rxjs.webSocket模块，不再挂载在Observable上，所以要从rxjs.webSocket中解构出WebSocketSubject
• 实例创建API变更：v5里的Rx.Observable.webSocket()在v6中替换为WebSocketSubject.create()，也可以传入配置对象实现更复杂的自定义（比如指定协议、序列化规则）：

  // 带配置的创建方式示例
  const socket$ = WebSocketSubject.create({
    url: 'ws://localhost:8080',
    protocol: 'your-custom-protocol',
    // 自动处理JSON序列化/反序列化，不用手动调用JSON.stringify/parse
    serializer: (value) => JSON.stringify(value),
    deserializer: (e) => JSON.parse(e.data)
  });
  

• 核心方法兼容：subscribe和next的用法和v5完全一致，不需要额外调整

内容的提问来源于stack exchange，提问作者Corey Cole