个人毕设作品。。。。。。

目前初步完成。继续完善中。。。

使用时,需要确保TcpClient和TcpServer的生命周期至少在EvnetLoop::run()函数退出之后结束

特性

例子

Tcp Echo Server

#include"TcpServer.h"#include"NetFwd.h"usingnamespacenet;intmain(int argc,char* argv[]) {    InetAddressaddr("127.0.0.1",55555);    EventLoop loop;    TcpServerserver(&loop, addr,"TCPEchoServer",3);    server.set_message_cb([](const TCPConnPtr& conn, Buffer* msg) {        conn->send(msg);    });    server.set_connection_cb([](const TCPConnPtr & conn) {if (conn->is_connected()) {            LOG_INFO <<"A new connection from" << conn->get_peer_addr().toIpPort();        }else {            LOG_INFO <<"Lost the connection from" << conn->get_peer_addr().to_ip_port();        }    });    server.run();    loop.run();}

Tcp Echo Client

#include<iostream>#include<unistd.h>#include"TcpClient.h"#include"NetFwd.h"#include"Socket.h"#include<string>usingnamespacestd;usingnamespacenet;intmain() {    EventLoop loop;    TcpClientclient(&loop,InetAddress("127.0.0.1",55555),"ChatClient");    client.set_message_cb([](const TCPConnPtr& conn, Buffer* msg) {        LOG_INFO<<"receive:"<<msg->read_ptr();    });Socket::setNonBlockAndCloseOnExec(STDIN_FILENO);    impl::Event e{&loop,STDIN_FILENO};    e.set_read_cb([&client]{        string s;getline(cin,s);        client.connection()->send(s);    });    client.set_connection_cb([&e](const TCPConnPtr& conn) {if(conn->is_connected())            e.enable_read();else            e.disable_all();    });    client.set_message_cb([&e](const TCPConnPtr& conn,Buffer*msg) {        msg->append("\0",1);        LOG_INFO<<"receive:"<<msg->read_ptr();        msg->clear();    });    client.connect();    loop.run();}