1

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

// 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-resources 中获得 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。

Redis / Jedis 配置

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

4

1 回答 1

1
  1. getJedi 不需要“同步”，因为 JedisPool 是线程安全的。
  2. 如果您的逻辑可以容忍从 setTestOnBorrow 添加延迟，您可以禁用其他东西（setTestOnReturn、setTestWhileIdle）。如果您的逻辑可以容忍重试，禁用 setTestOnBorrow 应该会有所帮助。（因为它总是对每次借款进行乒乓检查）
  3. 您的 pushWithResourceAndPipe 有错误：您正在为每个递归调用创建管道实例，这可能比 pushWithResource“慢”。我认为您打算将所有请求添加到一个管道并同步，然后您需要传递管道实例并从调用者调用同步。
于 2017-01-25T00:43:11.573 回答