用ps设计一个个人网站模板,微信小程序怎么下载,教你如何建设网站,网站到期只续域名不续空间能打开吗一、muduo网络库主要提供了两个类#xff1a; TcpServer#xff1a;用于编写服务器程序 TcpClient#xff1a;用于编写客户端程序
二、三个重要的链接库#xff1a; libmuduo_net、libmuduo_base、libpthread
三、muduo库底层就是epoll线程池#xff0c;其好处是…一、muduo网络库主要提供了两个类 TcpServer用于编写服务器程序 TcpClient用于编写客户端程序
二、三个重要的链接库 libmuduo_net、libmuduo_base、libpthread
三、muduo库底层就是epoll线程池其好处是 可以将网络I/O代码和业务代码区分开用户只需关注业务网络的连接断开、读写事件的上报与监控交给muduo库
四、muduo库对外暴露两个业务接口 1.用户的连接与断开 2.用户的可读写事件
五、基于muduo网络库的服务器开发步骤 1.组合TcpServer对象 2.创建Eventloop事件循环对象的指针 3.明确Tcpserver构造函数需要什么参数输出Chatserver的构造函数 a.Tcpserver 主要提供两个回调函数setConnectionCallback与setMessageCallback b.在构造函数中定义回调函数在类中定义具体回调的函数的实现 4.在当前服务类的构造函数中注册处理连接的回调函数和处理读写事件的回调函数 5.设置合适的服务端线程数量muduo库会自己分配I/O线程和work线程
/*
muduo网络库主要提供了两个类TcpServer用于编写服务器程序
TcpClient用于编写客户端程序三个重要的链接库
libmuduo_net、libmuduo_base、libpthreadmuduo库底层就是epoll线程池其好处是
可以将网络I/O代码和业务代码区分开用户只需关注业务网络的连接断开、读写事件的上报与监控交给muduo库只暴露两个业务接口
1.用户的连接与断开
2.用户的可读写事件*/
#includemuduo/net/TcpServer.h
#includemuduo/net/EventLoop.h
#includefunctional// #bind
#includeiostream
#includestring
using namespace std;
using namespace muduo;
using namespace muduo::net;
using namespace placeholders;/*
基于muduo网络库的服务器开发
1.组合TcpServer对象
2.创建Eventloop事件循环对象的指针
3.明确Tcpserver构造函数需要什么参数输出Chatserver的构造函数a.Tcpserver 主要提供两个回调函数setConnectionCallback与setMessageCallbackb.在构造函数中定义回调函数在类中定义具体回调的函数的实现
4.在当前服务类的构造函数中注册处理连接的回调函数和处理读写事件的回调函数
5.设置合适的服务端线程数量muduo库会自己分配I/O线程和work线程*/
class ChatServer{
public://构造函数对TcpServer进行初始化TcpServer没有默认构造ChatServer(EventLoop *loop,//事件循环 reactorconst InetAddress listenAddr,//ip portconst string nameArg)// 线程/server的名称: _server(loop, listenAddr, nameArg), _loop(loop){//给服务器注册用户连接与断开的回调函数,当监听到连接/断开时执行onConnection具体如何监听到是网络库的事情无需用户操心_server.setConnectionCallback(std::bind(ChatServer::onConnection,this,_1));//相当于this.onConnection(TcpConnectionPtr)//给服务器注册用户读写事件的回调函数_server.setMessageCallback(std::bind(ChatServer::onMessage,this,_1,_2,_3));//设置服务器端的线程数量muduo库会自适应处理连接线程和工作线程的分配CPU核数一般等于线程数//1个I/O线程3个work线程_server.setThreadNum(4);}//开启事件循环void start(){_server.start();}private://专门处理用户的连接创建和断开相当于epoll中监听到listenfd后执行acceptvoid onConnection(const TcpConnectionPtr conn){if(conn-connected()){coutconn-peerAddress().toIpPort()-conn-localAddress().toIpPort()state: onlineendl;}else{coutconn-peerAddress().toIpPort()-conn-localAddress().toIpPort()state: offlineendl;conn-shutdown();//close(fd)}}//专门处理用户的读写事件void onMessage(const TcpConnectionPtr conn,//连接的共享指针Buffer *buffer,//缓冲区存放数据Timestamp time)//接收到数据的时间信息{//echo服务器string bufbuffer-retrieveAllAsString();coutrecv: buftime: time.toString()endl;conn-send(buf);}TcpServer _server;// #1EventLoop *_loop;// #2 看作epoll};int main(){EventLoop loop;//类似于创建epollInetAddress addr(127.0.0.1,6000);//本地回环地址服务器仅接受来自本机的连接。适合在开发阶段进行本地调试。ChatServer server(loop,addr,ChatServer);server.start();//epoll_ctllistenfd加入epollloop.loop();//类似于epoll_wait,以阻塞的方式等待新用户连接已连接用户的读写事件等return 0;
}
结果展示
