| | |
|---|
| | | 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(); |
|---|
| | |
|---|
| | | 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); |
|---|
| | | // 比较 |
|---|
