mthread基于協(xié)程的高性能網(wǎng)絡(luò)庫(kù)

mthread

簡(jiǎn)介

[mthread]是一個(gè)基于協(xié)程的高性能網(wǎng)絡(luò)庫(kù)，目前提供支持TCP/UDP等協(xié)議的非阻塞式的客戶(hù)端庫(kù)(服務(wù)端正在開(kāi)發(fā)中...)

特性

1. 不用依賴(lài)任何第三方庫(kù)

2. 基于支持多個(gè)平臺(tái)的協(xié)程調(diào)度

3. 支持epoll，kequeue

4. 不用寫(xiě)異步調(diào)度代碼，全部代碼同步，但是框架內(nèi)部是異步處理

5. 提供非阻塞TCP客戶(hù)端

6. 提供非阻塞UDP客戶(hù)端

7. 優(yōu)秀的跨平臺(tái)特性和高性能（理論上只要系統(tǒng)內(nèi)存足夠大，句柄沒(méi)有限制，可以無(wú)限創(chuàng)建無(wú)限個(gè)協(xié)程）

8. 使用簡(jiǎn)單，只需要引入一個(gè)libmthread.a或者ibmthread.so

除此之外，基于該庫(kù)之上正在開(kāi)發(fā)各個(gè)客戶(hù)端庫(kù)：memcache,redis,wrk等

快速開(kāi)始

編譯

編譯.a或者.so，到當(dāng)前目錄下執(zhí)行：

make

編譯測(cè)試代碼，到tests目錄下執(zhí)行：

make

或者只運(yùn)行某個(gè)單元測(cè)試：

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();

????//?測(cè)試?:?使用協(xié)程請(qǐng)求耗時(shí)
????LOG_DEBUG("---?start?time?:?%ld",?Utils::system_ms());
????for?(int?i?=?2000;?i?
					

						說(shuō)明其中dns內(nèi)部修改調(diào)用接口
					
...

????addr.sin_family?=?AF_INET;
????if?(m_dns_svr_?==?NULL)
????{
????????addr.sin_addr.s_addr?=?inet_addr(PUBLIC_DNS_DEFAULT_SERVER);??///服務(wù)器ip
????}
????else
????{
????????addr.sin_addr.s_addr?=?inet_addr(m_dns_svr_);??///服務(wù)器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);

...