答案：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
2. 配置WebSocketConfig：
@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库：
<script src="https://cdn.jsdelivr.net/npm/sockjs-client@1/dist/sockjs.min.js"></script> <script src="https://cdn.jsdelivr.net/npm/@stomp/stompjs@6.1.0/bundles/stomp.umd.min.js"></script>
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的消息路由机制。