0
点赞
收藏
分享

微信扫一扫

mysql 8.0版本更换用户密码

丹柯yx 2023-06-29 阅读 84

windows操作系统上不能使用epoll模型,只能使用iocp网络模型。这里我把怎么在windows上使用iocp的代码直接贴上:


#include <iostream>
#include <signal.h>
#include <event2/event.h>
#include <event2/listener.h>
#include <event2/thread.h>

#define SPORT 5001

void listen_cb(struct evconnlistener* ev,
    evutil_socket_t s,
    struct sockaddr* addr,
    int socketLen,
    void* arg) {
    std::cout << "listen_cb event_base_new success!" << std::endl;
}

int main()
{
#ifdef _WIN32
    //windows初始化socket库
    WSADATA wsa;
    WSAStartup(MAKEWORD(2, 2), &wsa);
#else
    //发送数据给已关闭socket时,忽略管道信息.
    //否则可能导致程序dump.
    if (signal(SIGPIPE, SIG_IGN) == SIG_ERR) {
        return -1;
    }
#endif

    //创建配置上下文
    event_config* conf = event_config_new();

    //设置网络模型,使用select
    //event_config_avoid_method(conf, "epoll");
    //event_config_avoid_method(conf, "poll");

//window支持iocp
#ifdef _WIN32
    event_config_set_flag(conf, EVENT_BASE_FLAG_STARTUP_IOCP);
    // 初始化IOCP线程(必须要有)
    evthread_use_windows_threads();
    //设置cpu数量
    SYSTEM_INFO si;
    GetSystemInfo(&si);
    event_config_set_num_cpus_hint(conf, si.dwNumberOfProcessors);
#endif

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

    if (!base) {
        std::cerr << "event_base_new_with_config failed!" << std::endl;

    }
    else {
        std::cout << "event_base_new_with_config success!" << std::endl;

        //获取当前网络模型
        std::cout << "current method is:" << event_base_get_method(base) << std::endl;
        struct 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,  // 设置地址重用和关闭同时关闭socket
                                        10, // 连接队列大小,对应listen函数
                                        (struct sockaddr*)&sin, // 绑定socket地址和端口
                                        sizeof(sin));
        event_base_dispatch(base);

        evconnlistener_free(ev);
        event_base_free(base);
    }

#ifdef _WIN32
    //清理window的socket库
    WSACleanup();
#endif

    return 0;
}

运行后,我们在任务管理器里就可以看到程序进程的线程数目:我这里是11个线程。

举报

相关推荐

0 条评论