当前位置：首页 > news >正文

C++学习之libevent ②

news 来源：原创 2025/9/21 6:15:23

1.连接服务器函数bufferevent_socket_connect()

2.bufferevent缓冲区的读写函数bufferevent_write() bufferevent_read()

3.给bufferevent设置回调函数bufferevent_setcb（）

4.bufferevent回调函数的函数原型

5.基于bufferevent的套接字客户端处理流程

6.套接字通信的客户端-1

7.套接字通信的客户端-2

8.客户端套接字程序流程总结

9.创建链接监听器 evconnlistener_new_bind()

10.链接监听器的回调函数

11.链接监听器其他属性设置

12.套接字服务器端处理流程分析

13.套接字服务器程序实现

14.套接字通信的客户端和服务器通信流程串讲和补充以及测试

1.连接服务器函数bufferevent_socket_connect()

创建/释放基于套接字的 bufferevent

  ```c
  // 创建带缓冲区的事件, 起始对通信的套接字进行封装
  struct bufferevent *bufferevent_socket_new(
      struct event_base *base,
      evutil_socket_t fd,
      enum bufferevent_options options
  );
  参数:
      - base: 事件处理框架
      - fd: 通信的文件描述符
          - 自己创建通信的文件描述符, 通过函数: socket();
          - 自动初始化(创建)一个通信的文件描述符: -1
      - options:
          - BEV_OPT_CLOSE_ON_FREE: 在销毁这个对象的时候, 自动释放封装的文件描述符

  // 释放带缓冲区的事件
  void bufferevent_free(struct bufferevent *bev);
  ```

- 在bufferevent上启动链接

  ```c
  // 连接服务器端的程序, 类似于 connect() 函数, 后两个参数的传参方式相同
  int bufferevent_socket_connect(
        struct bufferevent *bev,
        struct sockaddr *address,
        int addrlen
  );
  参数:
      - bev: 带缓冲区的事件, 通过 bufferevent_socket_new() 得到的
      - address: 需要在这里边初始化服务器端的IP和端口信息
      - addlen: address参数执行的内存大小

2.bufferevent缓冲区的读写函数bufferevent_write() bufferevent_read()

bufferevent读写缓冲区回调操作

  ```c
  typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
  参数:
      - bev: 和 bufferevent_setcb() 的第一个参数是相同的
      - ctx: 通过 bufferevent_setcb() 传递进来的参数, 就是该函数的最后一个参数

  typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short events, void *ctx);
      参数:
          - bev: bufferevent_setcb()函数的第一个参数被作为实参传递给了形参bev
          - events: 实际检测到的事件, 是多个事件的集合, 检测方式: events & BEV_EVENT_CONNECTED
              EV_EVENT_READING：读取操作时发生某事件，具体是哪种事件请看其他标志。
                  - 读操作产生了异常, 举例: 读缓冲区没数据并且做了读操作(读不阻塞)
              BEV_EVENT_WRITING：写入操作时发生某事件，具体是哪种事件请看其他标志。
                  - 写操作产生了异常, 举例: 写缓冲区满了并且做了写操作(写不阻塞的情况下)
              BEV_EVENT_ERROR：操作时发生错误。关于错误的更多信息
                  - 请调用 EVUTIL_SOCKET_ERROR()。
              BEV_EVENT_TIMEOUT：发生超时。
              BEV_EVENT_EOF：遇到文件结束指示。
                  - 通信的另外一端已经关闭了连接 (常用事件)
              BEV_EVENT_CONNECTED：请求的连接过程已经完成
                  - 这个判定是在客户端做的
          - ctx: bufferevent_setcb() 函数中的最后一个参数 cbarg, 被传递到该函数中

3.给bufferevent设置回调函数bufferevent_setcb（）

// 给读写缓冲区设置回调函数
  typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
  typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short events, void *ctx);
  void bufferevent_setcb(struct bufferevent *bufev,
                             bufferevent_data_cb readcb,
                             bufferevent_data_cb writecb,
                             bufferevent_event_cb eventcb, void *cbarg
  );
  参数:
      - bufferevent_socket_new() 得到的返回值, 封装了通信的文件描述符
      - readcb: 设置读缓冲区对应的回调函数
          - 当读缓冲区中有数据, 这个函数被自动调用
      - writecb: 设置写缓冲区对应的回调函数
          - 当写缓冲区中的数据被写入到内核中之后, 该回调函数被自动调用
      - eventcb: 事件的回调
          - 读写操作以为的事件
              - 异常事件
              - 连接成功
              - 对方断开了连接
      - cbarg: 作为实参传递给到上的三个回调函数中

4.bufferevent回调函数的函数原型

