欢迎来到尧图网

客户服务 关于我们

您的位置:首页 > 房产 > 建筑 > 聊天服务器(3)muduo网络库

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

2025/11/6 9:49:55 来源:https://blog.csdn.net/qq_43920838/article/details/143745234  浏览:    关键词:聊天服务器(3)muduo网络库

目录

  • 基于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,//IP+Portconst 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()){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,特别像创建了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_net,l跟库名称
在这里插入图片描述
用一个客户端去连接他,发现连上了
在这里插入图片描述
在客户端中发送helloworld
在这里插入图片描述
ctrl+],显示telnet,输入quit退出客户端
在这里插入图片描述
vscode中配置命令所需要依赖的库,方便输出代码,最好在linux
在这里插入图片描述

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com

热搜词