Netty中自定义事件处理程序和监听器
内容提要
本教程介绍了如何使用Netty创建一个聊天室应用程序。通过使用Netty的通道和事件处理程序，可以实现多个客户端之间的实时对话。文章详细介绍了如何编写客户端和服务器端的事件处理程序，并解释了如何处理消息的发送和接收。此外，还介绍了如何使用自定义事件监听器来处理异步事件。最后，文章展示了如何运行和测试Netty应用程序。
延伸解读
消息解析的细节处理
在Message.parse方法中，使用split(";", 2)将字符串分割为用户名和消息内容两部分。限制分割次数为2是关键，因为消息内容本身可能包含分号，如果全部分割会导致解析错误。这种设计确保了消息的完整性，是处理自定义协议时值得注意的细节。
历史消息的缓存机制
服务器使用一个队列保存最近MAX_HISTORY条消息，当新客户端连接时，会先收到这些历史消息以了解上下文。这种机制在聊天室中很实用，但需要注意队列大小限制，避免内存过度占用。同时，历史消息只包含广播内容，不包括系统消息。
事件监听器的异步确认
通过实现GenericFutureListener，可以在异步操作完成时执行自定义逻辑，如记录连接成功或消息发送状态。这有助于监控网络操作的结果，并在失败时打印堆栈信息。示例中为连接、发送和广播操作添加了监听器，增强了程序的可靠性和可调试性。
管道顺序与编解码器
在ChannelPipeline中，处理器的添加顺序很重要：解码器、自定义处理器、编码器。这是因为入站事件从前往后传递，出站事件从后往前传递。使用内置的StringDecoder和StringEncoder可以简化字符串消息的处理，避免手动处理字节缓冲区。
Q&A
Netty中如何实现自定义事件处理程序？
通过继承SimpleChannelInboundHandler<String>并重写channelRead0()方法，处理接收到的字符串消息。例如，客户端事件处理程序打印消息，服务器事件处理程序解析消息并广播。
Netty聊天室服务器如何管理客户端连接和消息历史？
服务器使用静态Map<String, Channel>存储已连接客户端，键为通道ID；使用静态Queue<String>保存最近MAX_HISTORY（默认5）条消息历史。新客户端连接时，发送历史消息并广播上线通知；断开时移除客户端并广播下线通知。
Netty中如何创建自定义事件监听器？
实现GenericFutureListener<ChannelFuture>接口，在operationComplete方法中检查future是否成功，并执行自定义逻辑（如记录状态）。例如ChannelInfoListener用于操作确认。
Netty聊天室中消息的格式和解析方式是什么？
消息使用CSV格式，以分号分隔用户名和消息内容，例如"user;message"。解析时使用split(";", 2)限制分割次数为2，以允许消息内容包含分号。Message类包含时间、用户名和消息内容。
Netty服务器和客户端的ChannelPipeline是如何配置的？
服务器端在childHandler中为每个SocketChannel添加StringDecoder、ServerEventHandler和StringEncoder，顺序为解码器、处理器、编码器。客户端类似，但使用ClientEventHandler。顺序重要，因为事件在管道中从入站流向出站。
如何运行和测试Netty聊天室应用程序？
通过Maven命令运行：服务器使用mvn exec:java -Dexec.mainClass=ChatServerMain，客户端使用ChatClientMain。启动后，客户端输入用户名和消息，服务器广播消息，新客户端可看到历史消息。
