Helius
2022-05-10 80163ed89afd4d656b168070ced82d4f0cab0c7e
fix huobi url
1 files modified
3 ■■■■ changed files
src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java 3 ●●●● patch | view | raw | blame | history
src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java
@@ -43,7 +43,7 @@
            SubscriptionOptions subscriptionOptions = new SubscriptionOptions();
            subscriptionOptions.setConnectionDelayOnFailure(5);
//            subscriptionOptions.setUri("wss://api.hadax.com/ws");
            subscriptionOptions.setUri("wss://api.huobipro.com/ws");
            subscriptionOptions.setUri("wss://api.huobi.pro/ws");
            SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions);
            subscriptionClient.subscribeTradeEvent("btcusdt,ethusdt,xrpusdt,ltcusdt,bchusdt,eosusdt,etcusdt", tradeEvent -> {
                String symbol = tradeEvent.getSymbol();
@@ -51,6 +51,7 @@
                symbol = CoinTypeConvert.convert(symbol);
                if (null != symbol) {
                    String price = tradeEvent.getTradeList().get(0).getPrice().toPlainString();
                    System.out.println(price);
                    // TODO 测试环境关闭这个插入redis
                    redisUtils.set(CoinTypeConvert.convertToKey(symbol), price);
                    // 比较