KKSU
2024-09-30 36be00e0f3cbe0d559c646fd2977e6e3a74aa6f9
Merge branch 'bea' of http://120.27.238.55:7000/r/exchange into bea
1 files added
2 files modified
12 ■■■■■ changed files
lib/huobi-client-2.0.3-SNAPSHOT.jar patch | view | raw | blame | history
pom.xml 8 ●●●●● patch | view | raw | blame | history
src/main/java/com/xcong/excoin/quartz/job/NewestPriceUpdateJob.java 4 ●●● patch | view | raw | blame | history
lib/huobi-client-2.0.3-SNAPSHOT.jar
Binary 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);
                    // 比较