mthread基于協程的高性能網絡庫

mthread

簡介

[mthread]是一個基于協程的高性能網絡庫，目前提供支持TCP/UDP等協議的非阻塞式的客戶端庫(服務端正在開發中...)

特性

1. 不用依賴任何第三方庫

2. 基于支持多個平臺的協程調度

3. 支持epoll，kequeue

4. 不用寫異步調度代碼，全部代碼同步，但是框架內部是異步處理

5. 提供非阻塞TCP客戶端

6. 提供非阻塞UDP客戶端

7. 優秀的跨平臺特性和高性能（理論上只要系統內存足夠大，句柄沒有限制，可以無限創建無限個協程）

8. 使用簡單，只需要引入一個libmthread.a或者ibmthread.so

除此之外，基于該庫之上正在開發各個客戶端庫：memcache,redis,wrk等

快速開始

編譯

編譯.a或者.so，到當前目錄下執行：

make

編譯測試代碼，到tests目錄下執行：

make

或者只運行某個單元測試：

make event

An dns client

void?func(void?*args)
{
????std::string?*str?=?(std::string*)args;
????time_t?ttl?=?0;

????std::vector?vc;
????int?ret?=?GetInstance()->dns_lookup(str->c_str(),?vc,?&ttl);
????if?(ret?c_str());
????????return?;
????}
????for?(std::vector::iterator?iter?=?vc.begin();?
????????iter?!=?vc.end();?iter++)?
????{
????????struct?in_addr?addr;
????????memcpy(&addr,?&(*iter),?sizeof(struct?in_addr));
????????LOG_DEBUG("%s,?%d,?%s",?str->c_str(),?*iter,?inet_ntoa(addr));
????}
????LOG_DEBUG("ttl?:?%ld",?ttl);
}

int?main(int?argc,?char*?argv[])
{
????int?ret?=?mt_init_frame();
????LOG_DEBUG("init?ret?:?%d",?ret);
????mt_set_hook_flag();
????mt_set_timeout(200);

????Frame?*frame?=?GetInstance();

????//?測試?:?使用協程請求耗時
????LOG_DEBUG("---?start?time?:?%ld",?Utils::system_ms());
????for?(int?i?=?2000;?i?
					

						說明其中dns內部修改調用接口
					
...

????addr.sin_family?=?AF_INET;
????if?(m_dns_svr_?==?NULL)
????{
????????addr.sin_addr.s_addr?=?inet_addr(PUBLIC_DNS_DEFAULT_SERVER);??///服務器ip
????}
????else
????{
????????addr.sin_addr.s_addr?=?inet_addr(m_dns_svr_);??///服務器ip
????}
????addr.sin_port?=?htons((uint16_t)PUBLIC_DNS_DEFAULT_PORT);

????int?query_len?=?make_dns_query_format();
????if?(query_len?<=?0)?
????{
????????return?-1;
????}

????int?recv_len?=?sizeof(m_recv_buf_);
????ret?=?udp_sendrecv(&addr,?m_send_buf_,?query_len,?m_recv_buf_,?recv_len,?m_timeout_);
????LOG_DEBUG("ret?:?%d,?recv_buf?:?%s,?recv_len?:?%d",?ret,?m_recv_buf_,?recv_len);

...