http连接池是什么?http连接池就是一个池子,里面装满了连接,哈哈哈。连接就是一条通路,例如打电话,通了之后,就是一个连接。把这些连接放在一起就是连接池啦。
以通电话为例子,例如有下面几通接通的电话:
1.跟主席连通的电话
2.跟总理连通的电话
3.跟总司令连接的电话
4.跟指导员连接的电话
这一堆连通的电话机放在的一个神秘的小黑屋,这个小黑屋就是连接池啦。
而每个进小黑屋跟大领导通电话的人可以认为就是httpclient,而大领导就是各个服务器啦。大领导可忙了,如果每个进小黑屋的人跟大领导通完电话就挂断的话,那得多浪费大领导的时间,所以小黑屋里面的电话不能随便挂断,要过一段时间一直没有人跟大领导通话了才能挂断。这个就是连接池(小黑屋)的原理。
所以有一下两个特征:
1.连接池里面保存着可以马上通信的连接,免除了重新建立连接的麻烦
2.连接如果长期不用,就会挂断。
下面以一个连接放进连接池为例子讲解源码流程。
android 6.0系统源码路径:/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ConnectionPool.java
连接池所有的连接保存在一个链表connections里面
private final LinkedList<Connection> connections = new LinkedList<>();
往连接池增加一个连接时,会把连接放在链表connections的第一位,表示最新鲜的一个连接;连接池建立的时候,马上会准备好一个清理连接池的线程,用于清理过期的连接。
private void addConnection(Connection connection) {
boolean empty = connections.isEmpty();
connections.addFirst(connection); //放在链表connections的第一位
if (empty) {
executor.execute(connectionsCleanupRunnable); //启动一个清理连接池的线程
} else {
notifyAll();
}
}
重点看下okhttp是如何清理连接池的。
1.第一次往连接池增加连接时,都会伴随着清理线程connectionsCleanupRunnable 的启动
private final Runnable connectionsCleanupRunnable = new Runnable() {
@Override public void run() {
runCleanupUntilPoolIsEmpty();
}
};
2.连接池的所有连接都清除后,清理线程就结束,跳出runCleanupUntilPoolIsEmpty函数。
private void runCleanupUntilPoolIsEmpty() {
while (true) {
if (!performCleanup()) return; // Halt cleanup.
}
}
3.看看清理函数performCleanup
boolean performCleanup() {
List<Connection> evictableConnections; //用于保存要被清除的连接集合
synchronized (this) {
if (connections.isEmpty()) return false; // Halt cleanup. //连接池为空了,返回false,清理线程结束
evictableConnections = new ArrayList<>();
int idleConnectionCount = 0;
long now = System.nanoTime();
long nanosUntilNextEviction = keepAliveDurationNs; //默认空闲的连接保存5分钟
// Collect connections eligible for immediate eviction.
for (ListIterator<Connection> i = connections.listIterator(connections.size());
i.hasPrevious(); ) {
Connection connection = i.previous();
long nanosUntilEviction = connection.getIdleStartTimeNs() + keepAliveDurationNs - now;
// connection.getIdleStartTimeNs()是连接开始空闲的时间点
//故connection.getIdleStartTimeNs() + keepAliveDurationNs代表空闲连接要被回收的时间点
if (nanosUntilEviction <= 0 || !connection.isAlive()) { //这个连接要回收了
i.remove();
evictableConnections.add(connection);//将connection加入到清理集合
} else if (connection.isIdle()) {
idleConnectionCount++;
nanosUntilNextEviction = Math.min(nanosUntilNextEviction, nanosUntilEviction);
}
}
// If the pool has too many idle connections, gather more! Oldest to newest.
//如果idle的连接数超过了系统限制的最大数目,则要开始清理连接,从最旧的连接开始回收
for (ListIterator<Connection> i = connections.listIterator(connections.size());
i.hasPrevious() && idleConnectionCount > maxIdleConnections; ) {
Connection connection = i.previous();
if (connection.isIdle()) {
evictableConnections.add(connection);
i.remove();
--idleConnectionCount;
}
}
// If there's nothing to evict, wait. (This will be interrupted if connections are added.)
if (evictableConnections.isEmpty()) {
//没有连接要清理,清理进程就wait等待,当connections集合变化的时候会被唤醒,继续清理
try {
long millisUntilNextEviction = nanosUntilNextEviction / (1000 * 1000);
long remainderNanos = nanosUntilNextEviction - millisUntilNextEviction * (1000 * 1000);
this.wait(millisUntilNextEviction, (int) remainderNanos);
return true; // Cleanup continues.
} catch (InterruptedException ignored) {
}
}
}
// Actually do the eviction. Note that we avoid synchronized() when closing sockets.
for (int i = 0, size = evictableConnections.size(); i < size; i++) { //关闭要清理的连接的socket
Connection expiredConnection = evictableConnections.get(i);
Util.closeQuietly(expiredConnection.getSocket());
}
return true; // Cleanup continues.
}
大概就是三个步骤:
1.查看有没有过期的连接,有则干掉他
2.查看没事干的空闲的连接是不是过多了,按时间顺序干掉一部分。先把老的干掉
3.如果没有东西要清理,清理线程则休息一下。当有连接进入的时候,就起来继续干活,哈哈哈。