jedis正确管理连接

Question

我写了一个类，其中有连接池和流水线，使用这个类的方法类似于（我删除了一个循环，但setKey将发生在循环中）：

private Redis redis = new Redis();
redis.setKey(path, keyValueOutput, 3000);
redis.setKey(path, keyValueOutput, 3000);
redis.setKey(path, keyValueOutput, 3000);
if (redis.getPipelineCount() > 200) {
   redis.syncKeys();
   System.out.println("200 items added");
}

因此，一旦管道上的项目数超过200，i同步项目并清除管道，然后重新启动。问题是如何使用此设置将连接正确地返回到池。

public class Redis {
    private JedisPoolConfig poolConfig = new JedisPoolConfig();
    private JedisPool jedisPool = new JedisPool(poolConfig,"localhost", 6379);
    private Jedis jedis = jedisPool.getResource();
    
    private Pipeline pipeline = jedis.pipelined();
    private int pipelineCount = 0;

    public void setKey(String path, Map<String, String> keyValueOutput, int expireTime) {
        this.pipeline.hset(path, keyValueOutput);
        this.pipeline.expire(path, expireTime);
        this.pipelineCount = this.pipelineCount + 1;
    }

    public void syncKeys() {
        this.pipeline.sync();
        this.pipelineCount = 0;
    }

    public int getPipelineCount() {
        return this.pipelineCount;
    }

    public void close() {
        this.jedis.close();
    }

}

据我所知，我必须将jedispool.getResource（）包装到try块中，但我无法考虑如何将它与管道和计数器结合在一起。

        Jedis jedis = null;
        try {
            jedis = jedisPool.getResource();
            Pipeline p = jedis.pipelined();
            p.sync()
        } finally {
            if (jedis != null) {
                jedis.close();
            }
        }

Answer 1

synckeys()方法是执行此操作的正确位置。为了安全，你可能需要某种锁。我使用了synchronized作为示例。

    public synchronized void syncKeys() {
        this.pipeline.sync();
        this.jedis.close();
        this.jedis = null;
        this.pipelineCount = 0;
    }

除此之外，您的应用程序是多线程的吗？如果不是，那么您是在无谓地使用JedisPool。简单的绝地武士应该就够了。否则，你就用错了泳池。例如，您的Redis对象被限制在某个时间最多使用一个Jedis对象。这将是多线程场景中的一个瓶颈。