binance_swap_test.rs 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246
  1. // use std::cmp::max;
  2. // use std::collections::BTreeMap;
  3. // use std::sync::Arc;
  4. // use std::sync::atomic::AtomicBool;
  5. //
  6. // use tokio::sync::Mutex;
  7. // use tracing::{info, trace};
  8. //
  9. // use exchanges::binance_swap_rest::BinanceSwapRest;
  10. // use exchanges::binance_swap_ws::{BinanceSwapLogin, BinanceSwapSubscribeType, BinanceSwapWs, BinanceSwapWsType};
  11. // use exchanges::response_base::ResponseData;
  12. // use global::trace_stack::TraceStack;
  13. //
  14. // const ACCESS_KEY: &str = "";
  15. // const SECRET_KEY: &str = "";
  16. //
  17. //
  18. // //ws-订阅公共频道信息
  19. // #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
  20. // async fn ws_custom_subscribe() {
  21. // global::log_utils::init_log_with_trace();
  22. //
  23. //
  24. // let (write_tx, write_rx) = futures_channel::mpsc::unbounded();
  25. // let (read_tx, mut read_rx) = futures_channel::mpsc::unbounded::<ResponseData>();
  26. //
  27. // // let (write_tx, write_rx) = tokio::sync::broadcast::channel::<Message>(10);
  28. // // let (read_tx, mut read_rx) = tokio::sync::broadcast::channel::<ResponseData>(10);
  29. //
  30. //
  31. // let mut ws = get_ws(None);
  32. // ws.set_symbols(vec!["BTC_USDT".to_string()]);
  33. // ws.set_subscribe(vec![
  34. // BinanceSwapSubscribeType::PuBookTicker,
  35. // // BinanceSwapSubscribeType::PuAggTrade,
  36. // // BinanceSwapSubscribeType::PuDepth20levels100ms,
  37. // ]);
  38. //
  39. //
  40. // let write_tx_am = Arc::new(Mutex::new(write_tx));
  41. // let is_shutdown_arc = Arc::new(AtomicBool::new(true));
  42. //
  43. // //读取
  44. // let _is_shutdown_arc_clone = Arc::clone(&is_shutdown_arc);
  45. // let _tr = tokio::spawn(async move {
  46. // trace!("线程-数据读取-开启");
  47. // let mut max_delay = 0i64;
  48. // loop {
  49. // // 从通道中接收并丢弃所有的消息,直到通道为空
  50. // while let Ok(Some(data)) = read_rx.try_next() {
  51. // // 消息被忽略
  52. // let mut trace_stack = TraceStack::new(0, Instant::now());
  53. // trace_stack.on_before_unlock_core();
  54. // trace_stack.on_after_network(data.time);
  55. //
  56. // let delay = trace_stack.before_unlock_core - trace_stack.after_network;
  57. // max_delay = max(max_delay, delay);
  58. // info!("{}us, max={}us", delay, max_delay);
  59. //
  60. // // 从通道中接收并丢弃所有的消息,直到通道为空
  61. // while let Ok(Some(_)) = read_rx.try_next() {
  62. // // 消息被忽略
  63. // }
  64. // }
  65. // }
  66. // // trace!("线程-数据读取-结束");
  67. // });
  68. //
  69. // //写数据
  70. // // let bool_v2_clone = Arc::clone(&is_shutdown_arc);
  71. // // let write_tx_clone = Arc::clone(&write_tx_am);
  72. // // let su = ws.get_subscription();
  73. // // let tw = tokio::spawn(async move {
  74. // // trace!("线程-数据写入-开始");
  75. // // loop {
  76. // // tokio::time::sleep(Duration::from_millis(20 * 1000)).await;
  77. // // // let close_frame = CloseFrame {
  78. // // // code: CloseCode::Normal,
  79. // // // reason: Cow::Borrowed("Bye bye"),
  80. // // // };
  81. // // // let message = Message::Close(Some(close_frame));
  82. // //
  83. // //
  84. // // let message = Message::Text(su.clone());
  85. // // AbstractWsMode::send_subscribe(write_tx_clone.clone(), message.clone()).await;
  86. // // trace!("发送指令成功");
  87. // // }
  88. // // trace!("线程-数据写入-结束");
  89. // // });
  90. //
  91. // let t1 = tokio::spawn(async move {
  92. // //链接
  93. // let bool_v3_clone = Arc::clone(&is_shutdown_arc);
  94. // ws.ws_connect_async(bool_v3_clone, &write_tx_am, write_rx, read_tx).await.expect("链接失败(内部一个心跳线程应该已经关闭了)");
  95. // trace!("test 唯一线程结束--");
  96. // });
  97. // tokio::try_join!(t1).unwrap();
  98. // trace!("当此结束");
  99. // trace!("重启!");
  100. // trace!("参考交易所关闭");
  101. // return;
  102. //
  103. // //************************************
  104. // //************************************
  105. // //************************************
  106. // //************************************
  107. // //************************************
  108. // //************************************
  109. // //************************************
  110. // //11 点31 分
  111. //
  112. // // let mut is_shutdown_arc = Arc::new(AtomicBool::new(true));
  113. // // //创建读写通道
  114. // // let (write_tx, write_rx) = futures_channel::mpsc::unbounded();
  115. // // let (read_tx, mut read_rx) = futures_channel::mpsc::unbounded();
  116. // // // 封装 write_tx 到 Arc 和 Mutex
  117. // // let write_tx_am = Arc::new(Mutex::new(write_tx));
  118. // //
  119. // // //对象
  120. // // let mut ws = get_ws(None);
  121. // // // 币对
  122. // // ws.set_symbols(vec!["BTC_USDT".to_string()]);
  123. // // //订阅
  124. // // ws.set_subscribe(vec![
  125. // // BinanceSwapSubscribeType::PuBookTicker,
  126. // // BinanceSwapSubscribeType::PuAggTrade,
  127. // // BinanceSwapSubscribeType::PuDepth20levels100ms,
  128. // // ]);
  129. // //
  130. // //
  131. // // //模拟业务场景 开启链接
  132. // // let is_shutdown_arc_clone = Arc::clone(&is_shutdown_arc);
  133. // // let write_tx_clone1 = Arc::clone(&write_tx_am);
  134. // // let t1 = tokio::spawn(async move {
  135. // // ws.ws_connect_async(is_shutdown_arc_clone, write_tx_clone1, write_rx, &read_tx).await.unwrap();
  136. // // trace!("ws_connect_async 完成");
  137. // // });
  138. // //
  139. // // //模拟业务场景 一直监听数据
  140. // // let t2 = tokio::spawn(async move {
  141. // // loop {
  142. // // if let Some(data) = read_rx.next().await {
  143. // // trace!("读取数据data:{:?}",data)
  144. // // }
  145. // // }
  146. // // trace!("数据读取退出 完成");
  147. // // });
  148. // //
  149. // //
  150. // // //模拟用户主动写入数据
  151. // // // let write_tx_clone2 = Arc::clone(&write_tx_am);
  152. // // // let t3 = tokio::spawn(async move {
  153. // // // //模拟心跳
  154. // // // loop {
  155. // // // tokio::time::sleep(Duration::from_millis(5000)).await;
  156. // // // let mut write_tx_clone = write_tx_clone2.lock().unwrap();
  157. // // // match write_tx_clone.unbounded_send(Message::Pong(Vec::from("pong"))) {
  158. // // // Ok(_) => {
  159. // // // trace!("发送心跳");
  160. // // // continue;
  161. // // // }
  162. // // // Err(_) => {
  163. // // // break;
  164. // // // }
  165. // // // }
  166. // // // }
  167. // // // trace!("主动推出 完成");
  168. // // // });
  169. // // // tokio::try_join!(y,y1,y2).unwrap();
  170. // // tokio::try_join!(t1,t2).unwrap();
  171. // // trace!("323123213");
  172. // }
  173. //
  174. // //rest-获取服务器时间
  175. // #[tokio::test]
  176. // async fn rest_get_server_time_test() {
  177. // global::log_utils::init_log_with_trace();
  178. //
  179. // let mut rest = get_rest();
  180. // let rep_data = rest.get_server_time().await;
  181. // trace!(?rep_data)
  182. // }
  183. //
  184. // //rest-获取交易规则和交易对
  185. // #[tokio::test]
  186. // async fn rest_get_exchange_info_test() {
  187. // global::log_utils::init_log_with_trace();
  188. //
  189. // let mut rest = get_rest();
  190. // let rep_data = rest.get_exchange_info().await;
  191. // trace!(?rep_data)
  192. // }
  193. //
  194. // //rest-账户信息
  195. // #[tokio::test]
  196. // async fn rest_get_account_test() {
  197. // global::log_utils::init_log_with_trace();
  198. //
  199. // let mut rest = get_rest();
  200. // let rep_data = rest.get_account().await;
  201. // trace!(?rep_data)
  202. // }
  203. //
  204. //
  205. // //rest-根据币对 撤销全部订单
  206. // #[tokio::test(flavor = "multi_thread", worker_threads = 2)]
  207. // async fn rest_cancel_order_all_test() {
  208. // global::log_utils::init_log_with_trace();
  209. //
  210. // let mut rest = get_rest();
  211. //
  212. // let rep_data1 = rest.get_server_time().await;
  213. // trace!(?rep_data1);
  214. //
  215. // trace!("开始时间:{:?}",chrono::Utc::now().timestamp_millis().to_string());
  216. // let rep_data = rest.cancel_order_all("BTCUSDT".to_string()).await;
  217. // trace!(?rep_data);
  218. // trace!("结束时间:{:?}",chrono::Utc::now().timestamp_millis().to_string());
  219. // }
  220. //
  221. // //rest-账户成交历史
  222. // #[tokio::test]
  223. // async fn rest_get_user_trades_test() {
  224. // global::log_utils::init_log_with_trace();
  225. //
  226. // let mut rest = get_rest();
  227. // let rep_data = rest.get_user_trades("BTCUSDT".to_string(), -1, -1, 500).await;
  228. // trace!(?rep_data)
  229. // }
  230. //
  231. //
  232. // fn get_ws(btree_map: Option<BinanceSwapLogin>) -> BinanceSwapWs {
  233. // let binance_ws = BinanceSwapWs::new(false,
  234. // btree_map,
  235. // BinanceSwapWsType::PublicAndPrivate);
  236. // binance_ws
  237. // }
  238. //
  239. // fn get_rest() -> BinanceSwapRest {
  240. // let mut btree_map: BTreeMap<String, String> = BTreeMap::new();
  241. // btree_map.insert("access_key".to_string(), ACCESS_KEY.to_string());
  242. // btree_map.insert("secret_key".to_string(), SECRET_KEY.to_string());
  243. //
  244. // let ba_exc = BinanceSwapRest::new(false, btree_map);
  245. // ba_exc
  246. // }