From 28eb26d68f7a2a4e6b316c3ea9f511aa143db66e Mon Sep 17 00:00:00 2001
From: KKSU <15274802129@163.com>
Date: Mon, 30 Sep 2024 16:57:18 +0800
Subject: [PATCH] 55测试环境
---
src/test/java/com/xcong/excoin/HuobiTest.java | 36 ++++++++++++++++++++++++------------
1 files changed, 24 insertions(+), 12 deletions(-)
diff --git a/src/test/java/com/xcong/excoin/HuobiTest.java b/src/test/java/com/xcong/excoin/HuobiTest.java
index 1491015..865c089 100644
--- a/src/test/java/com/xcong/excoin/HuobiTest.java
+++ b/src/test/java/com/xcong/excoin/HuobiTest.java
@@ -1,6 +1,11 @@
package com.xcong.excoin;
import com.alibaba.fastjson.JSONObject;
+import com.binance.connector.client.WebSocketApiClient;
+import com.binance.connector.client.WebSocketStreamClient;
+import com.binance.connector.client.enums.DefaultUrls;
+import com.binance.connector.client.impl.WebSocketApiClientImpl;
+import com.binance.connector.client.impl.WebSocketStreamClientImpl;
import com.huobi.client.SubscriptionClient;
import com.huobi.client.SubscriptionOptions;
import com.huobi.client.model.Candlestick;
@@ -22,18 +27,25 @@
}
public static void main(String[] args) {
- System.out.println("========价格更新开启=======");
- SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
- //3秒重试
- subscriptionOptions.setConnectionDelayOnFailure(5);
- subscriptionOptions.setUri("wss://api.hadax.com/ws");
- SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
-// subscriptionClient.subscribeTradeEvent("btcusdt,ethusdt,xrpusdt,ltcusdt,bchusdt,eosusdt,etcusdt", tradeEvent -> {
-// log.info("{}", JSONObject.toJSONString(tradeEvent));
-// });
- subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> {
- log.info("{}", JSONObject.toJSONString(candlestickEvent));
- });
+
+ WebSocketStreamClient client = new WebSocketStreamClientImpl(DefaultUrls.TESTNET_WS_URL);
+ client.klineStream("btcusdt", "1m", ((event) -> {
+ System.out.println(event);
+// client.closeAllConnections();
+ }));
+// System.out.println("========价格更新开启=======");
+// SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
+// //3秒重试
+// subscriptionOptions.setConnectionDelayOnFailure(5);
+// subscriptionOptions.setUri("wss://api.hadax.com/ws");
+// SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
+//// subscriptionClient.subscribeTradeEvent("btcusdt,ethusdt,xrpusdt,ltcusdt,bchusdt,eosusdt,etcusdt", tradeEvent -> {
+//// log.info("{}", JSONObject.toJSONString(tradeEvent));
+//// });
+//
+// subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> {
+// log.info("{}", JSONObject.toJSONString(candlestickEvent));
+// });
}
}
\ No newline at end of file
--
Gitblit v1.9.1