我是靠谱客的博主 英勇黄豆,最近开发中收集的这篇文章主要介绍Linux c libevent库监听管道读写(mkfifo)1、libevent库使用基本流程2、管道通信代码,觉得挺不错的,现在分享给大家,希望可以做个参考。

概述

文章目录

  • 1、libevent库使用基本流程
  • 2、管道通信代码

1、libevent库使用基本流程

安装: Linux c libevent库安装(简单使用)

1、创建 底座 
struct event_base* event_base_new(void);

2、创建常规事件
回调函数类型:
	typedef void(*event_callback_fn)(evutil_socket_t fd,short,void*)

struct event* event_new(struct event_base* base,evutil_socket_t fd,short what,event_callback_fn cb,void *arg);
参数:
	base:event_base_new返回值
	fd:需要绑定的文件描述符
	what:对应事件(r、w、e)
        EV_READ 一次读事件
        EV_WRTIE 一次写事件
        EV_PERSIST  持续触发,结合event_base_dispatch函数使用生效
    cd:一旦事件满足监听条件、回调的函数
	arg:回调函数参数

3、添加事件
int event_add(struct event* ev,const struct timeval* tv);
参数:
    ev:event_new()的返回值
    tv:
    	NULL不会超时(一直等到事件被触发,回调函数会被调用)
        为非0等待期间,检查事件没有被触发,时间到,回调函数依旧会被调用

4、循环监听事件满足
int event_base_dispatch(struct event_base* base);
参数:
	base:event_base_new 返回值

5、释放
int event_free(struct event* ev);
参数:
	ev:event_new 事件
	
void event_base_free(struct event_base* base);
参数:
	base:event_base_new

2、管道通信代码

管道读端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <event2/event.h>

void sys_err(const char* str)
{
    perror(str);
    exit(1);
}


// 回调函数
void read_cb(evutil_socket_t fd,short what,void* arg)
{
    char buf[1024] = {0};
    int len = read(fd,buf,sizeof(buf));
    printf("read event:%sn",what&EV_READ?"yes":"NO");
    printf("data len = %d,buf=%sn",len,buf);
    sleep(1);
}

int main(int argc,char* argv[])
{
    unlink("myfifo");
    mkfifo("myfifo",0644);  // 创建管道
    int fd = open("./myfifo",O_RDONLY|O_NONBLOCK);
    if(fd == -1)
    {
        sys_err("open error");
    }
    struct event_base* base = event_base_new();

    // 创建事件 持续读事件
    struct event* ev = event_new(base,fd,EV_READ|EV_PERSIST,read_cb,NULL);

    // 添加事件
    event_add(ev,NULL);

    // 事件循环
    event_base_dispatch(base);  // while(1){epoll}

    // 释放
    event_free(ev);
    event_base_free(base);
    close(fd);
    return 0;
}

管道写端

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <fcntl.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <event2/event.h>

void sys_err(const char* str)
{
    perror(str);
    exit(1);
}


// 回调函数
void write_cb(evutil_socket_t fd,short what,void* arg)
{
    char buf[1024];
    static int num = 0;
    sprintf(buf,"hello %dn",num++);
    int len = write(fd,buf,strlen(buf)+1);

    sleep(1);
}

int main(int argc,char* argv[])
{
    // unlink("myfifo");
    // mkfifo("myfifo",0644);  // 创建管道
    int fd = open("./myfifo",O_WRONLY|O_NONBLOCK);
    if(fd == -1)
    {
        sys_err("open error");
    }
    struct event_base* base = event_base_new();

    // 创建事件
    struct event* ev = event_new(base,fd,EV_WRITE|EV_PERSIST,write_cb,NULL);

    // 添加事件
    event_add(ev,NULL);

    // 事件循环
    event_base_dispatch(base);  // while(1){epoll}

    // 释放
    event_free(ev);
    event_base_free(base);
    close(fd);
    return 0;
}

最后

以上就是英勇黄豆为你收集整理的Linux c libevent库监听管道读写(mkfifo)1、libevent库使用基本流程2、管道通信代码的全部内容,希望文章能够帮你解决Linux c libevent库监听管道读写(mkfifo)1、libevent库使用基本流程2、管道通信代码所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
点赞(42)

评论列表共有 0 条评论

立即
投稿
返回
顶部