我的脑袋围绕着 Flux Sinks,无法理解更高层次的图片。使用时Sinks.Many<T> tryEmitNext,该函数会告诉我是否存在争用以及在失败的情况下我该怎么办(FailFast/Handler)。
但是有没有一个简单的结构可以让我从多个线程安全地发出元素。例如,与其让用户知道存在争用,我应该再试一次,不如将元素添加到队列(mpmc、mpsc 等)中,并且仅在队列已满时才通知。
现在我可以自己添加一个队列来缓解这个问题,但这似乎是一个常见的用例。我想我在这里遗漏了一点。
由于 HTTP2 支持多路复用,我们还需要一个连接池来进行微服务通信吗?如果是,拥有这样的游泳池有什么好处?
示例:服务 A => 服务 B
以上两种服务都只有一个实例可用。
多个连接可能有助于克服每个连接(套接字)的操作系统缓冲区大小限制?还有什么?