package com.whyc.webSocket.receiver;
|
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.concurrent.ListenableFuture;
|
import org.springframework.web.socket.WebSocketSession;
|
import org.springframework.web.socket.client.standard.StandardWebSocketClient;
|
import org.springframework.web.socket.WebSocketHttpHeaders;
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
import javax.annotation.PostConstruct;
|
import java.net.URI;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.ScheduledExecutorService;
|
import java.util.concurrent.TimeUnit;
|
|
@Service
|
public class WebSocketClientService {
|
|
/*@Value("${third.party.websocket.uri}")
|
private String webSocketUri;*/
|
|
@Autowired
|
private ThirdPartyWebSocketHandler handler;
|
|
public WebSocketClientService(ThirdPartyWebSocketHandler handler) {
|
this.handler = handler;
|
}
|
|
private ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
|
|
@PostConstruct
|
public void connect() {
|
scheduler.scheduleAtFixedRate(() -> {
|
try {
|
//创建URI对象并将webSocketUri传入
|
//String webSocketUri = "ws://localhost:8919/fg/server";
|
String webSocketUri = "ws://localhost:18080/realtime-data";
|
URI uri = new URI(webSocketUri);
|
System.out.println("webSocketUri:"+webSocketUri);
|
if (handler.getSession() == null || !handler.getSession().isOpen()) {
|
System.out.println("Connecting to WebSocket server...");
|
StandardWebSocketClient client = new StandardWebSocketClient();
|
ListenableFuture<WebSocketSession> future = client.doHandshake(handler, new WebSocketHttpHeaders(), uri);
|
future.addCallback(session -> {
|
System.out.println("Connected to WebSocket server.");
|
}, ex -> {
|
System.err.println("Failed to connect to WebSocket: " + ex.getMessage());
|
});
|
}
|
} catch (Exception e) {
|
System.err.println("Unexpected error during connection attempt: " + e.getMessage());
|
}
|
}, 0, 60, TimeUnit.SECONDS); // 每60秒尝试重连一次
|
}
|
}
|
