redis通过事务获取和设置密钥过期

Question

private def getVersionTime(db: RedisClient, interval: Long)(implicit ec: ExecutionContext): Future[Long] = {

import akka.util.ByteString
import redis.ByteStringFormatter

implicit val byteStringLongFormatter = new ByteStringFormatter[Long] {
  def serialize(data: Long): ByteString = ByteString(data.toString.getBytes)
  def deserialize(bs: ByteString): Long = bs.utf8String.toLong
}

db.get[Long]("versionTime").map {
  case Some(v) => loggerF.info(s"Retrieved version time ${v}")
    v
  case None => val current = System.currentTimeMillis()
    db.setex[Long]("versionTime", (current / 1000) + interval, current)
    loggerF.info(s"set version time ${current}")
    current
}

it("check with multiple tasks"){
  val target = 10
  val latch = new java.util.concurrent.CountDownLatch(target)
  (1 to target).map{t =>
    getVersionTime(prodDb, 10).map{r => print("\n" + r); latch.countDown()}
  }
  assert(latch.await(10, TimeUnit.SECONDS))
}

14:52:46.692[pool-1-thread-12]信息EndtoEnditTests-设置版本时间1548062566687 14:52:46.693[pool-1-thread-6]信息EndtoEnditTests-设置版本时间1548062566687 14:52:46.693[pool-1-thread-20]信息EndtoEndittest-设置版本时间1548062566687 14:52:46.692[pool-1-thread-2]信息EndtoEndittest-设置版本时间1548062566686 14:52:46.692[pool-1-thread-10]信息EndtoEndittest-设置版本时间1548062566687 14:52:46.693[pool-1-thread-8]信息EndtoEndittest-设置版本时间1548062566687 14:52:46.692[pool-1-thread-4]信息测试-设置版本时间1548062566686 14:52:46.692[pool-1-thread-11]信息EndToEndITTests-设置版本时间1548062566687 14:52:46.692[pool-1-thread-9]信息EndtoEndtoEnditTests-设置版本时间1548062566687 14:52:46.692[pool-1-thread-7]信息EndtoEndtoEnditTests-设置版本时间1548062566687

预期的行为是-设置版本时间应该来一次，对于检索到的其余线程，版本时间应该打印出来。我想我需要在这里使用transaction，以便将get和setex包装在watch和exec中

  private def getVersionTimeTrans(db: RedisClient, interval: Long): Long = {
    import akka.util.ByteString
    import redis.ByteStringFormatter

    implicit val byteStringLongFormatter = new ByteStringFormatter[Long] {
      def serialize(data: Long): ByteString = ByteString(data.toString.getBytes)
      def deserialize(bs: ByteString): Long = bs.utf8String.toLong
    }

    val redisTransaction = db.transaction()
    redisTransaction.watch("versionTime")
    val result: Future[Long] = redisTransaction.get[Long]("versionTime").map {
      case Some(v) => loggerF.info(s"Retrieved version time ${v}")
        v
      case None => val current = System.currentTimeMillis()
        redisTransaction.setex[Long]("versionTime", (current / 1000) + interval, current)
        loggerF.info(s"set version time ${current}")
        current
    }
    redisTransaction.exec()
    val r = for {
      i <- result
    } yield {
      i
    }
    Await.result(r, 10 seconds)
  }

测试

it("check with multiple threads "){
  val target = 10
  val latch = new java.util.concurrent.CountDownLatch(target)
  (1 to target).map{t =>
    Future(getVersionTimeTrans(prodDb, 10)).map{r => latch.countDown()}
  }
  assert(latch.await(10, TimeUnit.SECONDS))
}

对于这个测试，输出也是一样的。我不知道如何正确地将它包装在事务中。请帮忙。

Answer 1

研究一下rediscala实现，您似乎不能使用我在原始答案中建议的乐观锁定（见下文），因为在rediscala中，TransactionBuilder直到exec命令才会发送watch命令，这使得它非常无用。GitHub上有一个老的封闭错误，它引用了另一个SO问题，正好是这个场景，答案是

在rediscala中，您不能在事务内部读取，因为您将阻止客户端进行其他请求。我建议您试着看看是否可以在LUA脚本中进行检查。（在lua脚本中转换事务）

几个月后

原始答案

我没有活的Redis来测试它，但查看Redis事务文档，它看起来Redis不支持SQL风格的事务，就像你想象的那样。它支持原子操作，但不能执行“启动事务-获取数据-检查-可能修改-提交”的循环。在exec命令到达之前，所有“获取数据”命令都将排队。这意味着您不能在同一事务中执行get和set之间的任何检查。

如果您查看该文档的“使用check-and-set的乐观锁定”部分，您可以看到实现行为的正确方法是：

null