在Scala中使用Redis（绝地武士）线程时遇到问题

Question

我有一个使用线程（实际上是Spark）和Redis（绝地）的Scala程序。我为我的Redis操作定义了一个对象，其中我为连接定义了一个Lazy val。我需要每个线程打开一个到Redis的连接，并与之并行工作
连接对象：

object redisOp{
  lazy val r = new Jedis("127.0.0.1",6379,30)
  def find(u: Long): Option[Long] = Option(r.get(s"p$u")).flatMap(p => if (p.toLong == u) Some(u) else find(p.toLong))
  // and other functions
}

当我用一根线的时候，效果很好。但当多个线程使用它时，我会出错。起初，我在每个线程中得到了Unknown replay:4，其中“4”是一个随机字符（redis.clients.jedis.exceptions.JedisConnectionException:Unknown reply:）
然后从redis cli我尝试设置config set timeout 30000和30000，因为我也看到了redis。客户。绝地武士。例外。JedisConnectionException：流的意外结束，有时是redis。客户。绝地武士。例外。JedisDataException:错误html" target="_blank">协议错误：日志中的多大容量长度无效。现在在一些运行中（当切换到2个线程而不是4个线程时），程序将永远在一个阶段中运行，不会出错！我查看了Spark UI以查看执行者日志，但找不到任何有用的内容：https://pastebin.com/iJMeBD0D

我认为问题在于定义和使用与Redis的连接。此外，如果需要，请告诉我关闭连接的正确方式。

Answer 1

绝地武士的目标不是线程安全的。您应该在多线程环境中使用某种对象/连接池。绝地武士为此提供绝地武士。更多细节可以在绝地维基上找到。

基本思想是通过JedisPool.getResources（）获取Jedis对象，并通过Jedis.close（）返回该对象。