答案：Java通过Spring Boot集成WebSocket实现长连接通信，首先添加spring-boot-starter-websocket依赖并配置WebSocketConfig启用STOMP协议，暴露/ws端点并设置消息代理；接着定义Message实体类和WsController控制器，使用@MessageMapping处理客户端请求，通过@SendTo广播消息或SimpMessagingTemplate实现点对点发送；前端引入sockjs和stompjs库，建立连接后订阅/topic/messages频道接收消息，向/app/send发送数据；为保障连接稳定，在配置中设置心跳间隔与超时，并可借助拦截器管理会话生命周期，最终实现聊天、通知等实时功能。
Java实现WebSocket长连接进行实时通信，核心在于使用标准API或框架建立持久化双向通道。Spring Boot结合JSR-356（Java API for WebSocket）或Spring WebSocket模块是主流做法。下面从配置到应用逐步说明。
启用WebSocket支持
在Spring Boot项目中开启WebSocket功能，需添加依赖并配置配置类。
1. 添加Maven依赖：- spring-boot-starter-websocket
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
@Override
public void registerStompEndpoints(StompEndpointRegistry registry) {
registry.addEndpoint("/ws").withSockJS(); // 暴露STOMP端点
}
@Override
public void configureMessageBroker(MessageBrokerRegistry registry) {
registry.enableSimpleBroker("/topic", "/queue"); // 订阅广播路径
registry.setApplicationDestinationPrefixes("/app"); // 客户端发送消息前缀
}
}
上述配置启用了STOMP协议，允许浏览器通过SockJS降级兼容，/ws为连接入口。
定义消息处理与数据模型
创建用于传输的数据对象和控制器接收客户端指令。
立即学习“Java免费学习笔记（深入）”；
1. 消息实体类：public class Message {
private String content;
private String sender;
// getter/setter
}
2. 处理器Controller：
@Controller
public class WsController {
@Autowired
private SimpMessagingTemplate messagingTemplate;
@MessageMapping("/send")
@SendTo("/topic/messages")
public Message broadcast(Message message) {
return message; // 广播给所有订阅者
}
// 点对点发送示例
public void sendToUser(String userId, Message message) {
messagingTemplate.convertAndSendToUser(userId, "/queue/private", message);
}
}
@MessageMapping对应客户端发送的目标地址，@SendTo将返回值推送到指定主题。
前端连接与交互
浏览器通过JavaScript建立连接并监听消息。
1. 引入sockjs和stompjs库：2. 建立连接并收发消息：
const socket = new SockJS('/ws');
const stompClient = Stomp.over(socket);
stompClient.connect({}, () => {
console.log('Connected');
// 订阅广播频道
stompClient.subscribe('/topic/messages', (msg) => {
const data = JSON.parse(msg.body);
console.log('Received:', data);
});
// 发送消息
stompClient.send('/app/send', {}, JSON.stringify({
content: 'Hello',
sender: 'user1'
}));
});
连接成功后可订阅/topic/messages获取广播消息，通过/app/send触发后端处理逻辑。
心跳与连接管理
保持长连接稳定需设置心跳机制和异常处理。
在WebSocketConfig中调整心跳间隔：@Override
public void configureHeartbeatValue(WebSocketSession session,
HeartBeatInfo info) {
info.setInterval(5000); // 发送心跳频率
info.setTimeout(20000); // 超时断开
}
也可自定义ChannelInterceptor监听连接生命周期，记录用户在线状态或清理资源。
基本上就这些。只要配置正确，前后端能稳定通信，就能实现实时聊天、通知推送等功能。关键是理解STOMP的发布订阅模型以及Spring的消息路由机制。
