libhv创建简单udp控制台测试程序

client:

#include <iostream>
#include "hv/UdpClient.h"
#pragma comment(lib,"hv.lib")

class client
{
public:
	client()
	{
		cli = nullptr;
	}
	~client()
	{
		SAFE_DELETE(cli);
	}
	int send(const std::string& msg)
	{
		return cli->sendto(msg);
	}
	bool start(int port, const char* host)
	{
		cli = new hv::UdpClient;
		int sockfd = cli->createsocket(port, host);
		if (sockfd < 0) return false;
		cli->start();
		return true;
	}
private:
	hv::UdpClient* cli;
};
int main()
{
	client* clie = new client();
	clie->start(8080, "127.0.0.1");
	std::string s;
	std::cin >> s;
	while(getchar())
	{
		clie->send(s);
		std::cin >> s;
	}
}

server:

#include <iostream>
#include "hv/UdpServer.h"
#pragma comment(lib,"hv.lib")

void rev(const hv::SocketChannelPtr& channel, hv::Buffer* buf)
{
	std::cout << (char*)buf->data() << std::endl;
	std::cout << "data size:" << buf->size() << std::endl;
}
class server
{
public:
	server()
	{
		ser = nullptr;
	}
	~server()
	{
		SAFE_DELETE(ser);
	}
	bool start(int port, const char* host)
	{
		ser = new hv::UdpServer;
		int sockfd = ser->createsocket(port, host);
		if (sockfd < 0) return false;
		ser->onMessage = rev;
		ser->start();
		return true;
	}
private:
	hv::UdpServer* ser;
};

int main()
{
	server* se = new server();
	se->start(8080, "127.0.0.1");
	getchar();
}