15. Bufferevent client test connection server

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;


// error , Overtime （ The connection is disconnected and the meeting enters ）
void event_cb(bufferevent* be,short events, void* arg)
{
	cout << "[E]" << flush;
	// After the read timeout event , Data stop reading 
	if (events & BEV_EVENT_TIMEOUT && events & BEV_EVENT_READING)
	{
		cout << "BEV_EVENT_READING BEV_EVENT_TIMEOUT" << endl;
		//bufferevent_enable(be, EV_READ);
		bufferevent_free(be);
	}
	else if (events & BEV_EVENT_ERROR)
	{
		bufferevent_free(be);
	}
	else
	{
		cout << "OTHERS" << endl;
	}
}

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

void read_cb(bufferevent* be, void* arg)
{
	cout << "[R]" << flush;
	char data[1024] = { 0 };
	// Read input buffer data 
	int len = bufferevent_read(be, data, sizeof(data) - 1);
	cout << "[" << data << "]" << endl;
	if (len <= 0) return;
	//if (strstr(data, "quit") != NULL)
	//{
	//	cout << "quit";
	//	// Exit and close socket  BEV_OPT_CLOSE_ON_FREE
	//	bufferevent_free(be);
	//}
	// send data , Write to output buffer 
	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;

	// establish bufferevent Context 	BEV_OPT_CLOSE_ON_FREE, clear bufferevent Turn off socket
	bufferevent *bev=bufferevent_socket_new(base, s, BEV_OPT_CLOSE_ON_FREE);

	// Add monitoring events 
	bufferevent_enable(bev, EV_READ|EV_WRITE);


	// Set the water level 
	// Read water level 
	bufferevent_setwatermark(bev, EV_READ,
		5,	// Low water level ,0 Is unlimited , The default is 0
		10);	// High water level ,0 Is unlimited , The default is 0

	bufferevent_setwatermark(bev, EV_WRITE,
		5,	// Low water level ,0 Is unlimited , The default is 0, Buffered data is lower than 5 The write callback is called 
		0);	// Invalid high water level 

	// The setting of timeout time 
	timeval t1 = { 3,0 };
	bufferevent_set_timeouts(bev, &t1,0);

	// Set the callback function 
	bufferevent_setcb(bev, read_cb, write_cb, event_cb, base);
	
}


void client_event_cb(bufferevent* be, short events, void* arg)
{
	cout << "[Client E]" << flush;
	// After the read timeout event , Data stop reading 
	if (events & BEV_EVENT_TIMEOUT && events & BEV_EVENT_READING)
	{
		cout << "BEV_EVENT_READING BEV_EVENT_TIMEOUT" << endl;
		//bufferevent_enable(be, EV_READ);
		bufferevent_free(be);
	}
	else if (events & BEV_EVENT_ERROR)
	{
		bufferevent_free(be);
	}
	else
	{
		cout << "OTHERS" << endl;
	}
}



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

void client_read_cb(bufferevent* be, void* arg)
{
	cout << "[Client R]" << flush;
}


int main(int argc, char** argv)
{
#ifdef _WIN32 
	// initialization socket library 
	WSADATA wsa;
	WSAStartup(MAKEWORD(2, 2), &wsa);
#else
	// Ignore the pipe signal , Send data to the closed socket
	if (signal(SIGPIPE, SIG_IGN) == SIG_ERR)
		return 1;
#endif

	event_base* base = event_base_new();
	// Create a web server 
	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,		// Callback function 
		base,			// The parameters of the callback function arg
		LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,
		10,				//listen back
		(sockaddr*)&sin,
		sizeof(sin)
	);

	 
	{
		// Call client code 
		//-1 Create inside socket
		bufferevent* bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE);
		sockaddr_in sin;
		memset(&sin, 0, sizeof(sin));
		sin.sin_family = AF_INET;
		sin.sin_port = htons(6969);
		evutil_inet_pton(AF_INET, "127.0.0.1", &sin.sin_addr.S_un.S_addr);

		// Set the callback function 
		bufferevent_setcb(bev, client_read_cb, client_write_cb, client_event_cb, 0);
		bufferevent_enable(bev, EV_READ | EV_WRITE);

		int re = bufferevent_socket_connect(bev, (sockaddr*)&sin, sizeof(sin));
		if (re == 0)
		{
			cout << "connect" << endl;
		}
	}

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

    return 0;
}

linux Next makefile

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