2

对远程参与者的并发请求的响应需要很长时间才能响应，即 1 个请求需要 300 毫秒，但 100 个并发请求需要将近 30 秒才能完成！所以看起来请求是按顺序执行的！请求大小很小，但序列化之前在 JVM 中的响应大小约为 120 kB。但是响应具有深层嵌套的案例类。

在同一台机器上的两个不同 JVM 上运行时，响应时间也相似。但是在同一个 JVM（即本地参与者）中响应速度很快。它是向一个远程参与者发出并发请求的单个客户端。

我在 akka 调试日志中看到了这个日志。这说明什么？

调试测试应用程序 akka.remote.EndpointWriter - maxWriteCount：50，fullBackoffCount：546，smallBackoffCount：2，noBackoffCount：1，adaptiveBackoff：2000 的耗尽缓冲区

4

1 回答 1

2

日志显示写入发送缓冲区失败。这可能表明

  • 发送缓冲区太小
  • 远程参与者的接收缓冲区太小
  • 网络问题

发送缓冲区大小和接收缓冲区大小直接限制了并发请求和响应的数量！增加客户端和服务器上的发送缓冲区和接收缓冲区大小，以支持客户端和服务器中所需的并发性。

如果缓冲区大小不够，netty 将等待缓冲区被清除，然后再尝试重写缓冲区。默认情况下也会有一个退避时间，这也可以配置。

设置在 remote.netty.tcp 下：

akka {
 remote {
  netty.tcp {
   # Sets the send buffer size of the Sockets,
   # set to 0b for platform default
   send-buffer-size = 1024000b

   # Sets the receive buffer size of the Sockets,
   # set to 0b for platform default
   receive-buffer-size = 2048000b
  }
  # Controls the backoff interval after a refused write is reattempted.
  # (Transports may refuse writes if their internal buffer is full)
  backoff-interval = 1 ms
 }
}

有关完整配置，请参阅Akka 参考配置。

于 2017-05-17T15:25:03.613 回答