From 0fc718dbe3ed1f208e7e992826b76e42f24c1ef0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=96=87=E8=96=87=E5=AE=89?= Date: Wed, 14 Jan 2026 13:29:35 +0800 Subject: [PATCH] a --- trading_system/WEBSOCKET_TROUBLESHOOTING.md | 143 ++++++++++++++++++++ trading_system/unicorn_websocket.py | 38 +++++- 2 files changed, 175 insertions(+), 6 deletions(-) create mode 100644 trading_system/WEBSOCKET_TROUBLESHOOTING.md diff --git a/trading_system/WEBSOCKET_TROUBLESHOOTING.md b/trading_system/WEBSOCKET_TROUBLESHOOTING.md new file mode 100644 index 0000000..c922794 --- /dev/null +++ b/trading_system/WEBSOCKET_TROUBLESHOOTING.md @@ -0,0 +1,143 @@ +# WebSocket 故障排除指南 + +## 常见错误及解决方案 + +### 错误1: `__init__() got an unexpected keyword argument 'throw_exception_if_unrepairable'` + +**原因**: +- `unicorn-binance-websocket-api` 2.4.0 版本不支持 `throw_exception_if_unrepairable` 参数 +- 该参数可能在新版本中被移除或改名 + +**解决方案**: +- ✅ 已修复：移除了不支持的参数 +- ✅ 已添加：多种初始化方式的回退机制 +- ✅ 已优化：更好的错误日志输出 + +**修复后的行为**: +1. 首先尝试使用 `high_performance=True` 参数 +2. 如果失败，尝试只使用 `exchange` 参数 +3. 如果还是失败，尝试使用位置参数 +4. 所有方式都失败时，输出详细的错误信息 + +### 错误2: `ModuleNotFoundError: No module named 'unicorn_binance_websocket_api'` + +**原因**: +- 未安装 `unicorn-binance-websocket-api` 依赖 + +**解决方案**: +```bash +cd trading_system +pip install -r requirements.txt +# 或单独安装 +pip install unicorn-binance-websocket-api==2.4.0 +``` + +### 错误3: WebSocket连接失败 + +**可能原因**: +1. 网络连接问题 +2. 防火墙阻止 +3. Binance服务器问题 + +**检查步骤**: +```bash +# 检查网络连接 +ping stream.binance.com + +# 检查DNS解析 +nslookup stream.binance.com +``` + +**解决方案**: +- 检查服务器网络配置 +- 检查防火墙规则 +- 等待Binance服务恢复 + +### 错误4: WebSocket订阅失败 + +**可能原因**: +1. 订阅的交易对数量过多 +2. 交易对格式错误 +3. WebSocket连接不稳定 + +**解决方案**: +- 减少订阅数量（调整 `WEBSOCKET_SUBSCRIBE_COUNT`） +- 检查交易对格式（应该是大写，如 `BTCUSDT`） +- 查看日志中的详细错误信息 + +## 验证WebSocket是否正常工作 + +### 1. 查看启动日志 + +正常启动应该看到： +``` +✓ Unicorn WebSocket管理器启动成功 (测试网: False) + 交易所: binance.com-futures +✓ 已成功订阅 100 个交易对的实时价格流 +✓ 价格数据将通过WebSocket实时更新，减少REST API调用 +``` + +### 2. 查看运行时日志 + +正常运行时应该看到： +``` +✓ [WebSocket] 从缓存获取 BTCUSDT 价格: 43250.50000000 (缓存年龄: 2.3秒) +``` + +### 3. 查看统计信息 + +每次扫描后应该看到： +``` +WebSocket状态: 订阅=100个交易对, 缓存=100个价格, 活跃流=1个 +``` + +## 调试技巧 + +### 启用详细日志 + +在 `config.py` 或环境变量中设置： +```python +LOG_LEVEL = 'DEBUG' +``` + +### 检查WebSocket状态 + +在代码中添加： +```python +if client.unicorn_manager: + stats = client.unicorn_manager.get_stream_statistics() + print(f"WebSocket统计: {stats}") +``` + +### 手动测试WebSocket连接 + +```python +from unicorn_binance_websocket_api.manager import BinanceWebSocketApiManager + +manager = BinanceWebSocketApiManager(exchange="binance.com-futures") +stream_id = manager.create_stream(["arr"], ["btcusdt@ticker"]) +print(f"Stream ID: {stream_id}") +``` + +## 版本兼容性 + +### 支持的版本 +- `unicorn-binance-websocket-api >= 2.0.0` +- 推荐版本: `2.4.0` + +### 已知问题 +- 2.4.0版本不支持 `throw_exception_if_unrepairable` 参数（已修复） +- 某些旧版本可能不支持 `high_performance` 参数（已添加回退） + +## 性能优化建议 + +1. **订阅数量**: 根据实际需求调整，不要订阅过多 +2. **缓存TTL**: 默认60秒，可以根据需要调整 +3. **日志级别**: 生产环境使用 `INFO`，调试时使用 `DEBUG` + +## 联系支持 + +如果问题仍然存在： +1. 查看完整的错误日志 +2. 检查 `unicorn-binance-websocket-api` 版本 +3. 查看 [Unicorn Binance WebSocket API 文档](https://github.com/LUCIT-Systems-and-Development/unicorn-binance-websocket-api) diff --git a/trading_system/unicorn_websocket.py b/trading_system/unicorn_websocket.py index b4b4607..cc88441 100644 --- a/trading_system/unicorn_websocket.py +++ b/trading_system/unicorn_websocket.py @@ -48,17 +48,43 @@ class UnicornWebSocketManager: """启动WebSocket管理器""" try: # 创建管理器 - self.manager = BinanceWebSocketApiManager( - exchange="binance.com-futures" if not self.testnet else "binance.com-futures-testnet", - throw_exception_if_unrepairable=True, - high_performance=True - ) + # 注意：unicorn-binance-websocket-api 2.4.0版本不支持某些参数 + exchange = "binance.com-futures" if not self.testnet else "binance.com-futures-testnet" + + # 尝试不同的初始化方式（兼容不同版本） + try: + # 方式1：使用high_performance参数（如果支持） + self.manager = BinanceWebSocketApiManager( + exchange=exchange, + high_performance=True + ) + logger.debug("使用 high_performance=True 参数初始化成功") + except TypeError as e1: + # 方式2：只使用exchange参数 + try: + self.manager = BinanceWebSocketApiManager(exchange=exchange) + logger.debug("使用 exchange 参数初始化成功") + except TypeError as e2: + # 方式3：使用位置参数 + try: + self.manager = BinanceWebSocketApiManager(exchange) + logger.debug("使用位置参数初始化成功") + except Exception as e3: + logger.error(f"所有初始化方式都失败:") + logger.error(f" 方式1错误: {e1}") + logger.error(f" 方式2错误: {e2}") + logger.error(f" 方式3错误: {e3}") + raise e3 self.running = True - logger.info(f"Unicorn WebSocket管理器启动成功 (测试网: {self.testnet})") + logger.info(f"✓ Unicorn WebSocket管理器启动成功 (测试网: {self.testnet})") + logger.info(f" 交易所: {exchange}") return True except Exception as e: logger.error(f"启动Unicorn WebSocket管理器失败: {e}") + logger.error(f"错误类型: {type(e).__name__}") + import traceback + logger.debug(f"详细错误信息:\n{traceback.format_exc()}") return False def stop(self):