订阅方式

exchanges/src/binance_swap_ws.rs

@@ -15,7 +15,7 @@ use tracing::{error, info, trace};
 use crate::binance_swap_rest::BinanceSwapRest;
 
 use crate::response_base::ResponseData;
-use crate::socket_tool::{AbstractWsMode, HeartbeatType};
+use crate::socket_tool::{AbstractWsMode};
 
 //类型
 pub enum BinanceSwapWsType {
@@ -260,9 +260,9 @@ impl BinanceSwapWs {
         tokio::spawn(async move {
             trace!("线程-异步时效记录-开始");
             // let time_5m = 1000 * 60 * 50;
-            let time_5m = 1000 * 60 * 50;
+            let reconnect_interval = 1000 * 60 * 50;
             loop {
-                tokio::time::sleep(Duration::from_millis(time_5m)).await;
+                tokio::time::sleep(Duration::from_millis(reconnect_interval)).await;
                 let write_tx_clone = write_tx_clone1.lock().await;
                 let close_frame = CloseFrame {
                     code: CloseCode::Normal,
@@ -279,7 +279,7 @@ impl BinanceSwapWs {
                 }
             }
             // AbstractWsMode::ping_or_pong(write_tx_clone1, HeartbeatType::Custom(), time_5m).await;
-            trace!("线程-异步时效记录-结束");
+            // trace!("线程-异步时效记录-结束");
         });
 
         //设置订阅

exchanges/tests/binance_swap_test.rs

@@ -1,7 +1,6 @@
 use std::collections::BTreeMap;
 use std::sync::Arc;
 use std::sync::atomic::AtomicBool;
-use std::time::Duration;
 use serde_json::json;
 use tokio::sync::Mutex;
 use tracing::trace;

strategy/src/binance_usdt_swap.rs

@@ -4,7 +4,7 @@ use std::sync::atomic::AtomicBool;
 use rust_decimal::Decimal;
 use tokio::sync::Mutex;
 use tokio_tungstenite::tungstenite::Message;
-use tracing::error;
+use tracing::{error, info};
 use exchanges::response_base::ResponseData;
 use global::trace_stack::{TraceStack};
 use crate::core::Core;
@@ -100,6 +100,9 @@ async fn on_data(core_arc: Arc<Mutex<Core>>, multiplier: &Decimal, run_symbol: &
     trace_stack.on_after_span_line();
 
     match response.channel.as_str() {
+        "info" => {
+            info!("connected: {}", response.data.to_string())
+        }
         "aggTrade" => {
             trace_stack.set_source("binance_usdt_swap.aggTrade".to_string());
             let mut trades = ExchangeStructHandler::trades_handle(ExchangeEnum::BinanceSwap, response, multiplier);