西安建设规划局网站,wordpress 仿36氪,网站建设与网页设计pdf,北京网站建设上石榴汇一、libevent的概念
1.定义
是开源社区的高性能的I/O框架库。旨在简化网络应用中事件驱动的编程模型。
2.特点
①跨平台支持
②统一事件源#xff1a;对I/O事件、信号和定时事件提供统一的处理。
③线程安全
④基于Reactor模式的实现。
3.工作原理
当有事件发生时对I/O事件、信号和定时事件提供统一的处理。
③线程安全
④基于Reactor模式的实现。
3.工作原理
当有事件发生时libevent库内部会采用I/O复用方法检测就绪事件如果就绪则调用该事件的回调函数。
①首先用户注册事件
②然后定义事件基础event_base
③调用底层多层复用等待事件发生
④事件就绪调用回调函数
扩展
1事件表示一项需要监听的事件。
2回调函数某个事件发生时触发的函数。
二、libevent对信号和定时事件的处理
1.步骤
①首先定义libevent实例
②定义事件
③将事件添加到libevent中
④事件循环检测事件是否就绪
⑤释放事件
2.代码实现
#includestdio.h
#includestdlib.h
#includestring.h
#includeunistd.h
#includeassert.h
#includeevent.h
#includesignal.h
#includetime.h
void sig_cb(int fd,short ev,void*arg)
{if(evEV_SIGNAL){printf(sig%d\n,fd);}
}
void timeout_cb(int fd,short ev,void*arg)
{if(evEV_TIMEOUT){printf(timeout\n);}
}
int main()
{//1.定义libevent事例struct event_base *baseevent_init();//2.定义事件struct event*sig_evevsignal_new(base,SIGINT,sig_cb,NULL);//3.添加事件到libeventevent_add(sig_ev,NULL);struct timeval tv{5,0};//定义事件struct event* time_evevtimer_new(base,timeout_cb,NULL);//添加事件到libeventevent_add(time_ev,tv);//事件循环——内部调用select/poll/epoll循环检测事件event_base_dispatch(base);//会阻塞 epoll_wait//释放事件event_free(time_ev);event_free(sig_ev);event_base_free(base);exit(0);}
三、libevent实现TCP协议
1.服务器端编写的步骤
①定义libevent实例
②定义接收连接的事件
③将事件添加到libevent库中
④循环检测事件是否就绪就绪则调用该回调函数
⑤释放事件和实例
注意主要编写的是回调函数回调函数中包括了接受连接和接受数据的功能
2.代码实现
1服务器端代码
#includestdio.h
#includestdlib.h
#includestring.h
#includeunistd.h
#includeassert.h
#includeevent.h
#includesignal.h
#includetime.h
//套接字初始化
int socket_init()
{int sockfdsocket(AF_INET,SOCK_STREAM,0);//定义套接字if(sockfd-1){return -1;}struct sockaddr_in saddr;memset(saddr,0,sizeof(saddr));//清空saddr.sin_familyAF_INET;//设置地址符saddr.sin_porthtons(6000);//端口saddr.sin_addr.s_addrinet_addr(127.0.0.1);//ip地址int resbind(sockfd,(struct sockaddr*)saddr,sizeof(saddr));//绑定if(res-1){printf(bind err\n);return -1;}reslisten(sockfd,5); //创建监听队列if(res-1){return -1;}return sockfd; //返回套接字
}
struct mess
{struct event*ev;//存放事件的指针//char data[1024];//定义自定义数据
};void recv_data(int c,short ev,void*arg)
{struct mess*p(struct mess*)arg;//强转获取参数if(evEV_READ)//判断事件是否发生{char buff[128]{0};int nrecv(c,buff,127,0);//接受数据if(n0) //判断对方是否关闭连接{//libevent移除event_free(p-ev);//不移除会阻塞因为如果同名则不放入libevent库free(p);//释放动态申请的空间close(c);printf(client close\n);return;}printf(buff%s\n,buff);send(c,ok,2,0);}
}
//sockfd的回调函数
void accept_client(int sockfd,short ev,void*arg)
{struct event_base* base(struct event_base*)arg;//将参数传递if(evEV_READ)//判断是否为只读事件{int caccept(sockfd,NULL,NULL);//接受客户端连接if(c0){return;}printf(accept c%d\n,c);//客户端连接成功//接受客户端的数据//定义连接数据事件recv_data接受数据事件的回调函数struct mess*p(struct mess*)malloc(sizeof(struct mess));//目的是确保释放时空间还在p-evevent_new(base,c,EV_READ|EV_PERSIST,recv_data,p);event_add(p-ev,NULL);//添加事件到libevent}
}
int main()
{int sockfdsocket_init();if(sockfd-1){exit(1);}//1.定义libevent实例struct even_base*baseevent_init();//2.添加事件sockfd到libevent//设置为只读和永久事件回调函数为accept_client,参数是实例struct event*sock_evevent_new(base,sockfd,EV_READ|EV_PERSIST,accept_client,base);event_add(sock_ev,NULL);//3.启动事件循环会阻塞event_base_dispatch(base);//4.释放事件和实例event_free(sock_ev);event_base_free(base);exit(0);
}
2客户端代码
#includestdio.h
#includestdlib.h
#includestring.h
#includeunistd.h
#includeassert.h
#includesys/socket.h
#includesys/types.h
#includearpa/inet.h
#includenetinet/in.h
//客户端的流程
//socket() connect send recv() close()
int main()
{int sockfdsocket(AF_INET,SOCK_STREAM,0);//创建套接字if(sockfd-1){printf(socket err\n);exit(1);}struct sockaddr_in saddr;//指定服务器端的ip和portmemset(saddr,0,sizeof(saddr));//清空结构体中的4个成员saddr.sin_familyAF_INET;//ipv4协议saddr.sin_porthtons(6000);//服务器端口saddr.sin_addr.s_addrinet_addr(127.0.0.1);//ip地址int resconnect(sockfd,(struct sockaddr*)saddr,sizeof(saddr));//建立连接三次握手if(res-1){printf(connect err\n);exit(1);}while(1){char buff[128]{0};printf(input:\n);fgets(buff,128,stdin);if(strncmp(buff,end,3)0){break;}send(sockfd,buff,strlen(buff)-1,0);//发送数据memset(buff,0,sizeof(buff));//清空buff中的数据recv(sockfd,buff,127,0);printf(buff%s\n,buff);}close(sockfd);exit(0);
}
