Springboot 集成websocket 并主动建立连接

你可以使用 Spring Boot 来集成 WebSocket 并主动建立连接。首先，确保你已经添加了 Spring WebSocket 相关的依赖。在 Maven 项目中，可以在 pom.xml 文件中添加如下依赖：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

接下来，你可以创建一个 WebSocket 配置类，用于配置 WebSocket 相关的信息。可以在其中定义一个 `@Bean` 方法，返回一个 `WebSocketHandler` 对象，用于处理 WebSocket 连接和消息的处理逻辑。例如：

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/my-websocket")
                .setAllowedOrigins("*");
    }

    @Bean
    public WebSocketHandler myHandler() {
        return new MyWebSocketHandler();
    }
}

在上面的代码中，使用 `@EnableWebSocket` 注解开启 WebSocket 功能。`registerWebSocketHandlers()` 方法用于注册 WebSocket 处理器，并指定处理器的路径。这里使用了 `/my-websocket` 路径，并使用 `setAllowedOrigins("*")` 方法允许来自任意来源的连接。

然后，你可以创建一个实现了 `WebSocketHandler` 接口的类，用于处理 WebSocket 连接和消息的逻辑。例如：

public class MyWebSocketHandler extends TextWebSocketHandler {

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        // 在连接建立后被调用
        // 可以在这里进行一些初始化操作
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        // 处理收到的文本消息
        String payload = message.getPayload();
        // 可以在这里编写处理逻辑
    }
}

在上面的代码中，你可以在 `afterConnectionEstablished()` 方法中进行一些初始化操作，例如保存 WebSocketSession 对象，或者发送一些初始消息。在 `handleTextMessage()` 方法中处理收到的文本消息，你可以在这里编写自定义的处理逻辑。

最后，你可以在你的控制器中注入 WebSocketHandler，并使用它来主动建立 WebSocket 连接。例如：

@RestController
public class MyController {

    @Autowired
    private WebSocketHandler myHandler;

    @GetMapping("/connect")
    public String connect() {
        // 主动建立 WebSocket 连接
        WebSocketSession session = myHandler.handleRequest();
        // 可以在这里进行一些操作，例如发送消息
        return "WebSocket connected";
    }
}

在上面的代码中，使用 `@Autowired` 注解将 WebSocketHandler 注入到控制器中。然后，在 `connect()` 方法中调用 `myHandler.handleRequest()` 来主动建立 WebSocket 连接，并返回 WebSocketSession 对象。你可以在这里进行一些操作，例如发送消息。

以上就是使用 Spring Boot 集成 WebSocket 并主动建立连接的步骤。希望能对你有帮助！