首页 手机软件 手机游戏 单机游戏 资讯文章 专题下载 游戏合集 文章合集 php下载 php教程 电脑软件
+ -
当前位置：首页 → 问答吧 → 大家说说libevent使用的经验吧。

大家说说libevent使用的经验吧。

时间：2010-09-19

来源：互联网

本帖最后由 ccnuliu 于 2010-09-19 18:48 编辑

大家说说libevent使用的经验吧。


我写了一个例子
第一 不知道撒时候释放client结构。我怎么知道客户端已经关闭了？
第二  释放client结构的时候，我需要调用event_del函数吗？

当建立了一个tcp连接的时候，如果双方不关闭
是始终保持打开的吗？ 需要发心跳包来保持连接吗？

event_del() 是删除 之前event_set的事件吧。


另外 event_add的作用是干嘛的呢？
  1. #include"event.h"
  2. #include<list>
  3. #include<sys/socket.h>
  4. #include<iostream>
  5. #include <errno.h>
  6. #include <arpa/inet.h>
  7. #include <unistd.h>
  8. #include <fcntl.h>
  9. using namespace std;

  11. struct EventData
  12. {
  13.         struct event readev;
  14.         struct event writeev;
  15.         EventData()
  16.         {
  17.                 memset(&readev,0,sizeof(readev));
  18.                 memset(&writeev,0,sizeof(writeev));
  19.         }
  20. };

  22. int setNoblock(int fd)
  23. {
  24.         int flags = fcntl(fd, F_GETFL);
  25.         if(flags < 0)
  26.         {       
  27.                 return flags;
  28.         }       
  29.         flags|=O_NONBLOCK;
  30.         if(fcntl(fd,F_SETFL,flags)<0)
  31.         {
  32.                 return -1;
  33.         }
  34.         return 0;
  35. }
  36. void Onread(int fd,short sev,void *agrv)
  37. {
  38.         struct EventData ev;
  39.         if(agrv==NULL)
  40.         {
  41.                 return ;
  42.         }
  43.         ev = *(struct EventData *)agrv;
  44.         //free(agrv);
  45.         agrv = NULL;
  46.        
  47.         char buf[1024] = {0};
  48.         int len = 0;
  49.         if(( len = read(fd,buf,sizeof(buf)) )<0)
  50.         {
  51.                 cout<<"read error"<<endl;
  52.                 close(fd);
  53.                 event_del(&ev.readev);
  54.                 return;
  55.         }
  56.         else if(len == 0)
  57.         {
  58.                 cout<<"client disconnected;"<<endl;
  59.                 close(fd);
  60.                 event_del(&ev.readev);
  61.                 return;
  62.         }
  63.         //cout<<"recv = "<<buf<<"recv size = "<<len<<endl;
  64.         //event_del(&ev.readev);
  65. }
  66. void Onwrite(int fd,short sev,void *agrv)
  67. {
  68.         cout<<"write = "<<fd<<endl;
  69.         if(agrv==NULL)
  70.         {
  71.                 return ;
  72.         }
  73.         struct EventData ev  = *(struct EventData *)agrv;
  74.         //free(agrv);
  75.         agrv = NULL;
  76.        
  77.         char buf[1024] = "welcome to Huazhong";
  78.         int len = 0;
  79.         len=write(fd,buf,strlen(buf));
  80.         if(len == -1)
  81.         {
  82.                 if (errno == EINTR || errno == EAGAIN)
  83.                 {
  84.                         event_add(&ev.writeev,NULL);
  85.                         return ;
  86.                 }
  87.                 else
  88.                 {
  89.                         cout<<"write error"<<endl;
  90.                         close(fd);
  91.                         event_del(&ev.writeev);
  92.                         return;
  93.                 }
  94.         }
  95.         //event_del(&ev.writeev);
  96. }

  98. void OnAccept(int fd,short ev,void *agrv)
  99. {
  100.         int clientFd;
  101.         struct sockaddr cli_Addr;
  102.         socklen_t len = sizeof(cli_Addr);
  103.        
  104.         if((clientFd = accept(fd,(struct sockaddr*)&cli_Addr,&len)) <0)
  105.         {
  106.                 cout<<"accept failed"<<endl;
  107.                 close(fd);
  108.                 return ;
  109.         }
  110.         setNoblock(clientFd);
  111.         EventData *client = (EventData*)malloc(sizeof(EventData));
  112.         if(client == NULL)
  113.         {
  114.                 cout<<"memmory haven't none"<<endl;
  115.                 return;
  116.         }
  117.         cout<<"client = "<<clientFd<<endl;
  118.         event_set(&client->readev,clientFd,EV_READ,Onread,client);
  119.         event_add(&client->readev,NULL);

  121.         event_set(&client->writeev,clientFd,EV_WRITE,Onwrite,client);
  122.         event_add(&client->writeev,NULL);
  123. }

  125. int main(int agrn,char* agrv[])
  126. {
  127.         if(agrn<=2)
  128.         {
  129.                 cout<<"ip,port"<<endl;
  130.                 return 0;
  131.         }
  132.         int listenFd = -1;       
  133.         listenFd  = socket(AF_INET,SOCK_STREAM,0);
  134.         setNoblock(listenFd);
  135.         if(listenFd < 0)
  136.         {
  137.                 cout<<"Create socket failed"<<endl;
  138.                 return -1;
  139.         }
  140.         cout<<"create socket sucess"<<endl;
  141.         struct sockaddr_in serv_addr;
  142.         memset(&serv_addr,0,sizeof(serv_addr));
  143.         serv_addr.sin_family = AF_INET;
  144.         serv_addr.sin_port = htons(atoi(agrv[2]));
  145.         serv_addr.sin_addr.s_addr = INADDR_ANY;
  146.         if( bind(listenFd,(struct sockaddr*)&serv_addr,sizeof(serv_addr))<0 )
  147.         {
  148.                 cout<<"bind failed"<<endl;
  149.                 return -1;
  150.         }
  151.         cout<<"bind sucess"<<endl;
  152.         if(listen(listenFd,200)<0)
  153.         {
  154.                 cout<<"listen Error..."<<endl;
  155.                 return -1;
  156.         }
  157.         cout<<"start listen....."<<endl;
  158.         event ev_accept;
  159.         event_init();
  160.         event_set(&ev_accept,listenFd,EV_READ|EV_PERSIST,OnAccept,NULL);
  161.         event_add(&ev_accept,NULL);
  162.         event_dispatch();
  163. }
复制代码

作者: ccnuliu   发布时间: 2010-09-19

1. recv 返回 0，表示客户端关闭了。
2. 要event_del

作者: zzyong08   发布时间: 2010-09-19

回复 zzyong08


   

在请问你一个问题：
当建立了一个tcp连接的时候，如果双方不关闭
是始终保持打开的吗？ 需要发心跳包来保持连接吗？

event_del() 是删除 之前event_set的事件吧。


另外 event_add的作用是干嘛的呢？

作者: ccnuliu   发布时间: 2010-09-19

相关阅读 更多

热门阅读

热门下载

更多
关于本站 免责申明 联系我们

Copyright 2006-2020 php爱好者(phpfans.net) All Rights Reserved.备案号：湘ICP备2023016114号-2

本站为非盈利性网站，不接受任何广告。本站所有资源均由网友上传，如有侵权，请发邮件至 [email protected] phpfans.net