给定以下代码（使用 Spring Webflux 和 RSocket）：
@MessageMapping("hello.{name}")
public Mono<String> greet(@DestinationVariable String name) {
return Mono.just("Hello " + name); // or assume this is making a slow http call
}
问题是：
当服务器负载过重时，客户端是否会向服务器发送请求，服务器会缓冲该请求？或者实际上是否有某种机制让客户端等到服务器向客户端发送信号？
如果客户端仍然发送请求，那么在某些时候服务器将内存不足来缓冲所有多余的请求。我们一般是怎么处理的？可以上网吗 经纪人在这种情况下有帮助吗？ （假设是突发流量，我们无法及时横向扩展或纵向扩展服务器）
【问题讨论】：
标签： spring-webflux project-reactor reactive rsocket netifi
RSocket 作为一种网络协议，具有一等公民的弹性。在 RSocket 中，Resilience 属性以两种方式公开：
如果您进行流式传输，您的订阅者可以控制传递的元素数量，因此您的订阅者不会被服务器淹没。下面的动画展示了响应流规范是如何在 RSocket 协议级别实现的：
可能会注意到，在 Reactive Streams 中，Subscriber（左侧）requests 数据通过其Subscription，此请求被转换为二进制帧，通过网络发送，并且一次接收者接收到该帧，对其进行解码，然后将其传递给远程站点上的相应订阅，以便远程发布者可以生成确切数量的消息。
另一方面，与流媒体一起，通常管理多个连接的服务器必须面对负载，并且在发生故障时，它应该能够阻止任何进一步的交互。为此，RSocket 带来了一个内置的协议特性，称为Leasing。简而言之，Leasing 是协议 Rate Limiting 的内置内容，其中请求限制是动态的，并且完全由 Responder 方控制。
在该过程中可能会区分一些短语：
Lease 的特定帧。该框架包含 2 个关键值：Number of Requests 和 Time to Live。第一个值告诉请求者它可以发送给响应者的请求数。第二个值表示这种津贴的有效期。因此，如果请求者到那时还没有使用所有这些，则该配额将被视为无效，并且请求者 sied 将拒绝任何进一步的请求。下面的动画描述了这种交互：
租约策略在per connection 基础上运作，这意味着如果您发出租约，您会为单个特定的远程请求者发出它，而不是为连接到您服务器的所有请求者发出它。另一方面，可以应用数学来在所有连接的请求者之间共享整个服务器容量，这取决于一些指标等。
有几个很好的示例演示了如何将流控制和租赁与 RSocket 一起使用。所有这些都可以在RSocket-Java项目here的官方git repo中找到
【讨论】：