java中的websocket

Java中的WebSocket是一种在Web浏览器和服务器之间进行双向通信的协议。它允许服务器主动向客户端发送消息，而不需要客户端发起请求。这使得实时通信和实时数据传输成为可能。

在Java中，可以使用Java API for WebSocket（JSR 356）来实现WebSocket。这个API提供了一组类和接口，用于创建WebSocket服务器和客户端。

要创建一个WebSocket服务器，可以使用javax.websocket.server.ServerEndpoint注解来标记一个类，表示这是一个WebSocket端点。然后，可以使用@OnOpen、@OnMessage、@OnClose和@OnError注解来定义处理连接打开、接收消息、连接关闭和错误处理的方法。

以下是一个简单的WebSocket服务器示例：

import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.ServerEndpoint;

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

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("WebSocket opened: " + session.getId());
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received message: " + message);
        session.getBasicRemote().sendText("Message received");
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("WebSocket closed: " + session.getId());
    }

    @OnError
    public void onError(Session session, Throwable error) {
        System.out.println("WebSocket error: " + error.getMessage());
    }
}

要创建一个WebSocket客户端，可以使用javax.websocket.ClientEndpoint注解来标记一个类，表示这是一个WebSocket端点。然后，可以使用@OnOpen、@OnMessage、@OnClose和@OnError注解来定义处理连接打开、接收消息、连接关闭和错误处理的方法。

以下是一个简单的WebSocket客户端示例：

import javax.websocket.ClientEndpoint;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import java.net.URI;

@ClientEndpoint
public class WebSocketClient {

    @OnOpen
    public void onOpen(Session session) {
        System.out.println("WebSocket opened: " + session.getId());
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received message: " + message);
    }

    @OnClose
    public void onClose(Session session) {
        System.out.println("WebSocket closed: " + session.getId());
    }

    @OnError
    public void onError(Session session, Throwable error) {
        System.out.println("WebSocket error: " + error.getMessage());
    }

    public static void main(String[] args) {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        try {
            Session session = container.connectToServer(WebSocketClient.class, new URI("ws://localhost:8080/websocket"));
            session.getBasicRemote().sendText("Hello, server!");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

以上示例展示了如何创建一个简单的WebSocket服务器和客户端，并定义了处理连接、消息、关闭和错误的方法。可以根据实际需求扩展这些示例来实现更复杂的功能。