这个是今天发现一个bug：在测试redis并发读写的时候（jedis作为客户端，并使用了连接池），总是报 java.lang.ClassCastException: java.util.ArrayList cannot be cast to java.lang.Long
at redis.clients.jedis.Connection.getIntegerReply(Connection.java:161)
at redis.clients.jedis.Jedis.del(Jedis.java:108)
类似的错误，就是返回值类型和文档上的返回值类型不相符，感觉很不应该；开始怀疑是jedis实现的一个bug，后来发现一个现象，当抛一个超时异常的时候，后面就连续的出现一个类似上面的错误，最后终于发现了问题所在。
原先的代码是这样的：
public long del(String key) {
long rt = 0L;
Jedis jedis = null;
try {
jedis = getJedis();
rt = jedis.del(key);
}
finally
{
releaseJedisInstance(jedis);
}
return rt;
}
这样写貌似OK，但实际上有问题，假设jedis在执行这个命令的时候，因为redis超负荷，jedis可能返回超时的异常，这个时候发生了什么，没有处理这个异常，直接将这个jedis的链接返回到了连接池，这样有没有问题呢？
查看jedis源码发现他的connection中对网络输出流做了一个封装，其中自建了一个buffer，所以当发生异常的时候，这个buffer里还残存着上次没有发送或者发送不完整的命令，这个时候没有做处理，直接将该连接返回到连接池，那么重用该连接执行下次命令的时候，就会将上次没有发送的命令一起发送过去，所以才会出现上面的错误“返回值类型不对”；
所以正确的写法应该是在发送异常的时候，销毁这个连接，不能再重用！
正确的写法如下：
public long del(String key) {
long rt = 0L;
Jedis jedis = null;
try {
jedis = getJedis();
rt = jedis.del(key);
releaseNormalResource(jedis);
} catch (Exception e) {
returnBrokenResource(jedis);
throw Exception x;
}
return rt;
}
从上面的分析来看，我更认为是jedis实现的一个bug，当连接出现异常的时候，应该对该连接的buffer进行清空的，你认为呢？
分享到：
相关推荐
本教程将详细介绍如何配置Jedis的连接池——ShardedJedisPool，这对于初学者理解和实践Redis连接池的使用至关重要。 首先，我们需要引入Jedis和Apache Commons Pool2的依赖库。在Maven项目中，可以在pom.xml文件中...
使用Jedis时，可以通过连接池来管理连接，例如使用`GenericObjectPoolConfig`配置连接池参数，如最大活动连接数、最大空闲连接数、最大等待时间等。然后创建`JedisPool`实例，指定Redis服务器地址、端口、密码等...
4. **使用JedisPool**：在需要使用Jedis时，从池中borrow一个实例，执行操作后返回给连接池，而不是直接关闭。 四、连接池的优势 1. **性能提升**：避免了频繁创建和销毁连接的开销，提高了应用的响应速度。 2. **...
Jedis连接池的使用 Jedis连接池是Redis客户端Jedis的连接池实现，用于管理Redis连接的创建、释放和复用。通过使用Jedis连接池，可以提高Redis的访问性能和可靠性。在本文中，我们将详细讨论Jedis连接池的使用，包括...
此外，开发过程中，使用Jedis时，要时刻注意错误处理和资源管理，确保每次操作后正确关闭Jedis实例，防止资源泄漏。对于大型项目，还可以考虑使用更高级的客户端，如Lettuce，它支持异步操作和更复杂的连接管理策略...
`JedisPoolConfig`用来设置连接池的参数，如最大连接数、最大空闲连接数、连接超时时间等。`JedisConnectionFactory`则用于创建与Redis服务器的连接。 ```xml <bean id="jedisPoolConfig" class="redis.clients....
3. **连接池配置**: 使用Apache Commons Pool配置JedisPool，这将管理连接的创建、复用和回收。 ```java JedisPoolConfig poolConfig = new JedisPoolConfig(); // 设置最大连接数、最大空闲连接等参数 Jedis...
4. `whenExhaustedAction`：当池中的连接都被使用时，定义处理策略。默认有三种： - WHEN_EXHAUSTED_FAIL：拒绝新的请求并抛出异常。 - WHEN_EXHAUSTED_BLOCK：阻塞请求，直到有连接可用，或者等待`maxWait`时间后...
4. **连接池**：为了提高性能和资源管理，建议使用Jedis连接池。 ```java JedisPoolConfig config = new JedisPoolConfig(); JedisPool pool = new JedisPool(config, "localhost"); Jedis jedis = pool.get...
创建jedis池配置实例，redis各种crud方法，包括使用主从同步，读写分离。工具类中包括存放hash表键值对，键值对以map的方式储存，删除键值对，永久存放键值对，设置过期时间，需要的直接去gitHab上看...
当需要使用时，可以从池中获取一个已建立连接的Jedis对象，用完后归还回池，而不是直接关闭连接。这样可以避免频繁创建和销毁连接带来的性能开销，提高系统效率。 二、JedisPool配置 配置JedisPool时，主要涉及...
本教程将深入探讨Jedis的连接池使用方法以及数据类型操作，同时也简单介绍Jedis的事务处理。 **一、Jedis连接池** 在实际应用中，频繁地创建和关闭Jedis连接会消耗大量的系统资源，因此使用连接池进行管理是必要的...
对于许多应用程序，最好使用连接池。实例化 Jedis 连接池： JedisPool pool = new JedisPool("localhost", 6379); 以下是如何在try-with-resources块中运行单个SET命令： try (Jedis jedis = pool.getResource()) {...
4. **线程安全**：Jedis设计为线程不安全，推荐每个线程都使用独立的Jedis实例，或者配合连接池使用，以避免线程间的数据冲突。 5. **API友好**：Jedis的API设计简洁明了，易于理解和使用，大大降低了开发者的学习...
当应用程序需要访问数据库时，它可以从池中获取一个已经建立好的连接，使用完毕后再归还到池中，而不是直接关闭。这样避免了频繁地创建和销毁连接，减少了系统资源的消耗，提升了系统响应速度。 在Ecmall框架中，...
然后，他们可以按照Jedis的API文档来配置和使用Jedis连接池，例如设置最大连接数、超时时间等参数，以及执行Redis操作。 以下是一个简单的Jedis连接池配置示例： ```java import redis.clients.jedis.JedisPool; ...
**Jedis连接池** 使用Apache Commons Pool 2的配置和管理机制，可以配置连接池的最大连接数、最小连接数、超时时间等参数。通过连接池，Jedis可以有效地处理高并发场景，避免因创建过多连接导致的资源浪费。同时，...
3. **获取和归还连接**：在需要操作Redis时，从连接池中借用一个Jedis实例，使用`JedisPool.getResource()`。完成操作后，必须通过`Jedis.close()`归还连接，确保资源得到正确释放。 4. **异常处理**：在使用Jedis...