springboot websocket 心跳onpong

Spring Boot是一个简化Spring应用开发的框架，它整合了Spring的一些常用配置，使得开发者可以快速搭建和运行Spring应用。WebSocket是一种在单个TCP连接上进行全双工通信的协议，Spring Boot提供了对WebSocket的支持，可以用来构建实时的双向通信应用。

在使用Spring Boot开发WebSocket应用时，心跳机制是一个重要的功能，用于检测连接是否仍然有效。心跳通常由发送心跳包（ping）和响应心跳包（pong）组成。服务器定期发送ping消息，客户端接收到ping消息后，需要回应一个pong消息，这样服务器可以确认客户端仍然在线并可以接收消息。

在Spring Boot中，可以通过配置心跳机制来维护WebSocket连接。例如，可以在`WebSocketMessageBrokerConfigurer`的配置类中重写`configureClientInboundChannel`方法，通过设置`StompSubProtocolHandler`的`heartbeat`属性来定义ping和pong消息的发送频率。

@Override
public void configureClientInboundChannel(ChannelRegistration registration) {
    registration.setInterceptors(new UserChannelInterceptorAdapter());
    registration.taskExecutor().corePoolSize(4 * Runtime.getRuntime().availableProcessors());
    registration.setLengthFieldBasedFrameDecoder(1024 * 1024, 15, 15, 0, 0);
    registration.setLengthFieldPrematureDetector(new LengthFieldPrependedFrameDecoder(64 * 1024));
    registration.setFrameHandler(new WebSocketFrameHandler());
    registration.setClientOutboundChannelHandler(new心跳处理Handler());
}

public class 心跳处理Handler extends ChannelOutboundHandlerAdapter {
    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
        if (msg instanceof PingWebSocketFrame) {
            // 直接发送pong响应
            ctx.writeAndFlush(new PongWebSocketFrame());
        } else {
            super.write(ctx, msg, promise);
        }
    }
}

在上面的代码示例中，`心跳处理Handler`类继承自`ChannelOutboundHandlerAdapter`，并重写了`write`方法，这样当服务器发送了`PingWebSocketFrame`时，会直接发送一个`PongWebSocketFrame`作为响应，从而实现了心跳机制。