std::vectorChannel2* m_allChannels;容器,以及如何根据channelid的意义
生活随笔
收集整理的這篇文章主要介紹了
std::vectorChannel2* m_allChannels;容器,以及如何根据channelid的意义
小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
std::vector<Channel2*> m_allChannels;容器,以及如何根據(jù)channelid的意義
這個(gè)容器保存了所有客戶端連接的channel
Channel2* LibEvtServer::CreateChannel(bufferevent* be)
{auto c2 = new Channel2;c2->ser = this;auto c = new Channel(be);//這個(gè)be比較重要,be是基于socket的bufferevent,包含socket信息以及發(fā)送和接收緩沖區(qū)c2->channel = c;c->m_event = m_event;//Libevent事件回調(diào)指針int id = -1;{//存在多個(gè)libevent thread同時(shí)訪問m_ids、m_allChannels,得加鎖
#ifdef MUL_LIBEVENT_THREADstd::lock_guard<std::mutex> lock(m_lts_mtx);
#endifid = m_ids->getId(); m_allChannels[id] = c2;//記錄所有channel信息,一個(gè)客戶端對應(yīng)一個(gè)channel,id通過其中保存的bufferevent就能確定是哪個(gè)客戶端
}c->m_id = id;if(id < 0)MessageBox(NULL, L"LibEvtServer::CreateChannel異常", L"重大錯(cuò)誤", MB_OK);m_event->on_connect(id);return c2;
}
//channelid在發(fā)送數(shù)據(jù)時(shí),通過channelid查找容器m_allChannels,然后就能確定是哪個(gè)bufferevent
if(0 != bufferevent_write(c->m_bev, m_send_buffer, len+4))//第一個(gè)參數(shù)就是bufferevent,其中能確定socket,通過socket就能確定是哪個(gè)客戶端
有一次同事吃飯的認(rèn)為是一個(gè)客戶端一個(gè)線程,其實(shí)不是這樣的,只能這樣說一個(gè)客戶端對應(yīng)一個(gè)bufferevent,在這些bufferevent又是通過base進(jìn)行輪轉(zhuǎn)的
在內(nèi)部是select模式進(jìn)行循環(huán)檢查的,哪個(gè)socket可讀,可寫,有錯(cuò)誤,都是知道的然后調(diào)用不同的函數(shù),
auto bev = bufferevent_socket_new(plt->thread_base, item.fd, BEV_OPT_THREADSAFE);Channel2* c2 = CreateChannel(bev);//設(shè)置接收、狀態(tài)改變 回調(diào)函數(shù)
bufferevent_setcb(bev, conn_readcb, NULL, conn_eventcb, c2);//此時(shí)已經(jīng)將c2傳遞進(jìn)去了,然后就能知道id,上層也是通過id進(jìn)行辨別哪個(gè)客戶端
在發(fā)送數(shù)據(jù)時(shí)也通過channelid,這邊也知道哪個(gè)客戶端,其實(shí)開線程不現(xiàn)實(shí),在服務(wù)器上開6000個(gè)線程有點(diǎn)扯啊
?
轉(zhuǎn)載于:https://www.cnblogs.com/zzyoucan/p/4101301.html
總結(jié)
以上是生活随笔為你收集整理的std::vectorChannel2* m_allChannels;容器,以及如何根据channelid的意义的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: ArcGis融合小多边形到相邻多边形
- 下一篇: [再寄小读者之数学篇](2014-11-