我正在使用apachestorm开发一个实时图像处理应用程序，它需要极低的延迟。在拓扑定义中，每1s一个喷口将发射原始图像（5mb），几个螺栓将处理它们。每个螺栓的处理延迟是可以接受的，总的计算延迟可以在150ms左右。
但是，我发现不同节点上的工作进程之间的消息传递延迟非常高。在5个连续的bolt上，总的延迟大约是200ms。为了计算这个延迟，我从端到端延迟中减去所有的任务延迟。此外，我还实现了一个计时器螺栓，其他处理螺栓将在这个计时器螺栓中注册，以便在开始真正的处理之前记录时间戳。通过比较螺栓的时间戳，我发现每个螺栓之间的延迟很高，正如我之前注意到的那样。
为了分析这种高附加延迟的来源，我首先将发送间隔缩短为1s，这样就不会因为高计算开销而出现排队延迟。另外，在storm ui中，我发现没有一个bolt的cpu利用率很高。
然后，我检查了网络延迟。我使用的是一个1gbps的网络测试平台，通过rtt和带宽对网络进行测试。要发送5mb映像，网络延迟应该不会太高。
最后，我考虑的是缓冲区延迟。我发现每个线程都维护自己的发送缓冲区，并将数据传输到工作者的发送缓冲区。我不知道需要多长时间接收器螺栓才能收到这个发送消息。按照社区的建议，我将发送方/接收方缓冲区大小增加到16384，将storm\u netty\u message\u batch\u size修改为32768。然而，这没有帮助。
我的问题是，如何消除/减少bolt之间的消息传递开销？（inter-workers）有可能同步bolt之间的通信，并让接收方立即毫不延迟地获得发送消息吗？