如何使用Autobahn与Asyncio连接币安WebSocket服务及问题排查

我来帮你拆解这个问题，其实这是币安WebSocket API的设计要求导致的：

• 核心原因：币安的Stream服务要求WebSocket连接必须携带指定的路径参数才能完成正确的升级和订阅。如果只连接根地址wss://stream.binance.com:9443，服务端无法识别你要订阅的数据流，就会直接触发连接升级失败的错误，断开连接。

• 验证过的正确方式：你已经通过在线工具确认了完整地址wss://stream.binance.com:9443/ws/bnbbtc@kline_1m可以正常工作，这是因为路径中的/ws/bnbbtc@kline_1m明确告诉了服务端你要订阅BNB/BTC的1分钟K线数据流，服务端能正确完成WebSocket握手并开始推送数据。

如果你的代码里之前有尝试省略路径的情况，这里给你几个实用注意点：

1. 确保在初始化WebSocket连接时，必须包含完整的路径部分，也就是/ws/<streamName>格式的路径，streamName根据你要订阅的标的和数据类型来指定（比如bnbbtc@kline_1m就是BNB/BTC的1分钟K线）。
2. 如果需要订阅多个数据流，可以使用合并流路径/stream?streams=<stream1>/<stream2>，比如wss://stream.binance.com:9443/stream?streams=bnbbtc@kline_1m/ethbtc@kline_1m，这样可以通过一个连接订阅多个数据。
3. 检查代码中是否有不小心截断路径的逻辑，比如把URL拆分成主机和路径两部分时有没有正确拼接。举个简单的JavaScript示例：

// 正确的写法
const ws = new WebSocket('wss://stream.binance.com:9443/ws/bnbbtc@kline_1m');

ws.onmessage = (event) => {
  console.log('收到K线数据:', JSON.parse(event.data));
};

// 错误的写法（会触发升级失败）
// const ws = new WebSocket('wss://stream.binance.com:9443');

总结一下，币安的WebSocket服务是基于路径来区分不同订阅流的，没有路径的连接请求不符合服务端的API规范，所以必然会被拒绝升级并断开连接。只要保持使用包含完整路径的URL，就能正常建立连接并接收数据。

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