提问者:小点点

在方法之间传递jedis实例是一种不好的做法吗?


我指的是这个SO问题,我在这个基准测试中做了一些补充。主要问题是我的api随着服务器负载的增加而变慢。我正在使用jedis池配置。

// get a new instance
    public synchronized Jedis getJedi() {
    try {
        return jedisPool.getResource();
    } catch (Exception e) {
        log.fatal("REDIS CONN ERR:", e);
        return null;
    }
    }

// intialize at start
    public void initialize() {
    if (jedisPool == null) {
        IniUtils cp = PropertyReader.getConnPoolIni();

        String host = cp.get(REDIS, REDIS_HOST);
        int port = Integer.parseInt(cp.get(REDIS, REDIS_PORT));
        String password = cp.get(REDIS, REDIS_PASSWORD);
        int timeout = Integer.parseInt(cp.get(REDIS, REDIS_TIMEOUT));

        JedisPoolConfig poolConfig = new JedisPoolConfig();
        poolConfig.setMaxTotal(Integer.parseInt(cp.get(REDIS, REDIS_MAX_TOTAL_CONNECTIONS)));
        poolConfig.setMaxIdle(Integer.parseInt(cp.get(REDIS, REDIS_MAX_IDLE)));
        poolConfig.setMinIdle(Integer.parseInt(cp.get(REDIS, REDIS_MIN_IDLE)));
        poolConfig.setMaxWaitMillis(Long.parseLong(cp.get(REDIS, REDIS_MAX_WAIT_TIME_MILLIS)));

        poolConfig.setTestOnBorrow(true);
        poolConfig.setTestOnReturn(true);
        poolConfig.setTestWhileIdle(true);

        if (password != null && !password.trim().isEmpty()) {
        jedisPool = new JedisPool(poolConfig, host, port, timeout, password);
        } else {
        jedisPool = new JedisPool(poolConfig, host, port, timeout);
        }

        test();

      }
    }

    @Override
    public void destroy() {
      if (jedisPool.isClosed() == false)
          jedisPool.destroy();
    }

    private void test() {
      try (Jedis test = getJedi()) {
        log.info("Testing Redis:" + test.ping());
      }
    }

在使用时,我在try-with资源中获取Jedis实例并对其进行处理。我使用的流水线非常少,并且对Redis有各种调用,因此每次方法调用时,都会创建一个新的jedis实例。

根据分享SO问题,我的实现将导致非常缓慢的结果。因此,我可以将Jedis实例传递给方法并根据业务逻辑使用管道吗?类似于这样-

  public void push5(int n) {
    try (Jedis jedi = redisFactory.getJedi()) {
        pushWithResource(n, jedi, 0);
    }
  }

  public void pushWithResourceAndPipe(int n, Jedis jedi, int k) {
    if (k >= n)
        return;
    Pipeline pipeline = jedi.pipelined();
    map.put("id", "" + i);
    map.put("name", "lyj" + i);
    pipeline.hmset("m" + i, map);
    ++i;
    pushWithResourceAndPipe(n, jedi, ++k);
    pipeline.sync();
  }

    public void pushWithResource(int n, Jedis jedi, int k) {
    if (k >= n)
        return;
    map.put("id", "" + i);
    map.put("name", "lyj" + i);
    jedi.hmset("m" + i, map);
    ++i;
    pushWithResource(n, jedi, ++k);
  }

有什么方法可以改进api调用吗?您能否推荐一些在服务器端使用jedis的项目,这样我就可以更好地了解如何有效地使用jedis。

Jedis版本:2.8.1 Redis版本:2.8.4Java版本:1.8


共1个答案

匿名用户

  1. getJedi不需要“同步”,因为JedisPool是线程安全的。
  2. 如果您的逻辑可以容忍从setTestOnBrow增加延迟,您可以禁用其他东西(setTestOnBack、setTestWhileIdle)。如果您的逻辑可以容忍重试,禁用setTestOnBrow应该会有所帮助。(因为它总是对每次借用进行乒乓检查)
  3. 您的pushWellResourceAndPipe有bug:您正在为每个递归调用创建管道实例,这可能比pushWellResource“慢”。我认为您打算将所有请求添加到一个管道并同步,然后您需要从调用者传递管道实例和调用同步。