lib/huobi-client-2.0.3-SNAPSHOT.jar | patch | view | raw | blame | history | |
pom.xml | ●●●●● patch | view | raw | blame | history | |
src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java | ●●●●● patch | view | raw | blame | history |
lib/huobi-client-2.0.3-SNAPSHOT.jarBinary files differ
pom.xml
@@ -294,6 +294,14 @@ <systemPath>${basedir}/lib/huobi-client-1.0.8-SNAPSHOT.jar</systemPath> </dependency> <!-- <dependency>--> <!-- <groupId>com.huobi.sdk</groupId>--> <!-- <artifactId>huobi-client</artifactId>--> <!-- <version>2.0.3-SNAPSHOT</version>--> <!-- <scope>system</scope>--> <!-- <systemPath>${basedir}/lib/huobi-client-2.0.3-SNAPSHOT.jar</systemPath>--> <!-- </dependency>--> <!-- submail邮件 start --> <dependency> <groupId>commons-logging</groupId> src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java
@@ -42,7 +42,8 @@ log.info("#=======价格更新开启=======#"); SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); subscriptionOptions.setConnectionDelayOnFailure(5); subscriptionOptions.setUri("wss://api.hadax.com/ws"); // subscriptionOptions.setUri("wss://api.hadax.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(); @@ -50,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); // 比较