From 8ad388d25ab0db33908d89e4df0f4478f047e2d5 Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Fri, 22 May 2020 17:59:55 +0800
Subject: [PATCH] add huobi jar and junit test
---
src/test/java/com/xcong/excoin/HuobiTest.java | 39 +++++++++++++++++++++++++++++++++++++++
lib/huobi-client-1.0.8-SNAPSHOT.jar | 0
src/main/java/com/xcong/excoin/modules/home/mapper/MemberQuickBuySaleEntityMapper.java | 3 ++-
pom.xml | 14 ++++++++++++++
4 files changed, 55 insertions(+), 1 deletions(-)
diff --git a/lib/huobi-client-1.0.8-SNAPSHOT.jar b/lib/huobi-client-1.0.8-SNAPSHOT.jar
new file mode 100644
index 0000000..6422e71
--- /dev/null
+++ b/lib/huobi-client-1.0.8-SNAPSHOT.jar
Binary files differ
diff --git a/pom.xml b/pom.xml
index 20f2f96..0a9f0d4 100644
--- a/pom.xml
+++ b/pom.xml
@@ -175,6 +175,20 @@
<artifactId>netty-all</artifactId>
<version>4.1.33.Final</version>
</dependency>
+
+ <dependency>
+ <groupId>com.squareup.okhttp3</groupId>
+ <artifactId>okhttp</artifactId>
+ <version>3.6.0</version>
+ </dependency>
+
+ <dependency>
+ <groupId>com.huobi.sdk</groupId>
+ <artifactId>huobi-client</artifactId>
+ <version>1.0.8-SNAPSHOT</version>
+ <scope>system</scope>
+ <systemPath>${basedir}/lib/huobi-client-1.0.8-SNAPSHOT.jar</systemPath>
+ </dependency>
</dependencies>
<build>
diff --git a/src/main/java/com/xcong/excoin/modules/home/mapper/MemberQuickBuySaleEntityMapper.java b/src/main/java/com/xcong/excoin/modules/home/mapper/MemberQuickBuySaleEntityMapper.java
index 2405f92..f48f2bb 100644
--- a/src/main/java/com/xcong/excoin/modules/home/mapper/MemberQuickBuySaleEntityMapper.java
+++ b/src/main/java/com/xcong/excoin/modules/home/mapper/MemberQuickBuySaleEntityMapper.java
@@ -1,5 +1,6 @@
package com.xcong.excoin.modules.home.mapper;
+import com.xcong.excoin.modules.home.entity.MemberQuickBuySaleEntity;
import org.mapstruct.Mapper;
import org.mapstruct.factory.Mappers;
@@ -12,6 +13,6 @@
public static final MemberQuickBuySaleEntityMapper INSTANCE = Mappers.getMapper(MemberQuickBuySaleEntityMapper.class);
- public abstract MemberQuickBuySaleEntityMapper dtoToEntity(MemberQuickBuySaleDto dto);
+ public abstract MemberQuickBuySaleEntity dtoToEntity(MemberQuickBuySaleDto dto);
}
diff --git a/src/test/java/com/xcong/excoin/HuobiTest.java b/src/test/java/com/xcong/excoin/HuobiTest.java
new file mode 100644
index 0000000..763f2f7
--- /dev/null
+++ b/src/test/java/com/xcong/excoin/HuobiTest.java
@@ -0,0 +1,39 @@
+package com.xcong.excoin;
+
+import com.alibaba.fastjson.JSONObject;
+import com.huobi.client.SubscriptionClient;
+import com.huobi.client.SubscriptionOptions;
+import com.huobi.client.model.Candlestick;
+import com.huobi.client.model.enums.CandlestickInterval;
+import lombok.extern.slf4j.Slf4j;
+import org.junit.jupiter.api.Test;
+import org.springframework.boot.test.context.SpringBootTest;
+
+/**
+ * @author wzy
+ * @date 2020-05-22
+ **/
+@Slf4j
+@SpringBootTest
+public class HuobiTest {
+
+ @Test
+ public void websocketTest() {
+ }
+
+ 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));
+ });
+ }
+}
--
Gitblit v1.9.1