集群聊天服务器---muduo库的使用
使用 C++ 和 muduo 网络库来实现一个简单的聊天服务器和客户端。
服务器端：
class chatServer
{
public:// 初始化TcpServerchatServer(muduo::net::EventLoop *loop,const muduo::net::InetAddress &listenAddr): _server(loop, listenAddr, "chatServer"){// 通过绑定器设置回调函数_server.setConnectionCallback(bind(&chatServer::onConnection, this, _1));_server.setMessageCallback(bind(&chatServer::onMessage, this, _1, _2, _3));// 设置EventLoop的线程个数_server.setThreadNum(10);}// 启动ChatServer服务void start(){_server.start();}private:// TcpServer绑定的回调函数，当有新连接或连接中断时调用void onConnection(const muduo::net::TcpConnectionPtr &con);// TcpServer绑定的回调函数，当有新数据时调用void onMessage(const muduo::net::TcpConnectionPtr &con,muduo::net::Buffer *buf,muduo::Timestamp time);private:muduo::net::TcpServer _server;
};首先：构造函数中
初始化TcpServer对象_server，传入EventLoop，监听地址和服务器名称
设置连接和消息的回调函数，这些函数将在连接建立或者断开时调用，以及接受到新消息时调用
设置Eventloop的线程数为10 使用10个线程来处理网络事件
而start（）方法 是为了启用TcpServer，开始监听和接受连接
其中私有成员：
两个函数 分别是为了处理新连接或者连接断开的回调函数。一个是为了处理接收到的新消息的回调函数。
私有成员的变量：_server：是TcpServer对象，是用来管理网络连接和事件。
客户端：
class chatClient
{
public:chatClient(muduo::net::EventLoop *loop,const muduo::net::InetAddress &addr): _client(loop, addr, "chatClient"){// 设置客户端TCP连接回调接口_client.setConnectionCallback(bind(&chatClient::onConnection, this, _1));// 设置客户端接收数据回调接口_client.setMessageCallback(bind(&chatClient::onMessage, this, _1, _2, _3));}// 连接服务器void connect(){_client.connect();}private:// TcpClient绑定回调函数，当连接或者断开服务器时调用void onConnection(const muduo::net::TcpConnectionPtr &con);// TcpClient绑定回调函数，当有数据接收时调用void onMessage(const muduo::net::TcpConnectionPtr &con,muduo::net::Buffer *buf,muduo::Timestamp time);muduo::net::TcpClient _client;
};构造函数：
初始化 TcpClient 对象 _client，传入 EventLoop、服务器地址和客户端名称。
设置连接和消息的回调函数，这些函数将在连接建立或断开时调用，以及接收到新消息时调用。
connect（）的作用是启动客户端连接到服务器。
私有成员：
onConnection()：处理连接或断开服务器的回调函数。
onMessage()：处理接收到的新消息的回调函数。
_client：TcpClient 对象，用于管理与服务器的连接和数据传输。
网络服务器编程常用模型
-
方案1：accept + read/write
这不是并发服务器。每个连接都需要一个独立的线程或进程来处理，不适合高并发场景。 -
方案2：accept + fork - process-pre-connection
适合并发连接数不大，计算任务工作量大于fork的开销的场景。服务器接受连接后，通过fork创建子进程来处理每个连接。 -
方案3：accept + thread - thread-pre-connection
比方案2的开销小了一点，但是并发造成线程堆积过多。服务器接受连接后，为每个连接创建一个线程来处理。 -
方案4：muduo的网络设计：reactors in threads - one loop per thread
一个main reactor负责accept连接，然后把连接分发到某个sub reactor（采用round-robin的方式来选择sub reactor），该连接的所有操作都在那个sub reactor所在的线程中完成。多个连接可能被分派到多个线程中，以充分利用CPU。Reactor poll的大小是固定的，根据CPU的数目确定。 -
方案5：reactors in process - one loop pre process
类似于Nginx服务器的网络模块设计，基于进程设计，采用多个Reactors充当I/O进程和工作进程，通过一把accept锁，完美解决多个Reactors的“惊群现象”。
muduo中的reactor模型
Reactor模型是一种事件处理模式，用于处理并发的服务请求。它可以处理一个或多个输入源（one or more inputs），并通过服务处理器（Service Handler）将输入事件（Event）同步分发给相应的请求处理器（Request Handler）进行处理。
-
muduo网络库的模型
-
main Reactor负责监听新的连接请求，并将新用户连接分配给工作线程（工作线程中包含epoll）。 -
工作线程使用
epoll来处理已连接用户的读写事件。 -
对于耗时的I/O操作（如传送文件、音视频），可以单独开辟线程来处理，以避免阻塞主线程。
-
-
使用多个Reactors
-
mainReactor负责接受新的客户端连接，并将这些连接分发给subReactor。 -
每个
subReactor处理一部分客户端的读写、解码、计算、编码和发送操作。
-
void setConnectionCallback(const ConnectionCallback& cb)
{connectionCallback_ = cb;
}/// Set message callback.
/// Not thread safe.
void setMessageCallback(const MessageCallback& cb)
{messageCallback_ = cb;
}
class ChatServer
{
public:ChatServer(EventLoop *loop, // 事件循环const InetAddress &listenAddr, // IP+Portconst string &nameArg) // 服务器的名字: _server(loop, listenAddr, nameArg), _loop(loop){// 给服务器注册用户连接的创建和断开回调_server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1));// 给服务器注册用户读写事件回调}private:// 专门处理用户的连接创建和断开 epoll listenfd acceptvoid onConnection(const TcpConnectionPtr&){}TcpServer _server; // #1EventLoop *_loop; // #2 epoll
};
-
构造函数：
-
ChatServer类接受一个EventLoop指针、一个InetAddress对象（包含IP地址和端口号）和一个服务器名称。 -
使用这些参数初始化
TcpServer对象_server和一个EventLoop指针_loop。并注册连接回调函数onConnection。 -
注册连接回调函数
onConnection，当有新连接或连接断开时调用。
-
-
私有成员变量：
-
_server：TcpServer对象，用于管理网络连接和事件。 -
_loop：EventLoop指针，用于处理事件循环。
-
