scala - ack in spray 超时

Question

在 Spray 中，对于分块响应，我们可以发送带有ack 的分块消息

peer ! MessageChunk(buffer).withAck(MyAck(k))

我们可以得到确认消息传递到操作系统网络层的确认消息。我们对这些 acks 有类似超时的东西吗？

Answer 1

我认为没有内置的 Ack Timeout 功能可以喷涂。

如果您的 Ack 包含有关已发送块的详细信息，则分块 Actor应该可以跟踪发送的消息和超时。请参阅ChunkingActor[T]用于Stream[T] 在喷雾源代码中编组以了解如何完成此操作。你可以选择让这个actor跟踪发送的最后一个块以及发送的时间。如果在设置的超时期间没有为该块返回 Ack，您可以处理块传递“超时”的情况。