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