使用Java、spring4.3.20、websocket编写一个消息推送功能，并给出详细的实现代码

好的，下面是一个简单的示例代码：

首先，我们需要引入相关的依赖（pom.xml文件中）：

<dependency>
    <groupId>org.springframework</groupId>
    <artifactId>spring-websocket</artifactId>
    <version>4.3.20.RELEASE</version>
</dependency>

然后，我们需要定义一个WebSocket处理器类，用于处理客户端连接、断开连接和消息发送等操作：

import java.io.IOException;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
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;
import org.springframework.web.socket.handler.TextWebSocketHandler;

@Component
public class MessagePushHandler extends TextWebSocketHandler implements WebSocketHandler {
    private static final Logger logger = LoggerFactory.getLogger(MessagePushHandler.class);
    
    private static final Map<String, WebSocketSession> sessions = new ConcurrentHashMap<>();

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        logger.info("New client connected: {}", session.getId());
        sessions.put(session.getId(), session);
    }

    @Override
    public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
        logger.info("Received message from client {}: {}", session.getId(), message.getPayload().toString());
    }

    @Override
    public void handleTransportError(WebSocketSession session, Throwable exception) throws Exception {
        if (session.isOpen()) {
            session.close();
        }
        logger.error("Error occurred at Websocket: {}", exception.getMessage());
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        logger.info("Client disconnected: {}", session.getId());
        sessions.remove(session.getId());
    }

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

    public static void pushMessage(String message) {
        logger.info("Pushing message to {} clients: {}", sessions.size(), message);
        TextMessage textMessage = new TextMessage(message);
        for (WebSocketSession session : sessions.values()) {
            try {
                if (session.isOpen()) {
                    session.sendMessage(textMessage);
                }
            } catch (IOException e) {
                logger.error("Error occurred while sending message to client: {}", e.getMessage());
            }
        }
    }
}

该处理器类继承自`TextWebSocketHandler`，重写了WebSocket处理器的方法，用于处理客户端连接、断开连接和消息发送等操作。

其中，`afterConnectionEstablished`方法用于处理客户端连接，将其WebSocketSession对象存储在`sessions`集合中；`handleMessage`方法用于处理客户端发送的消息；`handleTransportError`方法用于处理WebSocket传输错误；`afterConnectionClosed`方法用于处理客户端断开连接，将其WebSocketSession对象从`sessions`集合中移除。

此外，`pushMessage`方法用于向所有客户端推送消息，遍历`sessions`集合，发送消息给每一个WebSocketSession对象。

最后，我们需要在Spring配置文件中添加WebSocket相关的配置：

<websocket:message-broker>
    <websocket:stomp-endpoint path="/websocket"/>
    <websocket:simple-broker prefix="/topic"/>
</websocket:message-broker>

<bean class="com.example.MessagePushHandler"/>

其中，`stomp-endpoint`定义WebSocket的地址，`simple-broker`定义消息的前缀。

现在，我们可以在Controller中调用`MessagePushHandler.pushMessage()`方法来向客户端推送消息了。例如：

@RequestMapping("/pushMessage")
@ResponseBody
public String pushMessage(@RequestParam("message") String message) {
    MessagePushHandler.pushMessage(message);
    return "success";
}

以上就是一个简单的消息推送功能的实现代码。