package com.yami.trading.huobi.jsws;
|
|
|
import com.yami.trading.huobi.websocket.constant.enums.EStockType;
|
import lombok.extern.slf4j.Slf4j;
|
import org.java_websocket.client.WebSocketClient;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.stereotype.Component;
|
|
import java.net.URI;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@Slf4j
|
@Component
|
public class WebSocketClientBeanConfig {
|
|
|
@Bean
|
public Map<String, WebSocketClient> websocketRunClientMap() {
|
|
Map<String, WebSocketClient> retMap = new HashMap<>(1);
|
try {
|
WebsocketRunClient websocketRunClient = new WebsocketRunClient(new URI(EStockType.US.getWsUrl()), EStockType.US);
|
websocketRunClient.connect();
|
websocketRunClient.setConnectionLostTimeout(0);
|
startHeartbeatThread(websocketRunClient);
|
retMap.put(EStockType.US.getStockKey(), websocketRunClient);
|
} catch (Exception e) {
|
log.error("WebsocketRunClient 异常: {}", e.getMessage());
|
}
|
return retMap;
|
}
|
|
private void startHeartbeatThread(WebSocketClient client) {
|
new Thread(() -> {
|
while (true) {
|
try {
|
Thread.sleep(8000);
|
if (client.isOpen()) { // 先检查连接状态
|
client.send("heartbeat".getBytes());
|
} else {
|
client.reconnect();
|
client.setConnectionLostTimeout(0);
|
}
|
} catch (Exception e) {
|
log.error("心跳线程异常, 尝试重连: {}", e.getMessage());
|
try {
|
client.reconnect();
|
client.setConnectionLostTimeout(0);
|
} catch (Exception re) {
|
log.error("重连失败: {}", re.getMessage());
|
}
|
}
|
}
|
}).start();
|
}
|
|
|
}
|