C/C++：深入淺出-服務(wù)器高并發(fā)庫(kù)libevent(一)

1、安裝

libevent是一個(gè)開(kāi)源的高并發(fā)服務(wù)器開(kāi)發(fā)包，官方地址http://libevent.org/

libevent目前有兩個(gè)版本一個(gè)是1.4系列版本，一個(gè)是2.0系列版本。

我們可以在官方網(wǎng)站上看到類似 有個(gè)stable表示穩(wěn)定版本。

· libevent-1.4.15-stable.tar.gz

對(duì)于初學(xué)者學(xué)習(xí)，建議從1.4版本學(xué)起。

在安裝libevent之前先判斷本電腦是否已經(jīng)安裝了

通過(guò)指令

ls -al /usr/lib|grep libevent

如果沒(méi)有任何信息則表示沒(méi)有安裝，有的話如果發(fā)現(xiàn)libevent是1.3以下版本，則可以同過(guò)執(zhí)行 rpm -e libevent —nodeps 進(jìn)行卸載。如果是其他操作系統(tǒng)使用其他對(duì)應(yīng)卸載指令即可。

對(duì)于下好的tar包，通過(guò)

tar -zxvf libevent-release-1.4.15-stable.tar.gz

指令解壓。

然后執(zhí)行./configure命令，但是有的包可能沒(méi)有configure文件，卻存在一個(gè)

autogen.sh 腳本，運(yùn)行這個(gè)腳本。

(如果運(yùn)行不起來(lái)請(qǐng)安裝autoconf包)

然后

./configure –prefix=/usr

make

sudo make install

安裝完之后執(zhí)行

ls -al /usr/lib/|grep libevent

如果發(fā)現(xiàn)有l(wèi)ibevent文件庫(kù)存在就代表安裝完畢。

2、簡(jiǎn)單的libevent服務(wù)器

我們通過(guò)連接libevent庫(kù)來(lái)進(jìn)行管理libevent庫(kù)，所以在使用gcc或者g++編譯的時(shí)候最后需要加上-levent

下面是一個(gè)簡(jiǎn)單的libevent服務(wù)器。

#include

#include

#include

#include

#include

#include

#include

#include

#include

using namespace std;

#define SERVER_ADDR "127.0.0.1"

#define SERVER_PORT 8888

// 事件base

struct event_base* base;

// 讀事件回調(diào)函數(shù)

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;

// 連接結(jié)束(=0)或連接錯(cuò)誤(<0)，將事件刪除并釋放內(nèi)存空間

struct event *pEvRead = (struct event*)arg;

event_del(pEvRead);

delete pEvRead;

close(iCliFd);

return;

}

buf[iLen] = 0;

cout << "Client Info:" << buf << endl;

struct bufferevent* buf_ev;

buf_ev = bufferevent_new(iCliFd, NULL, NULL, NULL, NULL);

buf_ev->wm_read.high = 4096;

char MESSAGE[]="welcome to server..";

bufferevent_write(buf_ev, MESSAGE, strlen(MESSAGE));

}

// 連接請(qǐng)求事件回調(diào)函數(shù)

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

// 連接注冊(cè)為新事件 (EV_PERSIST為事件觸發(fā)后不默認(rèn)刪除)

struct event *pEvRead = new event;

event_set(pEvRead, iCliFd, EV_READ|EV_PERSIST, onRead, pEvRead);

event_base_set(base, pEvRead);

event_add(pEvRead, NULL);

struct bufferevent* buf_ev;

buf_ev = bufferevent_new(iCliFd, NULL, NULL, NULL, NULL);

buf_ev->wm_read.high = 4096;

char MESSAGE[]="welcome to server..";

bufferevent_write(buf_ev, MESSAGE, strlen(MESSAGE));

cout<<"a client connect:"<

}

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

sSvrAddr.sin_port = htons(SERVER_PORT);

// 創(chuàng)建tcpSocket(iSvrFd)，監(jiān)聽(tīng)本機(jī)8888端口

iSvrFd = socket(AF_INET, SOCK_STREAM, 0);

bind(iSvrFd, (struct sockaddr*)&sSvrAddr, sizeof(sSvrAddr));

listen(iSvrFd, 10);

// 初始化base

base = (struct event_base*)event_init();

struct event evListen;

// 設(shè)置事件

event_set(&evListen, iSvrFd, EV_READ|EV_PERSIST, onAccept, NULL);

// 設(shè)置為base事件

event_base_set(base, &evListen);

// 添加事件

event_add(&evListen, NULL);

// 事件循環(huán)

event_base_dispatch(base);

return 0;

}

通過(guò)編譯指令

g++ server.cpp -o server -Wall -g -I ./ -levent

得到可執(zhí)行程序

./server

啟動(dòng)。

如果能夠編譯成功并且能夠正常啟動(dòng)，說(shuō)明你操作系統(tǒng)的libevent安裝時(shí)沒(méi)問(wèn)題的。

然后可以通過(guò)命令

nc 127.0.0.1 8888

來(lái)進(jìn)行測(cè)試。

或者編寫如下客戶端代碼：

/******* 客戶端程序 client.c ************/

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#include

#define SERVER_ADDR "127.0.0.1"

#define SERVER_PORT 8888

int main(int argc, char *argv[])

{

int sockfd;

char buffer[1024];

struct sockaddr_in server_addr;

struct hostent *host;

int portnumber,nbytes;

if((host=gethostbyname(SERVER_ADDR))==NULL)

{

fprintf(stderr,"Gethostname error\n");

exit(1);

}

if((portnumber=SERVER_PORT)<0)

{

fprintf(stderr,"Usage:%s hostname portnumber\a\n",argv[0]);

exit(1);

}

/* 客戶程序開(kāi)始建立 sockfd描述符 */

if((sockfd=socket(AF_INET,SOCK_STREAM,0))==-1)

{

fprintf(stderr,"Socket Error:%s\a\n",strerror(errno));

exit(1);

}

/* 客戶程序填充服務(wù)端的資料 */

bzero(&server_addr,sizeof(server_addr));

server_addr.sin_family=AF_INET;

server_addr.sin_port=htons(portnumber);

server_addr.sin_addr=*((struct in_addr *)host->h_addr);

/* 客戶程序發(fā)起連接請(qǐng)求 */

if(connect(sockfd,(struct sockaddr *)(&server_addr),sizeof(struct sockaddr))==-1)

{

fprintf(stderr,"Connect Error:%s\a\n",strerror(errno));

exit(1);

}

while(true)

{

char MESSAGE[]="hello server..\n";

//bufferevent_write(buf_ev,MESSAGE,strlen(MESSAGE));

//

if(-1 == (::send(sockfd,MESSAGE,strlen(MESSAGE),0)))

{

printf("the net has a error occured..");

break;

}

if((nbytes = read(sockfd,buffer,1024))==-1)

{

fprintf(stderr,"read error:%s\n",strerror(errno));

exit(1);

}

buffer[nbytes]='\0';

printf("I have received:%s\n",buffer);

memset(buffer,0,1024);

sleep(2);

}

/* 結(jié)束通訊 */

close(sockfd);

exit(0);

}

通過(guò)編譯指令

g++ client.cpp -o client -Wall -g -I ./ -levent

生成客戶端程序client 進(jìn)行測(cè)試。

現(xiàn)在已經(jīng)可以跑起來(lái)一個(gè)簡(jiǎn)單的libevent程序了。那么這些神奇的代碼到底是什么含義呢?

期待下一章我們慢慢來(lái)分析~~~