java实现websocket实时推送数据

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

1. 首先，创建一个WebSocket端点类来处理WebSocket连接和消息：

import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;

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

    @OnOpen
    public void onOpen(Session session) {
        // 连接建立时触发
        System.out.println("WebSocket连接已建立");
    }

    @OnMessage
    public void onMessage(String message, Session session) {
        // 接收到消息时触发
        System.out.println("收到消息：" + message);
    }

    @OnClose
    public void onClose(Session session, CloseReason closeReason) {
        // 连接关闭时触发
        System.out.println("WebSocket连接已关闭");
    }

    @OnError
    public void onError(Throwable error) {
        // 发生错误时触发
        System.out.println("WebSocket错误：" + error.getMessage());
    }
}

2. 创建一个Servlet类来配置和启动WebSocket端点：

import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;

@WebServlet(urlPatterns = "/websocket/*")
public class WebSocketServlet extends HttpServlet {
    
    @Override
    public void init() {
        // 注册WebSocket端点
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        try {
            container.connectToServer(WebSocketEndpoint.class, new URI("ws://localhost:8080/websocket"));
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

3. 在web.xml中配置Servlet：

<web-app>
  <servlet>
    <servlet-name>WebSocketServlet</servlet-name>
    <servlet-class>com.example.WebSocketServlet</servlet-class>
    <load-on-startup>1</load-on-startup>
  </servlet>
</web-app>

4. 在Web应用程序中启动WebSocket服务器。

现在，您的Java应用程序已经配置了一个WebSocket端点，并可以接收和处理来自客户端的消息。您可以在`onMessage`方法中实现实时推送逻辑，例如将消息广播到所有连接的客户端。

请注意，此示例仅演示了最基本的WebSocket功能。在实际应用中，您可能需要考虑安全性、消息编解码、身份验证等方面的问题。