java实现websocket客户端发送消息

在Java中，WebSocket是一种全双工通信协议，用于实时双向数据传输。要实现WebSocket客户端发送消息，通常会用到`javax.websocket` API。以下是一个简单的步骤概述：

1. **添加依赖**：
首先，你需要在项目中引入Java WebSocket API，如果你使用Maven，可以在pom.xml文件中添加以下依赖：

   <dependency>
       <groupId>javax.websocket</groupId>
       <artifactId>javax.websocket-api</artifactId>
       <version>1.1</version>
   </dependency>

2. **创建WebSocket客户端**：
创建一个实现了`ClientEndpoint`接口的类，这个接口定义了连接服务器、关闭连接以及处理接收消息的方法：

   import javax.websocket.OnClose;
   import javax.websocket.OnMessage;
   import javax.websocket.OnOpen;
   import javax.websocket.Session;
   import javax.websocket.client.ClientEndpoint;

   @ClientEndpoint
   public class WebsocketClient {
       private Session session;

       @OnOpen
       public void onOpen(Session session) {
           this.session = session;
           System.out.println("Connected to server");
       }

       @OnMessage
       public void onMessage(String message) {
           System.out.println("Received message: " + message);
           // 这里你可以处理接收到的消息
       }

       @OnClose
       public void onClose() {
           System.out.println("Connection closed");
       }

       // 发送消息的方法
       public void sendMessage(String text) {
           try {
               session.getBasicRemote().sendText(text);
           } catch (Exception e) {
               e.printStackTrace();
           }
       }
   }

3. **启动连接**：
使用`javax.websocket.WebSocketContainer`来建立与服务器的连接，并通过创建`WebsocketClient`的实例来触发连接过程：

   import javax.websocket.ContainerProvider;
   import javax.websocket.Session;
   
   public static void main(String[] args) {
       ContainerProvider containerProvider = ContainerProvider.getWebSocketContainer();
       containerProvider.connectToServer(WebsocketClient.class, URL.of("ws://your-server-url"));
   }

替换`URL.of("ws://your-server-url")`为你实际的WebSocket服务器地址。

4. **发送消息**：
调用`sendMessage()`方法即可将文本发送给服务器：

   WebsocketClient client = new WebsocketClient();
   client.sendMessage("Hello from the client!");