libevent简介和使用【转】
轉自:http://www.open-open.com/lib/view/open1386510630330.html
libevent是一個基于事件觸發的網絡庫,memcached底層也是使用libevent庫。
總體來說,libevent有下面一些特點和優勢:
* 事件驅動,高性能;
* 輕量級,專注于網絡;?
* 跨平臺,支持 Windows、Linux、Mac Os等;?
* 支持多種 I/O多路復用技術, epoll、poll、dev/poll、select 和kqueue 等;?
* 支持 I/O,定時器和信號等事件;
?
libevent有下面幾大部分組成:
*?事件管理包括各種IO(socket)、定時器、信號等事件,也是libevent應用最廣的模塊;
*?緩存管理是指evbuffer功能;
*?DNS是libevent提供的一個異步DNS查詢功能;
*?HTTP是libevent的一個輕量級http實現,包括服務器和客戶端
?
一些資料:
* libevent官網:http://libevent.org/?
* libevent API:http://www.monkey.org/~provos/libevent/doxygen-2.0.1/index.html
* CSDN上剖析得很贊的文章:http://blog.csdn.net/sparkliang/article/details/4957667
?
// =============================================================================================
?
下面寫了2個簡單的使用例子,一個是定時器,一個是TCP服務器,都只涉及到libevent的事件管理模塊。
?
一、簡單定時器:實現程序每秒輸出一個“Game Over!”
event_init() =>?evtimer_set() =>?event_add() =>event_dispatch()
#include <stdio.h> #include <iostream> // libevent頭文件 #include <event.h> using namespace std; // 定時事件回調函數 void onTime(int sock, short event, void *arg) { cout << "Game Over!" << endl; struct timeval tv; tv.tv_sec = 1; tv.tv_usec = 0; // 重新添加定時事件(定時事件觸發后默認自動刪除) event_add((struct event*)arg, &tv); } int main() { // 初始化 event_init(); struct event evTime; // 設置定時事件 evtimer_set(&evTime, onTime, &evTime); struct timeval tv; tv.tv_sec = 1; tv.tv_usec = 0; // 添加定時事件 event_add(&evTime, &tv); // 事件循環 event_dispatch(); return 0; }編譯并執行,編譯加 -levent:
gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # mv time.cpp timer.cpp gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # g++ -o timer timer.cpp -levent gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # ./timer Game Over! Game Over! Game Over! Game Over!二、TCP服務器:實現監聽本機8888端口并輸出客戶端發送過來的信息
?
event_base_new()=>event_set()=>event_base_set()=>event_add()=>event_base_dispatch()
#include <stdio.h> #include <string.h> #include <iostream> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <netdb.h> #include <event.h> using namespace std; // 事件base struct event_base* base; // 讀事件回調函數 void onRead(int iCliFd, short iEvent, void *arg) { int iLen; char buf[1500]; iLen = recv(iCliFd, buf, 1500, 0); if (iLen <= 0) { cout << "Client Close" << endl; // 連接結束(=0)或連接錯誤(<0),將事件刪除并釋放內存空間 struct event *pEvRead = (struct event*)arg; event_del(pEvRead); delete pEvRead; close(iCliFd); return; } buf[iLen] = 0; cout << "Client Info:" << buf << endl; } // 連接請求事件回調函數 void onAccept(int iSvrFd, short iEvent, void *arg) { int iCliFd; struct sockaddr_in sCliAddr; socklen_t iSinSize = sizeof(sCliAddr); iCliFd = accept(iSvrFd, (struct sockaddr*)&sCliAddr, &iSinSize); // 連接注冊為新事件 (EV_PERSIST為事件觸發后不默認刪除) struct event *pEvRead = new event; event_set(pEvRead, iCliFd, EV_READ|EV_PERSIST, onRead, pEvRead); event_base_set(base, pEvRead); event_add(pEvRead, NULL); } int main() { int iSvrFd; struct sockaddr_in sSvrAddr; memset(&sSvrAddr, 0, sizeof(sSvrAddr)); sSvrAddr.sin_family = AF_INET; sSvrAddr.sin_addr.s_addr = inet_addr("127.0.0.1"); sSvrAddr.sin_port = htons(8888); // 創建tcpSocket(iSvrFd),監聽本機8888端口 iSvrFd = socket(AF_INET, SOCK_STREAM, 0); bind(iSvrFd, (struct sockaddr*)&sSvrAddr, sizeof(sSvrAddr)); listen(iSvrFd, 10); // 初始化base base = event_base_new(); struct event evListen; // 設置事件 event_set(&evListen, iSvrFd, EV_READ|EV_PERSIST, onAccept, NULL); // 設置為base事件 event_base_set(base, &evListen); // 添加事件 event_add(&evListen, NULL); // 事件循環 event_base_dispatch(base); return 0; }來自:http://blog.csdn.net/yyyiran/article/details/12219737
轉載于:https://www.cnblogs.com/sky-heaven/p/8563074.html
總結
以上是生活随笔為你收集整理的libevent简介和使用【转】的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: iOS提交应用至App Store流程及
- 下一篇: http状态码?