Language Translations:
- C++11 functional/bind style callback instead of C-style function pointer.
TCP
andUDP
wrapper.Timer
andTimerWheel
:Heartbeat timeout judgment with time complexity of O(1).Async
:libuv async wrapper,but optimized the problem of calling multiple times but callback will only be called once.Packet
andPacketBuffer
:Send and receive packet of Tcp data stream.- Log interface.
one thread 1k bytes ping-pong。
environment:Intel Core i5 6402 + ubuntu14.04.5 + gcc5.5.0 + libuv1.22.0 + O2优化
libuv_cpp | no use PacketBuffer | CycleBuffer | ListBuffer |
---|---|---|---|
Times/Sec | 192857 | 141487 | 12594 |
#include <iostream>
#include <uv/uv11.h>
int main(int argc, char** args)
{
//event's loop
//uv::EventLoop* loop = new uv::EventLoop();
//or
uv::EventLoop* loop = uv::EventLoop::DefalutLoop();
uv::SocketAddr serverAddr("127.0.0.1", 10000, uv::SocketAddr::Ipv4);
//Tcp Server
uv::TcpServer server(loop);
server.setMessageCallback(
[](uv::TcpConnectionPtr conn, const char* data , ssize_t size)
{
std::cout << std::string(data, size) << std::endl;
std::string str("hex :");
uv::LogWriter::ToHex(str, data, (unsigned int)size);
std::cout << str << std::endl;
conn->write(data, size,nullptr);
});
server.bindAndListen(serverAddr);
//Tcp Client
uv::TcpClient client(loop);
client.setConnectStatusCallback(
[&client](uv::TcpClient::ConnectStatus status)
{
if (status == uv::TcpClient::ConnectStatus::OnConnectSuccess)
{
char data[] = "hello world!";
client.write(data, sizeof(data));
}
else
{
std::cout << "Error : connect to server fail" << std::endl;
}
});
client.connect(serverAddr);
loop->run();
}