libevent使用

1:安装libevent

用wget指令直接下载libevent:# wget http://www.monkey.org/~provos/libevent-1.2.tar.gz

然后,在配置时需要指定一个安装路径,即./configure –prefix=/usr;然后make;然后make install;

详细的方法如下:

# cd /tmp

# wget http://www.monkey.org/~provos/libevent-1.2.tar.gz

# tar zxvf libevent-1.2.tar.gz
# cd libevent-1.2
# ./configure –prefix=/usr
# make
# make install

(注:在这里执行的时候出现错误:

1,no acceptable C compiler found in $PATH

由于centos默认没有安装gcc,使用yum安装

#yum install gcc* make*

测试libevent是否安装成功:
# ls -al /usr/lib | grep libevent
lrwxrwxrwx 1 root root 21 11?? 12 17:38 libevent-1.2.so.1 -> libevent-1.2.so.1.0.3
-rwxr-xr-x 1 root root 263546 11?? 12 17:38 libevent-1.2.so.1.0.3
-rw-r–r– 1 root root 454156 11?? 12 17:38 libevent.a
-rwxr-xr-x 1 root root 811 11?? 12 17:38 libevent.la
lrwxrwxrwx 1 root root 21 11?? 12 17:38 libevent.so -> libevent-1.2.so.1.0.3
还不错,都安装上了。

2:libevent的使用

-levent 使用

//#include <sys/socket.h>
//#include <sys/types.h>
//#include <netinet/in.h>
//#include <stdio.h>
//#include <event.h>
//struct event ev;
//struct timeval tv;
//void time_cb(int fd, short event, void *argc)
//{
// printf("timer wakeup/n");
// event_add(&ev, &tv); // reschedule timer
//}
//int main(void)
//{
// struct event_base *base = event_init();
// tv.tv_sec = 10; // 10s period
// tv.tv_usec = 0;
// evtimer_set(&ev,time_cb,NULL);
// event_add(&ev, &tv);
// event_base_dispatch(base);
// return 0;
//}
#include <sys/socket.h>
#include <sys/types.h>
#include <netinet/in.h>
#include <stdio.h>
#include <string.h>
#include <event.h>
#include <stdlib.h>

#define PORT 25341
#define BACKLOG 5
#define MEM_SIZE 1024

struct event_base* base;
struct sock_ev
{
struct event* read_ev;
struct event* write_ev;
char* buffer;
};

void release_sock_event(struct sock_ev* ev)
{
event_del(ev->read_ev);
free(ev->read_ev);
free(ev->write_ev);
free(ev->buffer);
free(ev);
}

void on_write(int sock, short event, void* arg)
{
char* buffer = (char*)arg;
printf("发送的%s\n",buffer);
send(sock, buffer, 1024, 0);
free(buffer);
}

void on_read(int sock, short event, void* arg)
{
printf("有连接可读\n");
struct event* write_ev;
int size;
struct sock_ev* ev = (struct sock_ev*)arg;
ev->buffer = (char*)malloc(MEM_SIZE);
bzero(ev->buffer, MEM_SIZE);
size = recv(sock, ev->buffer, MEM_SIZE, 0);
printf("receive data:%s, size:%d\n", ev->buffer, size);
if (size <= 0)
{
release_sock_event(ev);
close(sock);
return;
}
bzero(ev->buffer, MEM_SIZE);
sprintf(ev->buffer,"hello every one");
event_set(ev->write_ev, sock, EV_WRITE, on_write, ev->buffer);
event_base_set(base, ev->write_ev);
event_add(ev->write_ev, NULL);
}

void on_accept(int sock, short event, void* arg)
{

struct sockaddr_in cli_addr;
int newfd, sin_size;
struct sock_ev* ev = (struct sock_ev*)malloc(sizeof(struct sock_ev));
ev->read_ev = (struct event*)malloc(sizeof(struct event));
ev->write_ev = (struct event*)malloc(sizeof(struct event));
sin_size = sizeof(struct sockaddr_in);
printf("监听到可用sock\n");
newfd = accept(sock, (struct sockaddr*)&cli_addr, &sin_size);
//cli_addr.sin_addr.s_addr
event_set(ev->read_ev, newfd, EV_READ|EV_PERSIST, on_read, ev);//可读
event_base_set(base, ev->read_ev);
event_add(ev->read_ev, NULL);
}

int main(int argc, char* argv[])
{
struct sockaddr_in my_addr;
int sock;

sock = socket(AF_INET, SOCK_STREAM, 0);
int yes = 1;
setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int));
memset(&my_addr, 0, sizeof(my_addr));
my_addr.sin_family = AF_INET;
my_addr.sin_port = htons(5000);
my_addr.sin_addr.s_addr = INADDR_ANY;
bind(sock, (struct sockaddr*)&my_addr, sizeof(struct sockaddr));
listen(sock, BACKLOG);
/*
* 创建一个事件处理的全局变量,可以理解为这是一个负责集中处理各种出入IO事件的总管家,
* 它负责接收和派发所有输入输出IO事件的信息,这里调用的是函数event_base_new(),
* 很多程序里这里用的是event_init(),区别就是前者是线程安全的、而后者是非线程安全的
* 比如建议用event_base_dispatch代替event_dispatch
* 用event_assign代替event_set和event_base_set等
*/
struct event listen_ev;
base = event_base_new();//线程安全的版本

