SpringBoot整合Netty心跳机制过程详解

SpringBoot整合整合Netty心跳机制过程详解心跳机制过程详解

主要介绍了SpringBoot整合Netty心跳机制过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定

的参考学习价值,需要的朋友可以参考下

前言前言

Netty 是一个高性能的 NIO 网络框架，本文基于 SpringBoot 以常见的心跳机制来认识 Netty。

最终能达到的效果：

客户端每隔 N 秒检测是否需要发送心跳。

服务端也每隔 N 秒检测是否需要发送心跳。

当客户端空闲了 N 秒没有给服务端发送消息时会自动发送一个心跳来维持连接。

核心代码代码如下：

public class EchoClientHandle extends SimpleChannelInboundHandler<ByteBuf> {

private final static Logger LOGGER = LoggerFactory.getLogger(EchoClientHandle.class);

@Override

public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {

if (evt instanceof IdleStateEvent){

IdleStateEvent idleStateEvent = (IdleStateEvent) evt ;

if (idleStateEvent.state() == IdleState.WRITER_IDLE){

LOGGER.info("已经 10 秒没有发送信息！");

}

@Override

protected void channelRead0(ChannelHandlerContext channelHandlerContext, ByteBuf in) throws Exception {

//从服务端收到消息时被调用

LOGGER.info("客户端收到消息={}",in.toString(CharsetUtil.UTF_8)) ;

}

}

实现非常简单，只需要在事件回调中发送一个消息即可。

由于整合了 SpringBoot ，所以发送的心跳信息是一个单例的 Bean。

@Configuration

}

}

这里涉及到了自定义协议的内容，请继续查看下文。

当然少不了启动引导：

@Component

public class HeartbeatClient {

private final static Logger LOGGER = LoggerFactory.getLogger(HeartbeatClient.class);

private EventLoopGroup group = new NioEventLoopGroup();

@Value("${netty.server.port}")

private int nettyPort;