Jedis连接池1. 什么是连接池2. Jedis的连接池3. 源码解析4. 总结

public T borrowObject(long borrowMaxWaitMillis) throws Exception {
        assertOpen();

        ...other code...

        PooledObject<T> p = null;

        // 没有空闲连接的时候是否阻塞的等待连接
        boolean blockWhenExhausted = getBlockWhenExhausted();

        boolean create;
        long waitTime = System.currentTimeMillis();

        while (p == null) {
            create = false;
            // 没有空闲连接时等待
            if (blockWhenExhausted) {
                // 先从idleObjects队列中获取
                p = idleObjects.pollFirst();
                if (p == null) {
                  // 如果队列中没有空闲的连接, 则创建一个连接
                    p = create();
                    if (p != null) {
                        create = true;
                    }
                }
                // 如果连接创建失败, 则继续从idleObjects中阻塞的获取连接
                if (p == null) {
                    if (borrowMaxWaitMillis < 0) {
                     // 无限制的等待, 不会超时
                        p = idleObjects.takeFirst();
                    } else {
                     // 有超时时间的等待
                        p = idleObjects.pollFirst(borrowMaxWaitMillis,
                                TimeUnit.MILLISECONDS);
                    }
                }
                if (p == null) {
                    throw new NoSuchElementException(
                            "Timeout waiting for idle object");
                }
                if (!p.allocate()) {
                    p = null;
                }
            } else { // 没有空闲连接时直接抛出异常
                p = idleObjects.pollFirst();
                if (p == null) {
                    p = create();
                    if (p != null) {
                        create = true;
                    }
                }
                if (p == null) {
                    throw new NoSuchElementException("Pool exhausted");
                }
                if (!p.allocate()) {
                    p = null;
                }
            }
    ...other code...
        }

        updateStatsBorrow(p, System.currentTimeMillis() - waitTime);
   
   // 返回连接
        return p.getObject();
    }

private PooledObject<T> create() throws Exception {

   // 判断当前已经创建的连接是否已经超过设置的最大连接数(默认是8)
        int localMaxTotal = getMaxTotal();
        long newCreateCount = createCount.incrementAndGet();
        if (localMaxTotal > -1 && newCreateCount > localMaxTotal ||
                newCreateCount > Integer.MAX_VALUE) {
            createCount.decrementAndGet();
            return null;
        }

        final PooledObject<T> p;
        try {
          // 创建一个到redis server的连接
            p = factory.makeObject();
        } catch (Exception e) {
            createCount.decrementAndGet();
            throw e;
        }

       ...other code...

        createdCount.incrementAndGet();
        // 将新创建的连接放入到allObjects中
        allObjects.put(new IdentityWrapper<T>(p.getObject()), p);
        // 返回新创建的连接
        return p;
 }

  @Override
  public Jedis getResource() {
    // 获取连接
    Jedis jedis = super.getResource();
   // 将连接池放入到连接中, 这里这么做的目的其实就是为关闭连接的时候作准备的
    jedis.setDataSource(this);
    return jedis;
  }