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;
|
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) {
|
|
|
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));
|
// });
|
}
|
}
|
