| | |
|---|
| | | private final AtomicBoolean isConnecting = new AtomicBoolean(false); |
|---|
| | | private final AtomicBoolean isInitialized = new AtomicBoolean(false); |
|---|
| | | |
|---|
| | | private static final String CHANNEL = "candle5m"; |
|---|
| | | private static final String CHANNEL = "candle1m"; |
|---|
| | | // private static final String CHANNEL = "candle5m"; |
|---|
| | | // private static final String CHANNEL = "candle15m"; |
|---|
| | | |
|---|
| | | // 心跳超时时间(秒)，小于30秒 |
|---|
| | |
|---|
| | | MacdMaStrategy strategy = new MacdMaStrategy(); |
|---|
| | | |
|---|
| | | // 生成100个15分钟价格数据点 |
|---|
| | | List<Kline> kline15MinuteData = getKlineDataByInstIdAndBar(instId, "15m"); |
|---|
| | | List<Kline> kline15MinuteData = getKlineDataByInstIdAndBar(instId, "1m"); |
|---|
| | | List<BigDecimal> historicalPrices = kline15MinuteData.stream() |
|---|
| | | .map(Kline::getC) |
|---|
| | | .collect(Collectors.toList()); |
|---|
