spring boot 如何创建websockey客户端，向其他websocket服务端发送信息

在Spring Boot中创建WebSocket客户端并发送消息通常涉及以下几个步骤：

1. 添加依赖：首先，在你的项目中添加Spring WebSocket的依赖。如果你使用的是Maven，可以在pom.xml文件中添加：

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

2. 配置WebSocket支持：在`application.yml`或`application.properties`中配置WebSocket连接URL：

spring:
  websocket:
    url-pattern: /ws/

3. 创建WebSocket客户端：在需要的地方，如一个控制器或者专门的类中，使用`@WebsocketClient`注解创建一个WebSocket连接：

import org.springframework.messaging.poxm.annotation.Pojo;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;

@WebSocketClient(uri = "${spring.websocket.url}")
public class MyWebSocketClient {

    private final WebSocketSession session;

    public MyWebSocketClient(WebSocketSession session) {
        this.session = session;
    }

    // 发送消息的方法
    @SendTo("/channel")
    public void sendMessage(@Payload String message) {
        session.sendMessage(new TextMessage(message));
    }

    // 收到消息的回调
    @OnMessage
    public void onMessage(String message) {
        System.out.println("Received: " + message);
    }
    
    // 关闭连接
    @OnClose
    public void onClose() {
        System.out.println("Connection closed");
    }

    // 异常处理
    @OnError
    public void onError(Throwable error) {
        System.err.println("Error occurred: " + error.getMessage());
    }
}

4. 注册连接：在启动类上启用WebSocket，以便在应用程序启动时自动建立WebSocket连接：

@SpringBootApplication
@EnableWebSocketMessageBroker
public class Application implements WebSocketMessageBrokerConfigurer {
    // ... 其他配置

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic", "/queue");
        config.setApplicationDestinationPrefixes("/app");
    }

    // ... 其他配置
}

在这个例子中，我们创建了一个简单的WebSocket客户端，它监听特定的URI，并能发送和接收文本消息。`@SendTo`注解用于指定目标频道，`@OnMessage`则用于处理接收到的消息。