要實現消息推送功能，可以使用Java中的WebSocket技術。WebSocket是一種雙向通信協議，可以實現實時推送消息到客戶端。

首先，需要在Java項目中引入WebSocket相關的庫，比如Spring WebSocket或者Java-WebSocket。

然后，創建一個WebSocket服務器端，可以使用Spring Boot或者獨立的Java類來實現。在服務器端，需要定義一個WebSocket處理器類，來處理收到的消息和連接狀態的變化。可以繼承WebSocketHandler類并重寫其中的方法，比如onOpen、onClose、onMessage等。

在處理器類中，可以定義一個靜態的Set來保存所有的WebSocket連接，用于向所有連接的客戶端發送消息。可以使用ConcurrentHashMap來實現線程安全的Set。

以下是一個簡單示例：

import java.util.Collections;
import java.util.HashSet;
import java.util.Set;

import org.springframework.web.socket.CloseStatus;
import org.springframework.web.socket.TextMessage;
import org.springframework.web.socket.WebSocketHandler;
import org.springframework.web.socket.WebSocketMessage;
import org.springframework.web.socket.WebSocketSession;

public class MyWebSocketHandler implements WebSocketHandler {
    private static final Set<WebSocketSession> sessions = Collections.synchronizedSet(new HashSet<>());

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        // 處理收到的消息
        String receivedMessage = (String) message.getPayload();
        System.out.println("Received message: " + receivedMessage);
        
        // 向所有連接發送消息
        for (WebSocketSession s : sessions) {
            s.sendMessage(new TextMessage("Server: " + receivedMessage));
        }
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus closeStatus) throws Exception {
        sessions.remove(session);
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        // 處理連接錯誤
    }

    @Override
    public boolean supportsPartialMessages() {
        return false;
    }
}

最后，配置WebSocket服務器的地址，并在客戶端調用WebSocket的API來連接服務器。在客戶端，可以使用JavaScript的WebSocket對象來實現消息的接收和發送。

這只是一個簡單的實現示例，實際需要根據具體的業務需求來進行適當的修改和擴展。