java - 如何用netty4实现高吞吐量服务器

Question

如何用netty4实现高吞吐量的服务器？
包很小，大约16byte~0.5K，tps在我的benchmark中大约8.8w/s，无法上升，netty4中有一些参数调整建议以利于小包吗？
代码是RocketMQ ，它是一个具有自定义存储结构的MQ，在broker和client之间也使用私有(private)协议(protocol)。
非常感谢。

Answer 1

就像 Norman Maurer 在他的评论中所说的那样，如果没有一些代码和分析，就很难提供帮助。不过我会尝试一下...

由于每个数据包都很小，因此单独发送它们会产生很大的开销，这是因为 Netty 的设计方式所致。一旦您发送一条消息，它就会穿过整个链(管道)，虽然很有用，但它有助于保持事情简单和模块化，但如果您发送多条小消息，它会很快增加。

作为一种解决方案，您可以尝试将它们放在一个队列中，该队列每 10 毫秒或在 100 个数据包填满后刷新一次。请注意，这将会导致延迟增加，特别是当仅发送少量数据包时。