使用 rediscala 批量插入

Question

我正在尝试使用 https://github.com/etaty/rediscala 版本 1.2 准备批量插入，但没有成功。我认为最好的方法是制作这样的东西：

implicit val akkaSystem = akka.actor.ActorSystem()

val redis = RedisClient()

RedisProtocolRequest.multiBulk("SET", Seq(ByteString("mykey"), ByteString("myvalue")) ) ++ RedisProtocolRequest.multiBulk("SET", Seq(ByteString("yourkey"), ByteString("yourvalue")) )

???????????

akkaSystem.shutdown()

不幸的是，我找不到向服务器发送 ByteString 的方法。谁能帮我完成剧本，还是我走错了路？

Answer 1

为什么不使用 redis.transaction？

val keys = Seq("mykey", "yourkey")
val values = Seq("myvalue", "yourvalue")

val multi = redis.transaction()
keys.zip(values).foreach(p => {
  multi.set(p._1, p._2)
})
val futureResponse = multi.exec()

使用 rediscala 批量插入

Mass insert using rediscala

scala

redis

rediscala