设为首页 加入收藏

TOP

在Windows环境下实现一个简单的libevent服务器(一)
2017-10-10 12:02:52 】 浏览:9613
Tags:Windows 环境 实现 一个 简单 libevent 服务器

  最近再学习Libevent由于自己使用的是windows系统,遗憾的是有关在vs下可以参考的程序少之又少。在参考了许多的博客文章后。自己摸索写了一个简单的Libevent Server程序。并且在网上找了一个简单的客户端程序,测试该代码成功。今天在此做一个记录。

Libevent的确是一个非常好用的东西,还在继续学习中,后续还要在windows下实现Libevent的多线程使用。今天先把自己搞出来的东西贴上来,仅供学习参考。在vs2015上编译通过。

 

  默认情况下是单线程的(可以配置成多线程,如果有需要的话),每个线程有且只有一event base,对应一个struct event_base结构体(以及附于其上的事件管理器),用来schedule托管给它的一系列event,可以和操作系统的进程管理类比,当然,要更简单一点。当一个事件发生后,event_base会在合适的时间(不一定是立即)去调用绑定在这个事件上的函数(传入一些预定义的参数,以及在绑定时指定的一个参数),直到这个函数执行完,再返回schedule其他事件。

 

//创建一个event_base

struct event_base *base = event_base_new();

assert(base != NULL);

 

event_base内部有一个循环,循环阻塞在epoll / kqueue等系统调用上,直到有一个 / 一些事件发生,然后去处理这些事件。当然,这些事件要被绑定在这个event_base上。每个事件对应一个struct event,可以是监听一个fd或者POSIX信号量之类(这里只讲fd了,其他的看manual吧)。struct event使用event_new来创建和绑定,使用event_add来启用:

 

//创建并绑定一个event

struct event *listen_event;

//参数:event_base, 监听的fd,事件类型及属性,绑定的回调函数,给回调函数的参数

 

listen_event = event_new(base, listener, EV_READ | EV_PERSIST, callback_func, (void*)base);

//参数:event,超时时间(struct timeva l *类型的,NULL表示无超时设置)

event_add(listen_event, NULL);

 

注:libevent支持的事件及属性包括(使用bitfield实现,所以要用 | 来让它们合体)

(a) EV_TIMEOUT: 超时

(b) EV_READ : 只要网络缓冲中还有数据,回调函数就会被触发

(c) EV_WRITE : 只要塞给网络缓冲的数据被写完,回调函数就会被触发

(d) EV_SIGNAL : POSIX信号量,参考manual吧

(e) EV_PERSIST : 不指定这个属性的话,回调函数被触发后事件会被删除

(f) EV_ET : Edge - Trigger边缘触发,参考EPOLL_ET

然后需要启动event_base的循环,这样才能开始处理发生的事件。循环的启动event base dispatch,循环将一直持续,直到不再有需要关注的事件,或者是遇到event_loopbreak() / event_loopexit()函数。

//启动事件循环

event_base_dispatch(base);

接下来关注下绑定到event的回调函数callback_func:传递给它的是一个socket fd、一个event类型及属性bit_field、以及传递给event_new的最后一个参数(去上面几行回顾一下,把event_base给传进来了,实际上更多地是分配一个结构体,把相关的数据都撂进去,然后丢给event_new,在这里就能取得到了)。其原型是:

typedef void(*event_callback_fn)(evutil_socket_t sockfd, short event_type, void *arg)

 

对于一个服务器而言,上面的流程大概是这样组合的:

1. listener = socket(),bind(),listen(),设置nonblocking(POSIX系统中可使用fcntl设置,windows不需要设置,

    实际上libevent提供了统一的包装evutil_make_socket_nonblocking)

2. 创建一个event_base

3. 创建一个event,将该socket托管给event_base,指定要监听的事件类型,并绑定上相应的回调函数(及需要给它的参数)

    。对于listener socket来说,只需要监听EV_READ | EV_PERSIST

4. 启用该事件

5. 进入事件循环

-------------- -

6. (异步)当有client发起请求的时候,调用该回调函数,进行处理。

/*接下来关注下绑定到event的回调函数callback_func:传递给它的是一个socket fd、一个event类型及属性bit_field、以及传递给event_new的最后一个参数(去上面几行回顾一下,把event_base给传进来了,实际上更多地是分配一个结构体,把相关的数据都撂进去,然后丢给event_new,在这里就能取得到了)。*/

 

服务器端代码:Server.cpp

  1 #include <WinSock2.h>
  2 #include <stdlib.h>
  3 #include <stdio.h>
  4 #include <string.h>
  5 #include <errno.h>
  6 #include <event2/event.h>
  7 #include <event2/bufferevent.h>
  8 #include<iostream>
  9 #include<cassert>
 10 #pragma comment (lib,"ws2_32.lib")
 11 #include<ws2tcpip.h>
 12 #define LISTEN_PORT 9999
 13 #define LIATEN_BACKLOG 32
 14 using namespace std;
 15 /*********************************************************************************
 16 *                                      函数声明
 17 **********************************************************************************/
 18 //accept回掉函数
 19 void do_accept_cb(evutil_socket_t listener, short event, void *arg);
 20 //read 回调函数
 21 void read_cb(struct bufferevent *bev, void
首页 上一页 1 2 3 下一页 尾页 1/3/3
】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
上一篇php中数组和字符串的相互转换 下一篇PHPExcel 相关操作

最新文章

热门文章

Hot 文章

Python

C 语言

C++基础

大数据基础

linux编程基础

C/C++面试题目