优化

exchanges/src/binance_spot_ws.rs

@@ -24,6 +24,8 @@ pub enum BinanceSpotSubscribeType {
     PuBookTicker,
     PuAggTrade,
     PuDepth20levels100ms,
+
+
 }
 
 #[derive(Clone)]
@@ -128,6 +130,7 @@ impl BinanceSpotWs {
             BinanceSpotSubscribeType::PuBookTicker => {
                 format!("{}@bookTicker", symbol)
             }
+
         }
     }
     //组装订阅数据

exchanges/src/binance_swap_ws.rs

@@ -4,7 +4,7 @@ use std::sync::Arc;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::time::Duration;
 use tokio::sync::mpsc::Sender;
-use tracing::{info, trace};
+use tracing::{error, info, trace};
 use crate::{proxy};
 use tungstenite::client::{AutoStream, connect_with_proxy, ProxyAutoStream};
 use tungstenite::{connect, Message, WebSocket};
@@ -189,7 +189,7 @@ impl BinanceSwapWs {
                         self.proxy_subscription(bool_v1_clone, ws.0, subscription.clone()).await;
                     }
                     Err(err) => {
-                        trace!("Can't connect(无法连接): {}", err);
+                        error!("Can't connect(无法连接): {}", err);
                     }
                 };
             } else {
@@ -200,7 +200,7 @@ impl BinanceSwapWs {
                     }
                     Err(err) => {
                         // 连接失败时执行的操作
-                        trace!("Can't connect(无法连接): {}", err);
+                        error!("Can't connect(无法连接): {}", err);
                         // 返回一个默认的 WebSocket 对象或其他适当的值
                         // 或者根据需要触发 panic 或返回错误信息
                     }
@@ -254,7 +254,7 @@ impl BinanceSwapWs {
                 }
                 Err(error) => {
                     // trace!("Error receiving message: {}", error);
-                    trace!("Err-响应{}", error);
+                    error!("Err-响应{}", error);
                     break;
                 }
                 _ => {}
@@ -306,7 +306,7 @@ impl BinanceSwapWs {
                 }
                 Err(error) => {
                     // trace!("Error receiving message: {}", error);
-                    trace!( "Err-响应{}", error) ;
+                    error!( "Err-响应{}", error) ;
                     break;
                 }
                 _ => {}

exchanges/src/gate_swap_ws.rs

@@ -8,7 +8,7 @@ use serde_json::{json, Value};
 use hex;
 use hmac::{Hmac, Mac, NewMac};
 use sha2::Sha512;
-use tracing::{info, trace};
+use tracing::{error, info, trace};
 use crate::{proxy};
 use tungstenite::client::{AutoStream, connect_with_proxy, ProxyAutoStream};
 use tungstenite::{connect, Message, WebSocket};
@@ -264,7 +264,7 @@ impl GateSwapWs {
                         self.proxy_subscription(bool_v1_clone ,ws.0, subscription.clone()).await;
                     }
                     Err(err) => {
-                        trace!("Can't connect(无法连接): {}", err);
+                        error!("Can't connect(无法连接): {}", err);
                     }
                 };
             } else {
@@ -275,7 +275,7 @@ impl GateSwapWs {
                     }
                     Err(err) => {
                         // 连接失败时执行的操作
-                        trace!("Can't connect(无法连接): {}", err);
+                        error!("Can't connect(无法连接): {}", err);
                         // 返回一个默认的 WebSocket 对象或其他适当的值
                         // 或者根据需要触发 panic 或返回错误信息
                     }
@@ -351,7 +351,7 @@ impl GateSwapWs {
                 }
                 Err(error) => {
                     // trace!("Error receiving message: {}", error);
-                    trace!( "Err-响应{}", error);
+                    error!( "Err-响应{}", error);
                     break;
                 }
                 _ => {}
@@ -426,7 +426,7 @@ impl GateSwapWs {
                 }
                 Err(error) => {
                     // trace!("Error receiving message: {}", error);
-                    trace!( "Err-响应{}", error);
+                    error!( "Err-响应{}", error);
                     break;
                 }
                 _ => {}

exchanges/src/kucoin_swap_ws.rs

@@ -4,7 +4,7 @@ use std::sync::Arc;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::time::Duration;
 use tokio::sync::mpsc::Sender;
-use tracing::{info, trace};
+use tracing::{error, info, trace};
 use crate::{proxy};
 use tungstenite::client::{AutoStream, connect_with_proxy, ProxyAutoStream};
 use tungstenite::{connect, Message, WebSocket};
@@ -96,7 +96,7 @@ impl KucoinSwapWs {
                 ws_param = param
             }
             Err(error) => {
-                print!("-链接地址等参数错误:{:?}", error)
+                error!("-链接地址等参数错误:{:?}", error)
             }
         }
         /*****返回结构体*******/
@@ -283,7 +283,7 @@ impl KucoinSwapWs {
                         self.proxy_subscription(bool_v1_clone, ws.0, subscription.clone()).await;
                     }
                     Err(err) => {
-                        trace!("Can't connect(无法连接): {}", err);
+                        error!("Can't connect(无法连接): {}", err);
                     }
                 };
             } else {
@@ -294,7 +294,7 @@ impl KucoinSwapWs {
                     }
                     Err(err) => {
                         // 连接失败时执行的操作
-                        trace!("Can't connect(无法连接): {}", err);
+                        error!("Can't connect(无法连接): {}", err);
                         // 返回一个默认的 WebSocket 对象或其他适当的值
                         // 或者根据需要触发 panic 或返回错误信息
                     }
@@ -378,7 +378,7 @@ impl KucoinSwapWs {
                 }
                 Err(error) => {
                     // trace!("Error receiving message: {}", error);
-                    trace!( "Err-响应{}", error);
+                    error!( "Err-响应{}", error);
                     break;
                 }
                 _ => {}
@@ -461,7 +461,7 @@ impl KucoinSwapWs {
                 }
                 Err(error) => {
                     // trace!("Error receiving message: {}", error);
-                    trace!( "Err-响应{}", error);
+                    error!( "Err-响应{}", error);
                     break;
                 }
                 _ => {}