17370845950

答案：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功能，需添加依赖并配置配置类。

• 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为连接入口。

定义消息处理与数据模型

创建用于传输的数据对象和控制器接收客户端指令。

public class Message {
    private String content;
    private String sender;

    // getter/setter
}

@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建立连接并监听消息。

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触发后端处理逻辑。

心跳与连接管理

保持长连接稳定需设置心跳机制和异常处理。

@Override
public void configureHeartbeatValue(WebSocketSession session, 
                                   HeartBeatInfo info) {
    info.setInterval(5000);   // 发送心跳频率
    info.setTimeout(20000);   // 超时断开
}

也可自定义ChannelInterceptor监听连接生命周期，记录用户在线状态或清理资源。

基本上就这些。只要配置正确，前后端能稳定通信，就能实现实时聊天、通知推送等功能。关键是理解STOMP的发布订阅模型以及Spring的消息路由机制。