Boost asio 連接池問題

Fixend

回復(fù) 9# joepayne

你看清楚這個shared_ptr的生命期，已經(jīng)釋放了。

Fixend

joepayne 發(fā)表于 2017-11-15 20:47
回復(fù) 8# Fixend

你服務(wù)器是異步多線程的（指的是你用多線程調(diào)用io_service.run()了），實(shí)質(zhì)上也是需要緩沖的，只不過你的代碼暫時沒有連續(xù)發(fā)送或者多線程進(jìn)行發(fā)送，所用顯不出問題。

joepayne

回復(fù) 11# Fixend



我好像看明白了，因?yàn)槭钱惒降�，把socket傳遞給service內(nèi)部的shared_ptr后，acceptor已經(jīng)進(jìn)入新一輪InitAccept 函數(shù)了，所以在service發(fā)送完數(shù)據(jù)后，這個socket的count已經(jīng)變?yōu)?了，這時delete 就自然把這個socket給關(guān)閉關(guān)掉了。

感謝大神！我再fix一下，看行不

joepayne

回復(fù) 12# Fixend

那這里應(yīng)該如何整個緩沖區(qū)，保證多線程發(fā)送是安全的呢？

yulihua49

線程池，同步、異步IO，連接池這些我有體會，boost不熟�？纯茨銈冊趺锤恪�

linux_c_py_php

說明你還是封裝的不夠抽象，看看我的https://github.com/owenliang/boost_asio

joepayne

回復(fù) 16# linux_c_py_php

好詳細(xì)啊，還有日志部分，我得好好溫故學(xué)習(xí)一下。你的頭像看著好熟悉的感覺，好像當(dāng)初寫UC的時候也是看你的blog入的門。In touch!

sxcong

同步和異步可能沒和你說明白：
客戶要求同步，也就是說等你發(fā)成功再返回。
但網(wǎng)絡(luò)層一定是異步的,否則效率太低。也就是說在應(yīng)用層做成同步，簡單封裝一下。
偽代碼：
SendData
{
tcpsend();//異步發(fā)送，其實(shí)是放到發(fā)送隊列中，由發(fā)送線程去發(fā)。
wait...  // 等待發(fā)送成功或失敗的通知事件，或在回調(diào)函數(shù)里等
return ...;
}
boost里用bind來綁定回調(diào)，也是異步的。同步你在應(yīng)用層處理就行了。

joepayne

回復(fù) 18# sxcong


你的意思是，應(yīng)用層線程各自調(diào)SendData 將數(shù)據(jù)異步地寫往發(fā)送隊列（緩存），再由發(fā)送線程發(fā)送數(shù)據(jù)，發(fā)送完通知應(yīng)用層線程，然后應(yīng)用層線程返回。
那我可不可以這樣臆想，應(yīng)用層線程寫入數(shù)據(jù)的緩存（queue）是一個exclusive（加mutex）或者aotmic(lock-free)的東西，保證應(yīng)用層線程能夠安全的寫數(shù)據(jù)；發(fā)送線程與應(yīng)用線程應(yīng)該是并行的關(guān)系，而且發(fā)送線程才是socket的owner，由它從緩存（queue）進(jìn)行讀取操作，然后將數(shù)據(jù)寫入socket，并由它來管理并控制socket的資源。

那這里我有一個問題，你這里說的發(fā)送線程，難道是asio內(nèi)部維護(hù)的線程？那這樣的線程有幾個呢，是一個緩存（queue）對應(yīng)一個發(fā)送線程嗎？還有發(fā)送線程跟應(yīng)用線程之間是如何進(jìn)行通信的呢？

想搞清楚這些，聰哥能否給予一些指點(diǎn)，或者有對應(yīng)的詳盡資料對照看看？

sxcong

我設(shè)計的發(fā)送線程大致是這樣的：
while()
{
getData();//從隊列中取一個數(shù)據(jù)，隊列就是你說的加鎖的緩沖
send();    //異步發(fā)送
}
onSend() //boost發(fā)送的回調(diào)函數(shù)
{
觸發(fā)成功或失敗事件
}

asio官方帶的例子有異步發(fā)送，創(chuàng)建多個對象就是多路同時發(fā)了。