modify

Helius

2021-02-26 e5e3bc5b8f863ce8f1069a12350432ea8cfbf965

 src/main/java/com/xcong/excoin/quartz/job/KLineDataJob.java

@@ -26,22 +26,49 @@
    @Autowired
    WebSocketServer webSocketServer;

    @PostConstruct
    @Autowired
    private SubscriptionClient subscriptionClient;

//    @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 -> {
//        subscriptionClient.subscribePriceDepthEvent("btcusdt", priceDepthEvent -> {
//            log.info("bids:{}", JSONObject.toJSONString(priceDepthEvent.getData().getBids()));
//            log.info("asks:{}", JSONObject.toJSONString(priceDepthEvent.getData().getAsks()));
//        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN1, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN5, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN15, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.MIN60, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.HOUR4, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.DAY1, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });

        subscriptionClient.subscribeCandlestickEvent("btcusdt,ethusdt,eosusdt,etcusdt,ltcusdt,bchusdt,xrpusdt", CandlestickInterval.WEEK1, (candlestickEvent) -> {
            Candlestick data = candlestickEvent.getData();
        });
    }
}