java使用websocket

import java.io.IOException;
import javax.websocket.OnMessage;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

@ServerEndpoint("/websocket")
public class WebSocketExample {

    /**
     * 当客户端发送消息时，此方法会被调用。
     * @param message 客户端发送的消息
     * @param session 与客户端的会话
     */
    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received: " + message);

        // 回复客户端
        try {
            session.getBasicRemote().sendText("Echo: " + message);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

解释说明

1. 导入必要的包：

   • javax.websocket.*：用于WebSocket通信的核心类和注解。

2. 定义WebSocket服务器端点：

   • 使用 @ServerEndpoint 注解来指定WebSocket的URL路径。在这个例子中，路径是 /websocket。

3. 处理消息：

   • @OnMessage 注解的方法会在客户端发送消息时被调用。
   • 方法接收两个参数：客户端发送的消息和与客户端的会话对象。
   • 在这个例子中，服务器接收到消息后会打印到控制台，并将消息回显给客户端（加上前缀 "Echo: "）。

4. 发送回复：

   • 使用 session.getBasicRemote().sendText() 方法向客户端发送文本消息。

这个简单的示例展示了如何使用Java创建一个WebSocket服务器端点，并处理来自客户端的消息。