我是靠谱客的博主 英勇黄豆,最近开发中收集的这篇文章主要介绍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、管道通信代码所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复