推送数据完整Java代码

在Java中，一个完整的实时数据推送代码示例通常会结合WebSockets和第三方库，这里提供一个基于Spring框架和WebSocket API的基本例子。请注意，你需要在项目中导入相应的依赖，例如`spring-websocket`和`org.json`用于JSON处理。

首先，创建一个WebSocket配置类：

import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig {

    @Override
    public void configureMessageBroker(MessageBrokerRegistry config) {
        config.enableSimpleBroker("/topic");
        config.setApplicationDestinationPrefixes("/");
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/websocket").withSockJS();
    }
}

然后，创建一个消息发布服务：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Service;

@Service
public class DataPublisher {

    private final StompSessionHandler handler;

    @Autowired
    public DataPublisher(StompSessionHandler handler) {
        this.handler = handler;
    }

    public void sendData(String data) {
        // 假设我们有一个用户ID，可以根据需求添加更多逻辑
        String userId = "user_id"; // 用实际的用户ID替换
        handler.sendToUser(userId, "/topic/data", data);
    }

    @SendTo("/topic/data")
    public String processAndFormatData(String inputData) {
        // 根据需要处理并格式化数据
        return JSONUtils.toJson(inputData); // 使用json库处理
    }
}

最后，处理WebSocket客户端连接并接收消息的客户端类：

import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketSession;

import java.io.IOException;

@Component
public class StompSessionHandler implements TextMessageHandler {

    private Map<String, WebSocketSession> sessions = new HashMap<>();

    @Override
    public void handleTextMessage(WebSocketSession session, TextMessage message) {
        // 处理来自服务器的消息
        System.out.println("Received message from server: " + message.getPayload());

        // 发布数据给所有连接的客户端
        dataPublisher.sendData(message.getPayload());
    }

    public void sendToUser(String userId, String destination, String message) {
        WebSocketSession userSession = sessions.get(userId);
        if (userSession != null) {
            try {
                userSession.sendMessage(new TextMessage(message));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public void addSession(WebSocketSession session) {
        sessions.put(session.getId(), session);
    }

    public void removeSession(WebSocketSession session) {
        sessions.remove(session.getId());
    }
}

在这个例子中，当服务器接收到新的数据时，会通过WebSocket广播给所有已连接的客户端。客户端则负责接收并显示接收到的数据。