| | |
| | | import javax.annotation.PostConstruct; |
| | | |
| | | /** |
| | | * @author wzy |
| | | * @author |
| | | * @date 2022-03-24 |
| | | **/ |
| | | @Slf4j |
| | |
| | | |
| | | @PostConstruct |
| | | public void initNewPriceUpdate() { |
| | | log.info("#最新价更新启动#"); |
| | | redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30); |
| | | SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); |
| | | subscriptionOptions.setConnectionDelayOnFailure(5); |
| | | subscriptionOptions.setUri("wss://api.hadax.com/ws"); |
| | | SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions); |
| | | subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> { |
| | | redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice()); |
| | | }); |
| | | // log.info("#最新价更新启动#"); |
| | | // redisUtils.set(AppContants.REDIS_KEY_CHANGE_FEE, 30); |
| | | // SubscriptionOptions subscriptionOptions = new SubscriptionOptions(); |
| | | // subscriptionOptions.setConnectionDelayOnFailure(5); |
| | | // subscriptionOptions.setUri("wss://api.hadax.com/ws"); |
| | | // SubscriptionClient subscriptionClient = SubscriptionClient.create("", "", subscriptionOptions); |
| | | // subscriptionClient.subscribeTradeEvent("ethusdt", tradeEvent -> { |
| | | // redisUtils.set(AppContants.REDIS_KEY_ETH_NEW_PRICE, tradeEvent.getTradeList().get(0).getPrice()); |
| | | // }); |
| | | } |
| | | } |