集群聊天服务器(3)muduo网络库

基于muduo的客户端服务器编程

支持epoll+线程池，muduo封装了线程池
而且还有完善的日志系统
使用muduo库代码非常固定，基本就只有chatserver的类名要改

/*
muduo网络库给用户提供了两个主要的类
TcpServer:用于编写服务器程序的
TcpClient:用于编写客户端程序

将epoll+线程池封装起来
好处：能够把网络io的代码和业务代码区分开
                         用户的连接和断开    用户的可读写事件

*/
#include <muduo/net/TcpServer.h>
#include <muduo/net/EventLoop.h>
#include <iostream>
#include <functional>
#include <string>
using namespace std;
using namespace muduo;
using namespace muduo::net;
using namespace placeholders;

/*基于muduo网络库开发服务器程序
1.组合TcpServer对象
2.创建EventLoop事件循环对象的指针
3.明确TcpServer构造函数需要什么参数
4.在当前服务器类的构造函数当中，注册处理连接的回调函数和处理读写事件的回调函数
5.设置合适的服务器线程数量，muduo库会自己分配I/O线程和worker线程
*/
class ChatServer
{
public:
    ChatServer(EventLoop* loop,//事件循环
            const InetAddress& listenAddr,//IP+Port
            const string& nameArg)//服务器的名字
        : _server(loop,listenAddr,nameArg), _loop(loop)
    {
        //给服务器注册用户连接的创建和断开回调
        _server.setConnectionCallback(std::bind(&ChatServer::onConnection,this,_1));
        //给服务器注册用户读写事件回调
        _server.setMessageCallback(std::bind(&ChatServer::onMessage,this,_1,_2,_3));
        
        //设置服务器端的线程数量  1个I/O线程 3个worker线程
        _server.setThreadNum(4);
    }

    //开启事件循环
    void start(){
        _server.start();
    }
private:
    //专门处理用户的连接创建和断开 epoll listenfd accept
    void onConnection(const TcpConnectionPtr &conn){
        if(conn->connected()){
            cout<<conn->peerAddress().toIpPort()<<"->"<<
            conn->localAddress().toIpPort()<<
            "state:online"<<endl;
        }else{
            cout<<conn->peerAddress().toIpPort()<<"->"<<
            conn->localAddress().toIpPort()<<
            "state:offline"<<endl;
            conn->shutdown();//close(fd)
        
        }
        
    }
    void onMessage(const TcpConnectionPtr &conn,//连接
                    Buffer *buffer,//缓冲区
                    Timestamp time)//接收到数据的时间信息
    {
        string buf=buffer->retrieveAllAsString();
        cout<<"recv data:"<<buf<<"time:"<<time.toString()<<endl;
        conn->send(buf);
    }
    TcpServer _server;//1.定义一个server对象，这是第一步
    EventLoop *_loop;
};

int main()
{
    EventLoop loop;//epoll,特别像创建了epoll
    InetAddress addr("127.0.0.1",6000);
    ChatServer server(&loop,addr,"ChatServer");

    server.start();//启动了服务：listenfd epoll_ctl添加到epoll上
    loop.loop();//相当于调用了epoll_wait以阻塞方式等待新用户连接，已连接用户的读写事件等

    return 0;
}

编译需要添加链接

g++ -o server muduo_server.cpp -lmuduo_net -lmuduo_base -lpthread

-lmuduo_net，l跟库名称

用一个客户端去连接他，发现连上了

在客户端中发送helloworld

ctrl+]，显示telnet，输入quit退出客户端

vscode中配置命令所需要依赖的库，方便输出代码，最好在linux