C++Muduo网络库：简介及使用 - IT评测·应用市场-qidao123.com技术社区

TcpServer(EventLoop* loop, //事件循环
const InetAddress& listenAddr, //绑定IP地址 + 端口号
const string& nameArg, //TcpServer服务器名字
Option option = kNoReusePort); //tcp协议选项

复制代码

void setConnectionCallback(const ConnectionCallback& cb) //链接的创建与断开
{ connectionCallback_ = cb; }
void setMessageCallback(const MessageCallback& cb) //消息读写事件
{ messageCallback_ = cb; }

复制代码

#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网络库开发服务器程序
class ChatServer
{
public:
//3、明确TcpServer构造函数需要的参数，输出服务器对应类的构造函数
ChatServer(EventLoop *loop, const InetAddress &listenAddr, const string &nameArg) //事件循环、IP+port、服务器名字
: _server(loop, listenAddr, nameArg), _loop(loop)
{
//4.1、注册用户连接的创建和断开事件的回调
_server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1)); //利用绑定器绑定成员方法onConnection,保持参数与muduo库函数参数一致
//4.2、注册用户读写事件的回调
_server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3)); //利用绑定器绑定成员方法onMessage,保持参数与muduo库函数参数一致
//5、设置服务器端的线程数量
_server.setThreadNum(4);
}
//6.开启事件循环
void start()
{
_server.start();
}
private:
//4.1 专门处理用户的连接和断开
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(); //连接断开将socket资源释放
//或者调用_loop->quit()退出epoll;
}
}
//4.2 专门处理用户读写事件
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、组合TcpServer对象
EventLoop *_loop; //2、创建EventLoop事件循环对象的指针
};
int main()
{
EventLoop loop; //epoll
InetAddress addr("127.0.0.1", 6000);
ChatServer server(&loop, addr, "ChatServer");
server.start(); //启动服务：listenfd通过epoll_ctl添加到epoll上
loop.loop(); //类似于epoll_wait以阻塞的方式等待新用户连接或处理已连接用户的读写事件
return 0;
}

复制代码