/*
* 在listen_en这个事件监听sock这个描述字的读操作,当读消息到达是调用on_accept函数
* ,EV_PERSIST参数告诉系统持续的监听sock上的读事件,如果不加该参数,
* 每次要监听该事件时就要重复的调用
*
* event_add函数,从前面的代码可知,sock这个描述字是bind到本地的socket端口上
* ,因此其对应的可读事件自然就是来自客户端的连接到达,
* 我们就可以调用accept无阻塞的返回客户的连接了。
*
* listen_ev注册到base这个事件中,相当于告诉处理IO的管家请留意我的listen_ev上的事件
* 相当于告诉处理IO的管家,当有我的事件到达时你发给我(调用on_accept函数),
* 至此对listen_ev的初始化完毕。
* 正式启动libevent的事件处理机制,
* 使系统运行起来,运行程序的话会发现event_base_dispatch是一个无限循环。
*/
event_set(&listen_ev, sock, EV_READ|EV_PERSIST, on_accept, NULL);//当读消息到达时调用On_accpet

event_base_set(base, &listen_ev);
event_add(&listen_ev, NULL);
event_base_dispatch(base);

return 0;
}

时间: 2024-10-11 22:35:35

libevent使用的相关文章

Windows 上静态编译 Libevent 2.0.10 并实现一个简单 HTTP 服务器(无数截图)

[文章作者:张宴 本文版本:v1.0 最后修改:2011.03.30 转载请注明原文链接:http://blog.s135.com/libevent_windows/] 本文介绍了如何在 Windows 操作系统中,利用微软 Visual Studio 2005 编译生成 Libevent 2.0.10 静态链接库,并利用 Libevent 静态链接库,实现一个简单的 HTTP Web服务器程序:httpd.exe. 假设 Visual Studio 2005 的安装路径为“D:\Program

1 Linux 安装 Libevent

Libevent官网:http://libevent.org/ 在线文档:http://www.wangafu.net/~nickm/libevent-2.0/doxygen/html/ 下载地址:https://github.com/libevent/libevent/releases/ 解压,编译,安装 创建文件夹 [email protected]:~$ mkdir libevent [email protected]:~$ cd libevent/ 解压文件: [email protec

浅谈libevent的使用--事件和数据缓冲

首先在学习libevent库的使用前,我们还要从基本的了解开始,已经熟悉了epoll以及reactor,然后从event_base学习,依次学习事件event.数据缓冲Bufferevent和数据封装evBuffer等,再结合具体的几个实例来了解libevent库的一些基本使用,有助于我们理解它的一些内部实现(由于之前我已经写过一篇epoll反应堆模型的,所以这里就不再介绍,直接从event_base开始介绍). libevent下载与安装: 在官网上找到 libevent-2.0.22-sta

libevent for qt网络模块

libevent for qt网络模块,直接替换qt的select模型,支持epoll,select,pool.使用非常简单,无需修改以前的代码结构 最近在开发im服务器,需要大并发链接.QT默认的是使用select模型的,这种轮询方式非常慢.在高并发连接,我们需要epoll才能发挥linux服务器的性能.而且使用简单,整个服务端代码架构无需修改,设置QT的分发事件就可以使用了,只要在main里面添加 : 1 2 3 4 5 6 7 8 9 10 11 12 13 14 int main(int

libevent学习一

首先,libevent是个什么东西呢?通过阅读:官网. libevent:一个事件通知库.libevent的API提供了一个可以执行回调函数的机制.这些事件可以是一个文件描述符或到达指定时间.而且,libevent也支持由signals或常规的timeout产生的回调. libevent是用来替代网络服务器上的时间循环的.一个程序只需要去调用event_dispatch()然后去动态的增加或删除事件,而不用去改变事件循环. 目前,libevent支持/dev/poll, kqueue(2), e

libevent在windows下使用步骤详解

libevent是一个常用的网络库,下面就看看在windows下面编译测试的过程吧. 一 环境 系统:win8.1 编译器:VS2013 官方下载地址:http://libevent.org/ 版本:2.0.22-stable 二 编译静态库 1 解压 把上面下载到libevent-2.0.22-stable.tar.gz解压,得到libevent-2.0.22-stable文件夹 2 添加宏定义 在libevent-2.0.22-stable文件夹下找到下面三个文件: event_iocp.c

linux 基础学习编译安装php+mysql+python3+memcached+radis+rabbitmq+libevent+tcl+gcc+erlang

CentOS 6.9 编译安装 Nginx+PHP+MYSQL 0x01 环境约束 源码位置 /home/[用户文件夹] 源码编译安装位置  /usr/local/[软件名] CentOS6.9 x86 - 64 最小化安装 配置好网络 用户 使用Xshell登录 0x02 软件下载 内网地址: http://192.168.20.252/src/php.tar.gz http://192.168.20.252/src/cmake.tar.gz http://192.168.20.252/src

libevent源码分析-TCP服务端代码

先贴一段代码再说,Linux下使用g++ -g-o server server.c -levent 可以直接使用gdb调试,而且可以跟踪到libevent的库里. 1 #include <stdio.h> 2 #include <string.h> 3 #include <iostream> 4 #include <sys/socket.h> 5 #include <netinet/in.h> 6 #include <arpa/inet.h

libevent 信号事件实现方式

学会使用libevent,才能真正的掌握其是实现原理,我们先从一个简短的测试用例开始: 1 #include <sys/types.h> 2 #include <sys/stat.h> 3 #include <sys/queue.h> 4 #include <unistd.h> 5 #include <sys/time.h> 6 7 #include <signal.h> 8 #include <fcntl.h> 9 #i

libevent for qt的讨论

一直对Qt官方的QtNetwork模块抱有遗憾,Qt自带的网络模块用的是select模型,无法支持高并发的服务器开发.最近在网上看到有个libevent for qt的东西,它直接替换了Qt的select模型,支持epoll模型,所以就支持高并发了.这东西好啊,弥补了Qt的不足,也弥补了我的遗憾.我兴致勃勃的从网上下载了源代码(github地址:https://github.com/sjinks/qt_eventdispatcher_libevent),然后在windows上编译,结果每次都报错