正文
服务器搭建3 安装libevent2.0.20
小程序:扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序
【扫一扫了解最新限行尾号】
复制小程序
1.检测是否安装
安装了的话应该是这样的:如果不是,那就装一下。
root@iZ23nyl8frqZ:/home/upload# ls -a /usr/lib |grep libevent
libevent-2.0.so.5
libevent-2.0.so.5.1.9
libevent.a
libevent_core-2.0.so.5
libevent_core-2.0.so.5.1.9
libevent_core.a
libevent_core.la
libevent_core.so
libevent_extra-2.0.so.5
libevent_extra-2.0.so.5.1.9
libevent_extra.a
libevent_extra.la
libevent_extra.so
libevent.la
libevent_pthreads-2.0.so.5
libevent_pthreads-2.0.so.5.1.9
libevent_pthreads.a
libevent_pthreads.la
libevent_pthreads.so
libevent.so
2.下载
http://libevent.org/
3.安装
tar -xf libevent-2.0.-stable.tar.gz./configure –prefix=/usr //配置目录
make
sudo make install
4.验证
root@iZ23nyl8frqZ:/home/upload# ls -a /usr/lib |grep libevent
libevent-2.0.so.5
libevent-2.0.so.5.1.9
libevent.a
libevent_core-2.0.so.5
libevent_core-2.0.so.5.1.9
libevent_core.a
libevent_core.la
libevent_core.so
libevent_extra-2.0.so.5
libevent_extra-2.0.so.5.1.9
libevent_extra.a
libevent_extra.la
libevent_extra.so
libevent.la
libevent_pthreads-2.0.so.5
libevent_pthreads-2.0.so.5.1.9
libevent_pthreads.a
libevent_pthreads.la
libevent_pthreads.so
libevent.so
5.测试
服务器端ser.c
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <string.h>
#include <event.h>
#include <stdlib.h>#define PORT 25341
#define BACKLOG 5
#define MEM_SIZE 1024struct event_base* base;
struct sock_ev
{
struct event* read_ev;
struct event* write_ev;
char* buffer;
};void release_sock_event(struct sock_ev* ev)
{
event_del(ev->read_ev);
free(ev->read_ev);
free(ev->write_ev);
free(ev->buffer);
free(ev);
}void on_write(int sock, short event, void* arg)
{
char* buffer = (char*)arg;
send(sock, buffer, strlen(buffer), ); free(buffer);
}void on_read(int sock, short event, void* arg)
{
struct event* write_ev;
int size;
struct sock_ev* ev = (struct sock_ev*)arg;
ev->buffer = (char*)malloc(MEM_SIZE);
bzero(ev->buffer, MEM_SIZE);
size = recv(sock, ev->buffer, MEM_SIZE, );
printf("receive data:%s, size:%d\n", ev->buffer, size);
if (size == )
{
release_sock_event(ev);
close(sock);
return;
}
event_set(ev->write_ev, sock, EV_WRITE, on_write, ev->buffer);
event_base_set(base, ev->write_ev);
event_add(ev->write_ev, NULL);
}void on_accept(int sock, short event, void* arg)
{
struct sockaddr_in cli_addr;
int newfd, sin_size;
struct sock_ev* ev = (struct sock_ev*)malloc(sizeof(struct sock_ev));
ev->read_ev = (struct event*)malloc(sizeof(struct event));
ev->write_ev = (struct event*)malloc(sizeof(struct event));
sin_size = sizeof(struct sockaddr_in);
newfd = accept(sock, (struct sockaddr*)&cli_addr, &sin_size);
event_set(ev->read_ev, newfd, EV_READ|EV_PERSIST, on_read, ev);
event_base_set(base, ev->read_ev);
event_add(ev->read_ev, NULL);
}int main(int argc, char* argv[])
{
struct sockaddr_in my_addr;
int sock; sock = socket(AF_INET, SOCK_STREAM, );
int yes = ;
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int));
memset(&my_addr, , sizeof(my_addr));
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(PORT);
my_addr.sin_addr.s_addr = INADDR_ANY;
bind(sock, (struct sockaddr*)&my_addr, sizeof(struct sockaddr));
listen(sock, BACKLOG); struct event listen_ev;
base = event_base_new();
event_set(&listen_ev, sock, EV_READ|EV_PERSIST, on_accept, NULL);
event_base_set(base, &listen_ev);
event_add(&listen_ev, NULL);
event_base_dispatch(base); return ;
}
客户端client.c:
#include <unistd.h>
#include <stdio.h>
#include <fcntl.h>
#include <netdb.h>
#include <sys/socket.h>
#include <stdlib.h>
#include <string.h>
#define cerror(str) do{perror(str); exit(EXIT_FAILURE); }while(0)static int port;
static char addr[];
static int nlen;
static char msg[]="hello\n";
int main(int argc, char*argv[])
{
int fd;
struct sockaddr_in sin; memset(&sin, , sizeof(sin));
sin.sin_family = AF_INET; if(argc<)
{
port = ;
}else
{
port = atoi(argv[]);
} sin.sin_port = htons(port); if(argc<)
{
strcpy(addr, argv[]);
if (inet_pton(AF_INET, addr, &(sin.sin_addr) )<)
{
struct hostent *psh;
psh=gethostbyname(addr);
if(psh!=NULL)
inet_pton(AF_INET, psh->h_addr, &(sin.sin_addr) );
else
cerror("inet_pton");
}
} if((fd=socket(AF_INET, SOCK_STREAM, ))<)
cerror("socket"); if(connect(fd, (struct sockaddr*)&sin, sizeof(sin))< )
cerror("sonnect"); if( (nlen = write(fd,msg, strlen(msg)))< )
cerror("write"); if( (nlen = read(fd,msg, strlen(msg)))< )
cerror("read");
msg[nlen]='\0';
printf("msg: %s\n", msg);
return ;
}
编译
chen@chen-book1:~/libevent20/sample$ gcc echo_client.c -o client
chen@chen-book1:~/libevent20/sample$ gcc ser.c -o ser -levent
chen@chen-book1:~/libevent20/sample$ ./ser &
[]
chen@chen-book1:~/libevent20/sample$ ./client localhost
receive data:hello
, size:
msg: helloreceive data:, size:
chen@chen-book1:~/libevent20/sample$ ./client localhost
receive data:hello
, size:
msg: hello