13.bufferevent接受和发送数据

test.cpp

#include <iostream>
#include <event2/event.h>
#include <event2/thread.h>
#include<event2/listener.h>
#include <event2/bufferevent.h>
#include <errno.h>
#include <string.h>
#ifndef _WIN32
#include <signal.h>
#else
#endif
using namespace std;



void event_cb(bufferevent* be,short events, void* arg)
{
	cout << "[E]" << flush;
}

void write_cb(bufferevent* be, void* arg)
{
	cout << "[W]" << flush;
}

void read_cb(bufferevent* be, void* arg)
{
	cout << "[R]" << flush;
	char data[1024] = { 0 };
	//读取输入缓冲数据
	int len = bufferevent_read(be, data, sizeof(data) - 1);
	cout << "[" << data << "]" << endl;
	if (len <= 0) return;
	if (strstr(data, "quit") != NULL)
	{
		cout << "quit";
		//退出并关闭socket  BEV_OPT_CLOSE_ON_FREE
		bufferevent_free(be);
	}
	//发送数据，写入到输出缓冲
	bufferevent_write(be, "ok", 3);
}


void listen_cb(evconnlistener* ev, evutil_socket_t s, sockaddr* sin, int slen, void* arg)
{
	cout << "listen_cb" << endl;

	event_base* base = (event_base*)arg;

	//创建bufferevent上下文	BEV_OPT_CLOSE_ON_FREE,清理bufferevent时关闭socket
	bufferevent *bev=bufferevent_socket_new(base, s, BEV_OPT_CLOSE_ON_FREE);

	//添加监控事件
	bufferevent_enable(bev, EV_READ|EV_WRITE);

	//设置回调函数
	bufferevent_setcb(bev, read_cb, write_cb, event_cb, base);
	
}


int main(int argc, char** argv)
{
#ifdef _WIN32 
	//初始化socket库
	WSADATA wsa;
	WSAStartup(MAKEWORD(2, 2), &wsa);
#else
	//忽略管道信号，发送数据给已关闭的socket
	if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
		return 1;
#endif

	event_base* base = event_base_new();
	//创建网络服务器
	sockaddr_in sin;
	memset(&sin, 0, sizeof(sin));
	sin.sin_family = AF_INET;
	sin.sin_port = htons(6969);

	
	evconnlistener* ev = evconnlistener_new_bind(base,
		listen_cb,		//回调函数
		base,			//回调函数的参数arg
		LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,
		10,				//listen back
		(sockaddr*)&sin,
		sizeof(sin)
	);



    event_base_dispatch(base);
	evconnlistener_free(ev);
    event_base_free(base);

    return 0;
}

linux下的makefile

test:test.cpp
        g++ $^ -o $@ -levent
        ./$@
clean:
        rm -rf test
        rm -rf *.o