Netty 写入所有连接的通道

Question

我需要一些建议，如何实现一个 netty 服务器，该服务器从某些源（例如文件）获取数据，然后将其作为字符串发送给所有连接的客户端。我想要类 Server 并在此类的对象上调用方法广播。应该这样使用：

Server server = new Server();
String message;

while (true) {
    message = getMessage();
    server.broadcast(message);
}

我知道为此我可以使用 ChannelGroup，但是我不知道如何防止超出通道写入缓冲区（我不知道如何使用 channel.isWritable()）。

ChannelGroup broadcast = new DefaultChannelGroup("broadcast");

...

public void broadcast(String message) {
    for (Channel channel : broadcast) {
        if (channel.isWritable())
            channel.write(message);
    }
}

上述解决方案是错误的，因为我希望将每条消息传递给每个客户端。我很感激一些关于如何解决我的问题的建议。

Answer 1

如果交付给每个客户是指您需要将其发送给每个客户，那么最简单的技术是使用ChannelGroup 本身的方法。 writeAndFlush 方法（如果是 netty 3.x 则为 write 方法）返回一个 future，当消息被刷新到组中的所有通道时将发出信号。

ChannelGroupFuture future = broadcast.writeAndFlush(message);
future.awaitUninterruptibly();

您可以使用ChannelGroupFuture的方法来判断消息是否写入所有通道，并找出哪些通道失败。

这将限制您使用最慢通道的性能，但您的示例代码暗示这没关系。让各个渠道全速运行，或者知道消息已实际传递，可以显着扩大范围。