package com.xcong.excoin.quartz.job;
|
|
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 com.huobi.client.model.enums.MBPLevelEnums;
|
import com.huobi.client.model.event.PriceDepthEvent;
|
import com.xcong.excoin.netty.server.WebSocketServer;
|
import com.xcong.excoin.utils.CoinTypeConvert;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.PostConstruct;
|
|
/**
|
* @author wzy
|
* @date 2021-02-23
|
**/
|
@Slf4j
|
@Component
|
public class KLineDataJob {
|
|
@Autowired
|
WebSocketServer webSocketServer;
|
|
@PostConstruct
|
public void data() throws Exception {
|
webSocketServer.start();
|
log.info("==================");
|
SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
|
subscriptionOptions.setConnectionDelayOnFailure(5);
|
subscriptionOptions.setUri("wss://api.hadax.com/ws");
|
SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
|
|
subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> {
|
Candlestick data = candlestickEvent.getData();
|
});
|
|
subscriptionClient.subscribePriceDepthEvent("btcusdt", priceDepthEvent -> {
|
// log.info("bids:{}", JSONObject.toJSONString(priceDepthEvent.getData().getBids()));
|
// log.info("asks:{}", JSONObject.toJSONString(priceDepthEvent.getData().getAsks()));
|
});
|
}
|
}
|
