scala - 由于 redis 是单线程的，如何将这些调用包装在 Future 中？

Question

由于 redis 是单线程的，像下面这样的调用将阻塞直到它返回:

redis.hgetall("some_key")

现在假设我要将我所有的调用包装在 Futures 中，例如，如果我必须同时进行 100K 次这些类型的调用:

Future.sequence(redis_calls)

这样做对性能有帮助吗？还是故障跟踪，或者如果调用被备份，它是否会导致问题？

Answer 1

您会发现最慢的部分是向 Redis 获取命令并再次读取结果，而不是等待 Redis 执行请求。

为避免这种情况，您可以使用 pipelines一次发送一堆命令并一起接收结果。