| | |
| | | @Configuration |
| | | public class WebSocketClientBeanConfig { |
| | | |
| | | |
| | | @Bean |
| | | public void websocketRunClientMap() { |
| | | |
| | | // 创建WebSocket客户端实例 |
| | | try { |
| | | URI serverUri = new URI("wss://ws.durocaspitall.com/websocket-server"); |
| | | EStockType stockType = EStockType.IN; // 根据你的枚举调整 |
| | | |
| | | WebsocketRunClient client = new WebsocketRunClient(serverUri, stockType); |
| | | client.connect(); |
| | | |
| | | } catch (Exception e) { |
| | | log.error("创建WebSocket客户端失败: {}", e.getMessage(), e); |
| | | } |
| | | } |
| | | // |
| | | // @Bean |
| | | // public void websocketRunClientMap() { |
| | | // |
| | | // // 创建WebSocket客户端实例 |
| | | // try { |
| | | // URI serverUri = new URI("wss://ws.durocaspitall.com/websocket-server"); |
| | | // EStockType stockType = EStockType.IN; // 根据你的枚举调整 |
| | | // |
| | | // WebsocketRunClient client = new WebsocketRunClient(serverUri, stockType); |
| | | // client.connect(); |
| | | // |
| | | // } catch (Exception e) { |
| | | // log.error("创建WebSocket客户端失败: {}", e.getMessage(), e); |
| | | // } |
| | | // } |
| | | |
| | | } |