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 ++++++++++++++++++++++++------------
lib/binance-connector-java-3.2.0.jar | 0
pom.xml | 10 ++++++++--
3 files changed, 32 insertions(+), 14 deletions(-)
diff --git a/lib/binance-connector-java-3.2.0.jar b/lib/binance-connector-java-3.2.0.jar
new file mode 100644
index 0000000..c96b343
--- /dev/null
+++ b/lib/binance-connector-java-3.2.0.jar
Binary files differ
diff --git a/pom.xml b/pom.xml
index df19e47..fe1248b 100644
--- a/pom.xml
+++ b/pom.xml
@@ -35,7 +35,13 @@
</properties>
<dependencies>
-
+
+ <dependency>
+ <groupId>io.github.binance</groupId>
+ <artifactId>binance-connector-java</artifactId>
+ <version>3.2.0</version>
+ </dependency>
+
<dependency>
<groupId>ripple</groupId>
<artifactId>ripple</artifactId>
@@ -158,7 +164,7 @@
<artifactId>mysql-connector-java</artifactId>
<version>${mysql-driver.version}</version>
</dependency>
-
+
<dependency>
<groupId>org.web3j</groupId>
<artifactId>core</artifactId>
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