websocket实时推送数据纯java

在Java中实现WebSocket实时推送数据可以使用Java的WebSocket API。以下是一个简单的示例代码：

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;

@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) throws IOException {
        System.out.println("Received message: " + message);

        // 处理接收到的消息，并发送响应
        String response = "Response to: " + message;
        session.getBasicRemote().sendText(response);
    }

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

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

在上述示例中，我们使用`@ServerEndpoint`注解定义了一个WebSocket服务端的端点，指定了路径为`/websocket`。通过`@OnOpen`、`@OnMessage`、`@OnClose`和`@OnError`注解，我们可以定义处理WebSocket连接、接收消息、关闭连接和处理错误的方法。

要在Java应用程序中启动WebSocket服务器，您可以使用Java中的WebSocket容器，如Tomcat或Jetty。具体步骤取决于您使用的容器。

请注意，这只是一个简单的示例代码，您可能需要根据您的具体需求进行修改和扩展。另外，您还可以使用第三方库如Jetty或Tyrus来简化WebSocket的实现。