libevent3:event_config相关配置

libevent有很多配置需要根据不同的场景，去进行不同的选择。主要是 event_config_set_flag 与 event_config_require_features 两个函数

int event_config_set_flag(struct event_config cfg, int flag)
函数功能: 设置配置的标志位为了后面的new base做准备
参数介绍:
   cfg: 配置内部结构体用event_config_new()创建
   flag: 配置的标记会影响之后创建base时候的一些限制取值为
   EVENT_BASE_FLAG_NOLOCK //禁止对event_base 分配锁
       EVENT_BASE_FLAG_IGNORE_ENV //禁止检查EVENT_的环境变量如”EVENT_PRECISE_TIMER”
       EVENT_BASE_FLAG_NO_CACHE_TIME //base不缓存时间, 缓存时间是为了避免多次调用系统函数获得时间
       EVENT_BASE_FLAG_EPOLL_USE_CHANGELIST 如果后台方法是epoll，则此模式是指可以安全的使用libevent内部 changelist 进行批量增删而尽可能减少系统调用,这种模式可以让代码性能更高,但是可能会引起Linux bug 如果有任何由dup（）或者他的变量克隆的fds,则是不安全的,这样做会引起奇怪并且难以检查的bug
       EVENT_BASE_FLAG_PRECISE_TIMER 使用精度高的定时器如CLOCK_MONOTONIC, 如果系统支持timerfd_create() 则在epoll会使用此系统定时器,不设置的话默认使用CLOCK_MONOTONIC_COARSE(如果系统支持),了解此宏,可以看clock_gettime()系统函数的使用

int event_config_require_features(struct event_config *cfg, int features)
函数功能: 设置配置的特性,event base会选择含有设置特性的io机制
对配置设置此特性主要是为了筛选合适的io机制
对于各个io机制支持的特性如下:
“evport”:无
“kqueue”: EV_FEATURE_ET|EV_FEATURE_O1|EV_FEATURE_FDS
“epoll”: EV_FEATURE_ET|EV_FEATURE_O1|EV_FEATURE_EARLY_CLOSE
“devpoll”: EV_FEATURE_FDS|EV_FEATURE_O1
“poll”: EV_FEATURE_FDS
“select”: EV_FEATURE_FDS
参数:
   cfg: 内部配置结构体指针
features: 特性值如下
EV_FEATURE_ET 边缘触发触发机制,高效但是容易丢消息，注意与水平触发区分
EV_FEATURE_O1 要求具有很多事件的io机制可以以近似O（1）处理事件,select和poll无法提供这种特征，它们只能提供近似O（N）的操作
EV_FEATURE_FDS io机制可以处理包括sockets在内的各种文件描述符
EV_FEATURE_EARLY_CLOSE 检查事件连接是否关闭,可以使用此特性来检测链接是否关闭

以下代码是我在测试的时候写的，可自行做简单修改跑起来观察

git地址:http://121.4.70.4:3000/adminPyf/libevent_study.git
libevent_study/test_conf

#include <iostream>
#include<event2/event.h>
#include<event2/thread.h>
#include<event2/listener.h>
#include <string.h>
#ifdef _WIN32

#else
    #include <signal.h>
#endif // !_WIN32

using namespace std;

#define SPORT 5001

void listen_cb(struct evconnlistener *, evutil_socket_t, struct sockaddr *, int socklen, void *arg) {
    std::cout << "listen to be" << std::endl;
}

int main()
{
#ifdef _WIN32
    //初始化socket库
    WSADATA wsa;
    WSAStartup(MAKEWORD(2, 2), &wsa);
#else 
    if (signal(SIGPIPE, SIG_IGN) == SIG_ERR) { //忽略管道信号，发送数据给已关闭的socket，会飞掉！
        return 1;
    }
#endif

    //初始化libevent上下文
    event_config *conf = event_config_new();

    //打印支持的网络模式
    const char** methods =  event_get_supported_methods();
    cout << "supported_methods" << endl;
    for (int i = 0; methods[i] != NULL; i++) {
        cout << methods[i] << endl;
    }

    //设置特征
    //设置了EV_FEATURE_FDS 其它特征就无法设置，在windows中EV_FEATURE_FDS无效
    //event_config_require_features(conf,  EV_FEATURE_FDS);  //不支持epoll

    //设置网络模型使用select
    //event_config_avoid_method(conf, "epoll");  //linux 默认顺序为 epoll -> poll -> select
    //event_config_avoid_method(conf, "poll"); 


    //windows中支持IOCP(线程池) 要查看该项是否开启成功，可以在运行程序后打开任务管理器查看线程数量
#ifdef _WIN32
    event_config_set_flag(conf, EVENT_BASE_FLAG_STARTUP_IOCP);
    evthread_use_windows_threads();
    //设置cpu数量
    SYSTEM_INFO si;
    GetSystemInfo(&si);
    event_config_set_num_cpus_hint(conf, si.dwNumberOfProcessors);
#endif


    //初始化配置上下文
    event_base* base =  event_base_new_with_config(conf);


    if (!base) {
        cout << "event_base_new_with_config failed!" << endl;
        base = event_base_new();
        if (!base) {
            cerr << "event_base_new failed" << endl;
            return 0;
        }
    }
    else {
        //获取当前网络模型
        cout << "current mothed is " << event_base_get_method(base) << endl;


        //确认特征是否生效
        int f = event_base_get_features(base);
        if (f& EV_FEATURE_ET) {
            cout << "EV_FEATURE_ET  events are supported" << endl;
        }
        else {
            cout << "EV_FEATURE_ET events are not supported" << endl;
        }
        if (f& EV_FEATURE_O1) {
            cout << "EV_FEATURE_O1 events are supported" << endl;
        }
        else {
            cout << "EV_FEATURE_O1 events are not supported" << endl;
        }
        if (f& EV_FEATURE_FDS) {
            cout << "EV_FEATURE_FDS events are supported" << endl;
        }
        else {
            cout << "EV_FEATURE_FDS events are not supported" << endl;
        }
        if (f& EV_FEATURE_EARLY_CLOSE) {
            cout << "EV_FEATURE_EARLY_CLOSE events are supported" << endl;
        }
        else {
            cout << "EV_FEATURE_EARLY_CLOSE events are not supported" << endl;
        }

        cout << "event_base_new_with_config success!" << endl;


        sockaddr_in sin;
        memset(&sin, 0, sizeof(sin));
        sin.sin_family = AF_INET;
        sin.sin_port = htons(SPORT);

        evconnlistener * ev = evconnlistener_new_bind(base, //libevent上下文
            listen_cb, //接收到连接的回调函数
            base, //回调函数获取的参数(根据业务来)
            LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE, //地址重用，evconnlistener关闭同时关闭socket
            10,  //连接队列大小，对应listen函数参数
            (sockaddr*)&sin,//绑定的地址和端口
            sizeof(sin)
        );
        event_base_dispatch(base);
        event_base_free(base);
        evconnlistener_free(ev);

        event_config_free(conf);
    }
    return 0;
}

libevent3:event_config相关配置

发表回复 取消回复

发表回复取消回复