java写一个websocket消息推送

在Java中，实现WebSocket的消息推送通常涉及到Spring框架和WebSocket的相关库，如Spring Websocket或Jetty等。下面是一个简单的示例，展示如何使用Spring Boot创建一个基本的WebSocket服务器：

首先，你需要添加依赖到你的`pom.xml`文件中：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-websocket</artifactId>
</dependency>

然后，在Spring配置类中开启WebSocket支持，并绑定WebSocket处理器：

@Configuration
@EnableWebSockets
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(new ChatWebSocketHandler(), "/chat");
    }
}

接着，创建一个处理WebSocket消息的处理器类，比如`ChatWebSocketHandler`：

@Component
public class ChatWebSocketHandler extends TextMessageHandler {

    private Map<String, UserSocket> users = new ConcurrentHashMap<>();

    @Override
    protected void handleTextMessage(WebSocketSession session, String message) throws Exception {
        // 在这里解析接收到的消息并发送给所有用户
        for (UserSocket user : users.values()) {
            if (!user.equals(session)) { // 不发送给自己
                user.sendMessage(message);
            }
        }

        // 添加新连接和移除断开连接的操作
        // ...
    }

    public synchronized void sendMessage(String userId, String message) {
        UserSocket user = users.get(userId);
        if (user != null) {
            user.sendMessage(message);
        }
    }

    // 用户Socket接口或实现类
    interface UserSocket {
        void sendMessage(String message);
    }
}

在这个例子中，当你向"/chat"端点发送文本消息时，`handleTextMessage`方法会被触发，它会广播消息给其他所有连接的客户端。