是的,我知道。当使用BroadcastHub时,如果source的元素个数小于buffer size,则下游可能会收不到任何消息。这是因为BroadcastHub只有在缓冲区填满时才会开始发送消息,而在这种情况下,缓冲区不会被填满。要解决这个问题,可以使用MergeHub来代替BroadcastHub,以确保下游始终可以接收到消息。

akka的broadcasthub在source的元素个数小于其buffer size时,如果先启动了,可能下游一个消息也收不到,你知道吗

原文地址: https://www.cveoy.top/t/topic/vXb 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录