通道中有数据时抛弃，看看是否会缓解。

exchanges/src/socket_tool.rs

@@ -103,37 +103,38 @@ impl AbstractWsMode {
                                     let mut data_c = data.clone();
                                     data_c.time = chrono::Utc::now().timestamp_micros();
                                     data_c.label = lable.clone();
-
-                                    // if data_c.label.contains("gate_usdt_swap") {
-                                    //     if data_c.channel == "futures.order_book" {
-                                    //         if read_tx.len() == 0 {
-                                    //             read_tx.unbounded_send(data_c).unwrap();
-                                    //         }
-                                    //     } else {
-                                    //         read_tx.unbounded_send(data_c).unwrap();
-                                    //     }
-                                    // } else if data_c.label.contains("binance_usdt_swap") {
-                                    //     if data_c.channel == "bookTicker" {
-                                    //         if read_tx.len() == 0 {
-                                    //             read_tx.unbounded_send(data_c).unwrap();
-                                    //         }
-                                    //     } else {
-                                    //         read_tx.unbounded_send(data_c).unwrap();
-                                    //     }
-                                    // } else if data_c.label.contains("bybit_usdt_swap") {
-                                    //     if data_c.channel == "orderbook" {
-                                    //         if read_tx.len() == 0 {
-                                    //             read_tx.unbounded_send(data_c).unwrap();
-                                    //         }
-                                    //     } else {
-                                    //         read_tx.unbounded_send(data_c).unwrap();
-                                    //     }
-                                    // } else {
-                                    //     if read_tx.len() == 0 {
                                     let r = read1.clone();
-                                    r.lock().await.unbounded_send(data_c).unwrap();
-                                    // }
-                                    // }
+                                    let read = r.lock().await;
+
+                                    if data_c.label.contains("gate_usdt_swap") {
+                                        if data_c.channel == "futures.order_book" {
+                                            if read.len() == 0 {
+                                                read.unbounded_send(data_c).unwrap();
+                                            }
+                                        } else {
+                                            read.unbounded_send(data_c).unwrap();
+                                        }
+                                    } else if data_c.label.contains("binance_usdt_swap") {
+                                        if data_c.channel == "bookTicker" {
+                                            if read.len() == 0 {
+                                                read.unbounded_send(data_c).unwrap();
+                                            }
+                                        } else {
+                                            read.unbounded_send(data_c).unwrap();
+                                        }
+                                    } else if data_c.label.contains("bybit_usdt_swap") {
+                                        if data_c.channel == "orderbook" {
+                                            if read.len() == 0 {
+                                                read.unbounded_send(data_c).unwrap();
+                                            }
+                                        } else {
+                                            read.unbounded_send(data_c).unwrap();
+                                        }
+                                    } else {
+                                        if read.len() == 0 {
+                                            read.unbounded_send(data_c).unwrap();
+                                        }
+                                    }
                                 }
 
                                 let code = data.code.clone();

strategy/src/binance_usdt_swap.rs

@@ -63,7 +63,7 @@ async fn on_data(bot_arc_clone: Arc<Mutex<Quant>>,
     trace_stack.on_after_network(data.time);
     trace_stack.on_before_unlock_quant();
 
-    println!("bian>{}", trace_stack.to_string());
+    info!("bian>{}", trace_stack.to_string());
 
     // if data.code != "200".to_string() {
     //     return;

strategy/src/gate_swap.rs

@@ -104,7 +104,7 @@ async fn on_data(bot_arc_clone: Arc<Mutex<Quant>>,
     trace_stack.on_after_network(data.time);
     trace_stack.on_before_unlock_quant();
 
-    println!("gate>{}", trace_stack.to_string());
+    info!("gate>{}", trace_stack.to_string());
 
     // if data.code != "200".to_string() {
     //     return;