当前位置: 首页 > news >正文

集群聊天服务器---muduo库使用(2)

书接上回

聊天服务器,这个类主要是用于处理网络连接和消息。

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();
}

上面是整个代码的核心,之后对其中两个最重要的回调函数:

    一个是用户连接的创建和断开回调

    一个用户读写事件回调。 

用户的连接创建和断开

// 专门处理用户的连接创建和断开 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)}
}

        该函数检查传入的 conn 对象是否处于连接状态(connected() 方法返回 true 表示连接状态)。

        如果连接,它将输出远端地址和端口号(peerAddress().toIpPort()),本地地址和端口号(localAddress().toIpPort()),以及状态 "state:online" 

        如果断开,它将输出相同的地址和端口号,但状态为 "state:offline" 

        它的输出:格式为:远端地址和端口 -> 本地地址和端口 状态:online/offline 

 

   peerAddress()localAddress() 分别返回连接的远端和本地的网络地址信息 

   toIpPort() 方法将地址信息转换为字符串格式,包括IP地址和端口号

处理用户读写事件

// 专门处理用户的读写事件
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
EventLoop *_loop;// #2 epoll

两个成员 

TcpServer _server;// #1
EventLoop *_loop;// #2 epoll

_server 是一个 TcpServer 类型的成员变量,用于管理TCP服务器的连接和通信

 _loop 是一个 EventLoop 类型的成员变量,用于处理事件循环。EventLoop 是muduo网络库中用于处理I/O事件的核心组件

而用到的一些细节:

    retrieveAllAsString() 方法从 buffer 中提取所有数据,并将其转换为字符串

           toString() 方法将 Timestamp 对象转换为字符串格式的时间信息

           send() 方法将数据发送回给客户端

 main函数

int main()
{EventLoop loop;  // epollInetAddress addr("127.0.0.1", 6000);ChatServer server(&loop, addr, "ChatServer");server.start();  // listenfd epoll_ctl_epollloop.loop();  // epoll_wait以阻塞方式等待新用户连接,已连接用户的读写事件等return 0;
}

        首先创建 EventLoop 对象EventLoop loop;:创建一个 EventLoop 对象,用于处理事件循环。

        创建 InetAddress 对象InetAddress addr("127.0.0.1", 6000);:创建一个 InetAddress 对象,指定服务器监听的本地IP地址为 127.0.0.1(即本机地址),端口号为 6000

        创建 ChatServer 对象ChatServer server(&loop, addr, "ChatServer");:创建一个 ChatServer 对象,传入 EventLoop 对象、InetAddress 对象和服务器名称 "ChatServer"

        启动服务器server.start();:调用 ChatServer 对象的 start 方法,启动服务器,开始监听指定的IP地址和端口,准备接受新用户的连接。

        启动事件循环loop.loop();:调用 EventLoop 对象的 loop 方法,启动事件循环。服务器将进入阻塞状态,等待新的用户连接和处理已连接用户的读写事件。

        返回值return 0;:程序正常结束,返回 0 表示成功。

最后是一开始的所有注释


综上 我们muduo网络库的代码就全部编写完成 


本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.dtcms.com/a/258339.html

相关文章:

  • 轻量级小程序自定义tabbar组件封装的实现与使用
  • 做上门私厨/上门做饭App小程序,到底是定制开发,还是选成品系统?
  • 域名 SSL证书和IP SSL证书有什么区别?
  • JVM堆(Heap)详解与工作流程分析
  • Dify与代理商奇墨科技为企业定制AI应用开发专属方案,适配多样化业务需求
  • 如何将短信从 Android 传输到计算机
  • Sentinel的流控策略
  • prometheus+grafana+Linux监控
  • RAG实战 第四章:RAG 检索增强技术与优化
  • Hive decimal类型详解
  • 技术解析:基于x264与FFmpeg的视频高效压缩策略——以小丸工具箱类GUI工具为例
  • vue.js 3: markmap using typescript
  • maven:迁移到 Maven Central 后 pom.xml的配置步骤
  • 【云计算】云测试
  • OSS跨区域复制灾备方案:华东1到华南1的数据同步与故障切换演练
  • Java模块打包格式与多版本JAR详解
  • 深度解析:2D写实数字人交互场景的创新与应用
  • IDC报告AR/VR市场反弹Meta份额超半,谷歌/微美全息精准卡位AR/AI眼镜市场机遇
  • Unity3D下的RTSP/RTMP超低延迟直播播放器实践:跨平台、高性能与VR全景支持的完整解析
  • 如何为虚拟机上的 Manjaro Linux启用 VMware 拖放功能
  • RAG实战 第三章:知识库构建与管理
  • Python与大数据:Spark和PySpark实战教程
  • STM32Cube 包结构解析
  • 创建型设计模式——单例模式
  • C++的单例模式
  • dify动手实践课6
  • 关于 Babel 编译后的 Generator 状态机结构解析
  • 数据赋能(319)——安全与合规——数据安全可控
  • 美团小程序闪购 mtgsig1.2
  • 第三节 布局与盒模型-盒模型与box-sizing