小编Rah*_*aha的帖子

如何从多个线程调用 Sinks.Many<T>.tryEmitNext?

我的脑袋围绕着 Flux Sinks,无法理解更高层次的图片。使用时Sinks.Many<T> tryEmitNext,该函数会告诉我是否存在争用以及在失败的情况下我该怎么办(FailFast/Handler)。

但是有没有一个简单的结构可以让我从多个线程安全地发出元素。例如,与其让用户知道存在争用,我应该再试一次,不如将元素添加到队列(mpmc、mpsc 等)中,并且仅在队列已满时才通知。

现在我可以自己添加一个队列来缓解这个问题,但这似乎是一个常见的用例。我想我在这里遗漏了一点。

project-reactor

6
推荐指数
1
解决办法
1232
查看次数

我们还需要一个连接池来连接 HTTP2 的微服务吗?

由于 HTTP2 支持多路复用,我们还需要一个连接池来进行微服务通信吗?如果是,拥有这样的游泳池有什么好处?

示例:服务 A => 服务 B

以上两种服务都只有一个实例可用。

多个连接可能有助于克服每个连接(套接字)的操作系统缓冲区大小限制?还有什么?

rpc connection-pooling http2 microservices

3
推荐指数
1
解决办法
1524
查看次数