站内推广方式有哪些,协会建设网站的目的,中国互联网协会电话多少,宣讲网站建设目录 基于muduo的客户端服务器编程 muduo只能装在linux中#xff0c;依赖boost库 客户端并不需要高并发 基于muduo的客户端服务器编程
支持epoll线程池#xff0c;muduo封装了线程池 而且还有完善的日志系统 使用muduo库代码非常固定#xff0c;基本就只有chatserver的类名… 目录 基于muduo的客户端服务器编程 muduo只能装在linux中依赖boost库 客户端并不需要高并发 基于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,//IPPortconst 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 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)//接收到数据的时间信息{string bufbuffer-retrieveAllAsString();coutrecv data:buftime:time.toString()endl;conn-send(buf);}TcpServer _server;//1.定义一个server对象这是第一步EventLoop *_loop;
};int main()
{EventLoop loop;//epoll,特别像创建了epollInetAddress 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_netl跟库名称 用一个客户端去连接他发现连上了 在客户端中发送helloworld ctrl]显示telnet输入quit退出客户端 vscode中配置命令所需要依赖的库方便输出代码最好在linux
