多线程操作 redis 会有并发问题嘛？

使用的可以是这种格式的

keyA queue:test

keyB data:overload:user

抽风了， 使用的 key 是上面这种格式的

这是 jedis 的问题吧

发一下代码吧，估计是代码写的有问题。

用了同一个 connection 吧，估计是用错了。

看上去复用了一个网络连接，所以线程 1 发出请求的回答被线程 2 收走了。

请用 Lettuce

@rrfeng
@arrow8899
@ke1e

private static void initialPool() {
ApplicationContext applicationContext =
new FileSystemXmlApplicationContext("classpath:config/spring-application-redis.xml");
jedisPool = (JedisPool) applicationContext.getBean("jedisPool");
logger.info("<---jedis pool init--->");
}

/**
* 初始化,加锁防止被多次初始化 pool
*/
private synchronized static void poolInit() {
if (jedisPool == null) {
initialPool();
}
}

/**
* 获取 Jedis 实例
*
* @return Jedis
*/
public static Jedis getJedis() {
poolInit();
Jedis jedis = null;
try {
if (jedisPool != null) {
jedis = jedisPool.getResource();
}
} catch (Exception e) {
logger.error("get jedis error",e);
} finally {
returnResource(jedis);
logger.debug("<---jedis return resource--->");
}
return jedis;
}


/**
* 释放 jedis 资源
*
* @param jedis
*/
public static void returnResource(final Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}


public static String get(String key) {
try {
return getJedis().get(key);
} catch (Exception ex) {
logger.error("redis get error",ex);
}
return null;
}


public static String lpop(String key) {
try {
return getJedis().lpop(key);
} catch (Exception ex) {
logger.error("lpop error , key = {}", key, ex);
}
return null;
}

jedis 是线程不安全的
请使用 redisson

@msg7086 还有复用同一个网络连接这么一说

@cheng6563
我看网上说直接使用 jedis 是线程不安全的，但是使用 JedisPool 是线程安全的,
我使用的就是 jedisPool 来获取 jedis 实例



Jedis 不是线程安全的，故不应该在多线程环境中共用一个 Jedis 实例。但是，也应该避免直接创建多个 Jedis 实例，因为这种做法会导致创建过多的 socket 连接，性能不高。
要保证线程安全且获得较好的性能，可以使用 JedisPool。JedisPool 是一个连接池，既可以保证线程安全，又可以保证了较高的效率。
可以声明一个全局的 JedisPool 变量来保存 JedisPool 对象的引用，然后在其他地方使用。要知道，JedisPool 是一个线程安全的连接池。

} finally {
returnResource(jedis);
logger.debug("<---jedis return resource--->");
}
return jedis;

这是什么操作，返回后马上把 redis 关闭

看问题是拿到了同一个 jedis
原因应该是出在你获取 jedis 的代码，获取了 jedis 你还没用，你就在 finally 处调用了 jedis.close 将连接返回了连接池，导致连接池存在可用的 jedis，不会创建新对象，下一次拿到的还是相同的 jedis

关注，有大佬找到原因的话告知下。。

这一看就是 jedis 的问题，或者是你用的不对

知道
@jorneyr 尴尬，应该是
public static Jedis getJedis() {
poolInit();
Jedis jedis = null;
try {
if (jedisPool != null) {
jedis = jedisPool.getResource();
}
} catch (Exception e) {
logger.error("get jedis error", e);
returnResource(jedis);
logger.debug("<---jedis return resource--->");
}
return jedis;
}

歪个楼，初始化 JedisPool 用单例的安全检查或者静态内部类，别加锁。。。Jedis 不是熟，但是 Lettuce 现在 shi 更流行也更好用，所以换 Lettuce 是最好的方式。

@Jrue0011 大佬，为什么拿到相同的 jedis，使用的 key 是不同的，为什么会拿到别的 key 的结果呢？

@Buffer2Disk 额。。你追踪下 Jedis 源码就知道了。一个 jedis -> client -> connection 维护一个 outputStream 和一个 inputStream，命令用 outputStream 发送，响应从 inputStream 读取，发送命令和读取响应的方法没加锁，一个线程读到另一个线程本该接收的响应很正常。。

@Jrue0011 改了以后确实可以了，有一个问题就是，jedis close() 后难道不是立马就释放回连接池的嘛？

我试了下循环一百次 get 操作，很容易就触发到 maxTotal 的阈值了，然后程序就一直 hang 在那里，像是在等待连接池释放新的连接出来一样，但是等了很久也没有出来，这个是有什么参数可以控制的么

@Jrue0011 我看到有个 maxWaitMillis
当资源池连接用尽后，调用者的最大等待时间(单位为毫秒)，默认值 -1：表示永不超时

有没有什么参数可以控制 close 后，多久返回连接池的。，。。。

/**
* 获取 Jedis 实例
*
* @return Jedis
*/
public static Jedis getJedis() {
poolInit();
Jedis jedis = null;
try {
if (jedisPool != null) {
jedis = jedisPool.getResource();
}
} catch (Exception e) {
logger.error("get jedis error", e);
returnResource(jedis);
logger.debug("<---jedis return resource--->");
}
return jedis;
}


public static String get(String key) {
Jedis jedis = null;
try {
jedis = getJedis();
return jedis.get(key);
} catch (Exception ex) {
logger.error("redis get error", ex);
} finally {
returnResource(jedis);
}
return null;
}

/**
* 释放 jedis 资源
*
* @param jedis
*/
public static void returnResource(final Jedis jedis) {
if (jedis != null) {
jedis.close();
}
}

有安全问题，用 jedispool

@leafre 注意审题啊，我用的就是 jedisPool,只不过现在查出来是我的用法不太对

@Buffer2Disk 没有设置调用 close()之后多久返回连接池的这种设定。。。只要调用 jedis.close()，内部做一些处理就会返回对象池了，你调用 100 次之后的阻塞应该是别的问题。

@Jrue0011 但是我测试以后，这个阻塞的上限确实是一直跟着 maxTotal 变化的，给人的感觉就像是用完以后没有释放回连接池里面一样。。。。但是你看我上面的代码，调用 get(key) 后确实 finally 里面 close()了

@Jrue0011 我设置了 maxWaitMillis 为 2 秒，当到达 maxTotal 2 秒后，抛出了这个错误

edis.clients.jedis.exceptions.JedisException: Could not get a resource from the pool

说明确实拿不到新的实例了，那么为啥没释放回去呢。。。。

@Jrue0011

我明白了，是我自己傻逼了，测试的这个新方法没去释放连接，应该没问题了

我看楼上他们说用 lettuce 这个玩意，内部用了 netty，可以复用连接

不知道大佬你用过没有？有没有坑啊

redis 我记得都是原子操作

@kppwp 注意审题哈，这里其实跟 redis 其实没啥关系， 是我操作 jedis 的去连接 redis 的方式不对，

导致并发场景下，向 redis 发送请求的数据被污染了

你可以认为 redis 中的指令没有并发安全问题。但是外部并发地去调用 redis 服务就需要自己去控制了

每个线程使用不同的 redis 连接