- 禁用、启用缓冲区

  ```c
  // bufferevent 读缓冲区默认不可用, 读事件就不会被检测, 读回调也就不会被调用
  // bufferevent 写缓冲区默认可用
  void bufferevent_enable(struct bufferevent *bufev, short events);
  void bufferevent_disable(struct bufferevent *bufev, short events);
  参数:
      - bufev: bufferevent 事件
      - events:
          - 读事件: EV_READ    2
          - 写事件: EV_WRITE   4
  // 获取当前缓冲区的状态
  short bufferevent_get_enabled(struct bufferevent *bufev);
  返回值为6: 读写缓冲区都可用
  返回值为2: 读缓冲区可用
  返回值为4: 写缓冲区可用

5.基于bufferevent的套接字客户端处理流程

操作bufferevent中的数据

  ```c
  // 数据发送, 其实数据通过这个函数将写数据写入bufferevent的写缓冲区中
  // 使用方法和write() 类似
  int bufferevent_write(struct bufferevent *bufev, const void *data, size_t size);
  参数:
      - bufev: bufferevent_socket_new() 得到的返回值, 封装了通信的文件描述符
        - data: 要发送的数据
        - size: 发送的数据 data 的长度
    返回值:
        >0: 发送的字节数
        -1: 失败

6.套接字通信的客户端-1

    // 接收数据, 其实数据通过这个函数从bufferevent的读缓冲区中可以将数据读出了
    // 使用方法和 read() 类似
    size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size);
    参数:
        - bufev: bufferevent_socket_new() 得到的返回值, 封装了通信的文件描述符
        - data: 存储数据的内存
        - size: data对应的内存大小
    ```

7.套接字通信的客户端-2

基于bufferevent的套接字通信的客户端程序

  ```c
  int main()
  {
      // 1. 创建事件处理框架
      struct event_base* base  =event_base_new();
      // 2. 创建带缓冲区的事件
      struct bufferevent *bufev = bufferevent_socket_new();
      // 3. 连接服务器
      bufferevent_socket_connect();
      // 给带缓冲区的事件设置回调函数
      bufferevent_setcb(bufev, read_cb, write_cb, event_cb, NULL);
      bufferevent_enable(bufev, EV_READ);
      // 4. 启动事件处理框架
      event_base_dispatch();
      // 5. 释放资源
  }

  ```

8.客户端套接字程序流程总结

> `在套接字通信的服务器端使用`
>
> 套接字通信服务器端的通信流程:
>
> 1. 创建监听的套接字
> 2. 绑定本地的IP和端口
> 3. 设置监听
> 4. 等待并接受客户端的连接
> 5. 通信
> 6. 断开连接
>
> 连接监听器能够处理上边的前四件事情

- 创建和释放evconnlistener

9.创建链接监听器 evconnlistener_new_bind()

// 创建链接监听器
  // 封装了监听的文件描述符, 可以设置监听, 并且建立新的连接
  struct evconnlistener* evconnlistener_new(
              struct event_base *base,
              evconnlistener_cb cb,
              void *ptr,
              unsigned flags,
              int backlog,
              evutil_socket_t fd
  );

10.链接监听器的回调函数

参数:
      - base: 事件的处理框架
      - cb: 回调函数, 处理连接成功之后的通信操作
      - ptr: 作为实参传递给回调函数cb
      - flags: 链接监听器的选项设置
          - LEV_OPT_CLOSE_ON_FREE: 链接监听器释放的时候关闭封装的监听的文件描述符
          - LEV_OPT_REUSEABLE: 设置端口复用
      - backlog: 相当于listen()函数的第二个参数
      - fd: 用于监听的文件描述符, 需要自己绑定, 然后传给该函数

  /*
  1. 创建监听的套接字
  2. 绑定ip和端口
  3. 设置监听
  4. 建立新连接
  */

11.链接监听器其他属性设置

struct evconnlistener *evconnlistener_new_bind(
              struct event_base *base,
              evconnlistener_cb cb,
              void *ptr,
              unsigned flags,
              int backlog,
              const struct sockaddr *sa,
              int socklen
  );
  参数:
      - base: 事件的处理框架
      - cb: 回调函数, 处理连接成功之后的通信操作
      - ptr: 作为实参传递给回调函数cb
      - flags: 链接监听器的选项设置
          - LEV_OPT_CLOSE_ON_FREE: 链接监听器释放的时候关闭封装的监听的文件描述符
          - LEV_OPT_REUSEABLE: 设置端口复用
      - backlog: 相当于listen()函数的第二个参数
          - 最大值128, 也可以指定为 -1 ==> libevent自动指定一个合适的值
      - sa: 绑定过程中需要的IP和端口
      - socklen: sa对应的结构体的内存大小

12.套接字服务器端处理流程分析

  // 释放链接监听器
  void evconnlistener_free(struct evconnlistener *lev);
  ```



- 启用和禁用 evconnlistener

  ```c
  #include <event2/listener.h>
  // 如果禁用之后服务器端的程序就不能监听客户端连接了
  int evconnlistener_disable(struct evconnlistener *lev);
  int evconnlistener_enable(struct evconnlistener *lev);
  ```

13.套接字服务器程序实现

服务器端套接字通信流程

  ```c
  void callback(
              struct evconnlistener *listener,
              evutil_socket_t sock,
              struct sockaddr *addr,
              int len,
              void *ptr
  )
  {
      // 通信, 将sock 封装为 bufferevent 类型
      // 给bufferevent 设置回调
      // 读缓冲区设置Wie可用
  }

  int main()
  {
      // 1. 创建事件处理框架
      // 2. 创建连接监听器
      struct evconnlistener * evl = evconnlistener_new_bind(...., callback, ...);

      // 3. 启动事件循环
      // 4. 释放资源
  }
  ```