我有一个Scala程序,使用线程(实际上是Spark)和Redis (Jedis)。我为我的Redis操作定义了一个object,其中我为连接定义了一个Lazy val。连接对象: lazy val r = new Jedis("127.0.0.1",6379,30)
def find(u: Long): Option[Long]首先,我在每个线程中都有Unknown replay: 4,其中"4“是一个随机字符(redis.clients.jedis.
我尝试使用JedisPool创建几个用于多线程使用的Jedis实例(每个线程可以有一个Jedis实例)。但是,当我试图使用JedisPool.getResource()创建多个实例时,它总是给出相同的Jedis实例。下面的代码还将为我提供redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream,因为多个线程只有一个Jedis实例。jedis = jedisPool.getResour