A modern C++ network library based on asio for high performance network services
sample tcp server
#include <iostream>
#include "EventLoop.h"
#include "TcpServer.h"
#include "TcpConn.h"
void OnConnection(const TCPConnPtr& conn) {
if (conn->IsConnected()) {
std::cout << conn->GetName() <<" connection accepted.\n";
}
else if (conn->IsDisconnecting()) {
std::cout << conn->GetName() <<" connection disconnecting.\n";
}
}
void OnMessage(const TCPConnPtr& conn, ByteBuffer& buffer) {
std::cout << "recv msg " << std::string(buffer.Data(), buffer.Size()) << std::endl;
buffer.ReadBytes(buffer.Size());
buffer.Normalize();
conn->Send("server say hello!");
}
int main()
{
EventLoop loop;
TCPServer s(&loop, "0.0.0.0", 7788, "EchoServer", 4);
s.SetConnectionCallback(OnConnection);
s.SetMessageCallback(OnMessage);
s.Init();
s.Start();
loop.Run();
return 0;
}sample tcp client
#include <iostream>
#include "EventLoop.h"
#include "TcpClient.h"
#include "TcpConn.h"
void OnConnection(const TCPConnPtr& conn) {
if (conn->IsConnected()) {
std::cout << conn->GetName() <<" connection accepted.\n";
conn->Send("client say hello!");
}
else if (conn->IsDisconnecting()) {
std::cout << conn->GetName() <<" connection disconnecting.\n";
}
}
void OnMessage(const TCPConnPtr& conn, ByteBuffer& buffer) {
std::cout << "recv msg " << std::string(buffer.Data(), buffer.Size()) << std::endl;
buffer.ReadBytes(buffer.Size());
buffer.Normalize();
conn->Send("client say hello!");
}
int main()
{
EventLoop loop;
TCPClient client(&loop, "127.0.0.1", 7788, "EchoClient");
client.Connect();
client.SetAutoReconnect(true);
client.SetConnCallback(OnConnection);
client.SetMessageCallback(OnMessage);
loop.Run();
return 0;
}