健壮性通过了测试。

Cargo.toml

@@ -25,7 +25,7 @@ futures-channel = "0.3.28"
 flate2 = "1.0"
 
 # WebSocket 客户端，基于 tokio 构建，用于订阅 K 线和深度
-tokio-tungstenite= { git = "https://github.com/HonestHouLiang/tokio-tungstenite.git",rev = "208fc9b09bcc2e2c8cb52e1cde5087446464fc91"  }
+tokio-tungstenite= { git = "https://github.com/skyfffire/tokio-tungstenite-proxy.git" }
 
 # futures 工具库，提供一些异步编程中常用的 trait 和工具
 # 包含了 Stream 的一些方法，例如 split 用于分离 WebSocket stream 的读写端

readme.md

@@ -2,11 +2,11 @@
 
 - [x] ~~public接口对接、测试~~
 - [x] ~~整体架构~~
-- [ ] 2370多个币对的同时订阅信息未测试
-- [ ] private接口未对接、测试
+- [x] ~~2370多个币对的同时订阅信息未测试~~
+- [x] ~~ws的ping、pong链接健壮性未测试~~
 - [ ] k线信息的处理逻辑
 - [ ] 深度信息的处理逻辑
-- [ ] ws的ping、pong链接健壮性未测试
+- [ ] private接口未对接、测试
 - [ ] 交易逻辑对接测试
 - [ ] 数据存储方案的设计与实现
 - [ ] 后台接口的设计与实现

src/exchange/mexc_spot_client.rs

@@ -287,8 +287,8 @@ impl MexcSpotClient {
         let request_builder = match request_type.as_str() {
             "GET" => self.client.get(addrs_url.clone()).headers(headers),
             "POST" => self.client.post(url.clone()).body(body).headers(headers),
-            // "DELETE" => self.client.delete(addrs_url.clone()).headers(headers),
-            // "PUT" => self.client.put(url.clone()).json(&params),
+            "DELETE" => self.client.delete(addrs_url.clone()).headers(headers),
+            "PUT" => self.client.put(url.clone()).json(&params),
             _ => {
                 panic!("{}", format!("错误的请求类型:{}", request_type.clone()))
             }

src/ws_manager.rs

@@ -18,7 +18,7 @@ pub struct WsManager {
 impl WsManager {
     pub fn new(symbols: Vec<String>, data_manager_am: Arc<Mutex<DataManager>>, running: Arc<AtomicBool>) -> WsManager {
         WsManager {
-            symbols: symbols[0..100].to_owned(),
+            symbols,
             data_manager_am,
             running
         }