OkHttp原始碼解析三連線池復用

這個方法是在連線是返回stream物件的。我們看這個方法裡的這段**。

realconnection resultconnection = findhealthyconnection(connecttimeout, readtimeout, writetimeout, connectionretryenabled, doextensivehealthchecks);

//省略其他**

findhealthyconnection方法返回健康的鏈結。我們繼續跟蹤**。最後到了findconnection方法。

//省略其他**
realconnection pooledconnection = internal.instance.get(connectionpool, address, this);
//省略其他**

上面的internal.instance是啥玩意呢？這個是在okhttpclient的靜態**塊中初始化的。我們看下他對應的get方法。

@override public realconnection get(
connectionpool pool, address address, streamallocation streamallocation)

這裡呼叫connectionpool的get方法返回乙個realconnection物件。

realconnection get(address address, streamallocation streamallocation) 
}return null;
}

這樣就返回了乙個已經存在的同樣的realconnect物件。

streamallocation.acquire(connection);是realconnection的allocations增加了乙個弱引用。

回到streamallocation的findconnection方法，，如果從連線池中拿到了realconnection物件，就返回。否則，繼續。生成乙個realconnection物件，並加入連線池。

現在我們看看健康檢查是怎麼回事。

public
boolean
ishealthy(boolean doextensivechecks) 
if (framedconnection != null) 
if (doextensivechecks) 
return
true;
} finally 
} catch (sockettimeoutexception ignored)  catch (ioexception e) 
}return
true;
}

這裡就是檢查socket的各項指標是夠正確，比如說socket關閉沒，輸入輸出通道關閉沒。

如果不健康的話就呼叫nonewstream，這裡就是釋放這個realconnection所佔的資源，並且從上面操作，直到返回乙個可用的健康的realconnection。加入池裡沒有，就建立乙個新的。並將這個新的加入池中，相關**如下。

realconnection newconnection = new realconnection(selectedroute);
acquire(newconnection);
synchronized (connectionpool)

public
connectionpool()

恩，預設是5個鏈結，每個鏈結的存活時長為5分鐘。鏈結池在加入第乙個鏈結物件的時候，會啟動cleanuprunnable，做清理。我們看下這個。

private
final runnable cleanuprunnable = new runnable()  catch (interruptedexception ignored) }}
}}
};

在cleanup函式中，會根據一定的策略移除鏈結。其中還有很多細節，我在這裡就不關注了，感興趣的同學自己去看下他的策略吧。

OkHttp原始碼解析三連線池復用

Mybatis自帶連線池原始碼解析

實驗三連線查詢

Mosh Mysql 學習筆記（三）連線

OkHttp原始碼解析 三 連線池復用

Mybatis自帶連線池原始碼解析

實驗三 連線查詢

Mosh Mysql 學習筆記（三） 連線

相關推薦

OkHttp原始碼解析三連線池復用

實驗三連線查詢

Mosh Mysql 學習筆記（三）連線