java - Netty 中用于服务器端计划任务/事件的最佳方法

Question

我正在尝试在 Netty 4.0 中实现一个服务器应用程序，它通过 TCP/IP 套接字与客户端通信。 建立连接后，客户端将建立初始连接。 服务器将每隔 X 分钟向客户端发送一次 ping 消息，每个客户端的 X 可以不同。 一旦客户端成功获得“ping”，客户端将尝试上传/传输文件到服务器。 服务器接收文件，并将其写入磁盘。

我想知道在 Netty 中执行此操作的最佳方法是什么，主要是调度部分(在 cron 基础上发送 ping 消息并接收文件)

我在网上查了一下，发现有一个及时连接到服务器的 Uptime ClientHandler 示例，但那是一个客户端，它也在 ClientBootstrap 中使用了一些方法 ( https://github.com/netty/netty/blob/master/example/src/main/java/io/netty/example/uptime/UptimeClientHandler.java#L78 )

我还找到了一个 http://netty.io/4.0/api/io/netty/util/HashedWheelTimer.html , 但找不到任何有用的示例来详细说明 Netty 4.0 中的用法。

任何帮助将不胜感激，非常感谢!!

Answer 1

基本上你会使用 IdleStateHandler和一个 ChannelStateHandler 实现，它将对 IdleStateEvent 使用react或直接使用 Channel 的 eventLoop。

例如，eventLoop 的用法可能是这样的:

Channel channel = ...
channel.eventLoop().schedule(new PingTask, delay, time unit);