486-手写C++muduo库(测试代码)

我会带着你远行 2022-09-08 15:57 203阅读 0赞

## testserver.cc ##

#include <mymuduo/TcpServer.h>
    #include <mymuduo/Logger.h>
    
    #include <string>
    #include <functional>
    
    class EchoServer
    {
        
    public:
        EchoServer(EventLoop *loop,
                const InetAddress &addr, 
                const std::string &name)
            : server_(loop, addr, name)
            , loop_(loop)
        {
        
            //注册回调函数
            server_.setConnectionCallback(
                std::bind(&EchoServer::onConnection, this, std::placeholders::_1)
            );
    
            server_.setMessageCallback(
                std::bind(&EchoServer::onMessage, this,
                    std::placeholders::_1, std::placeholders::_2, std::placeholders::_3)
            );
    
            //设置合适的loop线程数量 loopthread
            server_.setThreadNum(3);
        }
        void start()
        {
        
            server_.start();
        }
    private:
        //连接建立或者断开的回调
        void onConnection(const TcpConnectionPtr &conn)
        {
        
            if (conn->connected())
            {
        
                LOG_INFO("Connection UP : %s", conn->peerAddress().toIpPort().c_str());
            }
            else
            {
        
                LOG_INFO("Connection DOWN : %s", conn->peerAddress().toIpPort().c_str());
            }
        }
    
        //可读写事件回调
        void onMessage(const TcpConnectionPtr &conn,
                    Buffer *buf,
                    Timestamp time)
        {
        
            std::string msg = buf->retrieveAllAsString();
            conn->send(msg);
            conn->shutdown(); // 写端   EPOLLHUP =》 closeCallback_
        }
    
        EventLoop *loop_;
        TcpServer server_;
    };
    
    int main()
    {
        
        EventLoop loop;
        InetAddress addr(8000);
        EchoServer server(&loop, addr, "EchoServer-01");//Acceptor non-blocking listenfd  create bind 
        server.start();//listen  loopthread  listenfd => acceptChannel => mainLoop =>
        loop.loop();//启动mainLoop的底层Poller
    
        return 0;
    }

## Makefile ##

testserver :
    	g++ -o testserver testserver.cc -lmymuduo -lpthread -g
    
    clean :
    	rm -f testserver

**执行make就OK了**  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/7424a2bbc03049b5892dd48d3f084b7d.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBALeael-azveWuhw_size_20_color_FFFFFF_t_70_g_se_x_16 1]: /images/20220829/f1d257a9254c467ea150d16775739c94.png