#include #include #include #include #include using namespace trantor; #define USE_IPV6 0 int main() { LOG_DEBUG << "test start"; Logger::setLogLevel(Logger::kTrace); EventLoopThread loopThread; loopThread.run(); #if USE_IPV6 InetAddress addr(8888, true, true); #else InetAddress addr(8888); #endif TcpServer server(loopThread.getLoop(), addr, "test"); server.enableSSL("server.pem", "server.pem"); server.setRecvMessageCallback( [](const TcpConnectionPtr &connectionPtr, MsgBuffer *buffer) { // LOG_DEBUG<<"recv callback!"; std::cout << std::string(buffer->peek(), buffer->readableBytes()); connectionPtr->send(buffer->peek(), buffer->readableBytes()); buffer->retrieveAll(); connectionPtr->forceClose(); }); server.setConnectionCallback([](const TcpConnectionPtr &connPtr) { if (connPtr->connected()) { LOG_DEBUG << "New connection"; connPtr->send("Hello world\r\n"); } else if (connPtr->disconnected()) { LOG_DEBUG << "connection disconnected"; } }); server.setIoLoopNum(3); server.start(); loopThread.wait(); }