目录
环境:ubuntu 24.04
1. 更新系统包列表
首先,确保你的系统包列表是最新的。
sudo apt-get updatesudo apt-get upgrade
2. 安装必要的依赖项
Muduo依赖于一些基本的开发工具和库。安装这些依赖项:
sudo apt-get install -y git cmake g++ libboost-all-dev libssl-dev
3. 克隆Muduo的源码仓库
使用 git 克隆 Muduo 的源码。Muduo 的官方仓库托管在 GitHub 上。
git clone4. 创建构建目录并编译
进入 Muduo 源码目录,创建一个构建目录,并使用 CMake 进行编译。
cd muduomkdir buildcd buildcmake ..make5. 安装 Muduo(可选)
如果你希望将 Muduo 安装到系统目录,可以执行以下命令:
sudo make install默认情况下,Muduo 会被安装到
/usr/local目录下。如果需要自定义安装路径,可以在运行时指定CMAKE_INSTALL_PREFIX:cmake -DCMAKE_INSTALL_PREFIX=/your/custom/path ..makesudo make install6. 配置环境变量(如果需要)
如果你将 Muduo 安装到了自定义路径,可能需要将库路径添加到
LD_LIBRARY_PATH环境变量中。export LD_LIBRARY_PATH=/your/custom/path/lib:$LD_LIBRARY_PATH你可以将上述命令添加到或
~/.profile文件中,以便每次启动终端时自动设置。7. 验证安装
你可以编译并运行 Muduo 提供的示例程序,确保安装成功。
cd ../examplesmake./echo_server如果
echo_server启动成功并监听指定端口,说明 Muduo 安装成功。8. 编写自己的项目
在你的项目中使用 Muduo 时,需要在
CMakeLists.txt中添加相应的配置。例如:cmake_minimum_required(VERSION 3.10)project(MyMuduoApp)set(CMAKE_CXX_STANDARD 11)find_package(muduo REQUIRED)add_executable(MyMuduoApp main.cpp)target_link_libraries(MyMuduoApp muduo_net muduo_base pthread)确保中包含 Muduo 的头文件并使用其功能。
9.测试代码
把muduo库的头文件和lib库文件拷贝完成以后,使用muduo库编写一个简单的echo回显服务器,测试muduo库是否可以正常使用,代码如下:
#include#include #include #include // 使用muduo开发回显服务器class EchoServer{ public:EchoServer(muduo::net::EventLoop* loop,const muduo::net::InetAddress& listenAddr);void start();private:void onConnection(const muduo::net::TcpConnectionPtr& conn);void onMessage(const muduo::net::TcpConnectionPtr& conn,muduo::net::Buffer* buf,muduo::Timestamp time);muduo::net::TcpServer server_;};EchoServer::EchoServer(muduo::net::EventLoop* loop,const muduo::net::InetAddress& listenAddr): server_(loop, listenAddr, "EchoServer"){server_.setConnectionCallback(boost::bind(&EchoServer::onConnection, this, _1));server_.setMessageCallback(boost::bind(&EchoServer::onMessage, this, _1, _2, _3));}void EchoServer::start(){server_.start();}void EchoServer::onConnection(const muduo::net::TcpConnectionPtr& conn){LOG_INFO << "EchoServer - " << conn->peerAddress().toIpPort() << " -> "<< conn->localAddress().toIpPort() << " is "<< (conn->connected() ? "UP" : "DOWN");}void EchoServer::onMessage(const muduo::net::TcpConnectionPtr& conn,muduo::net::Buffer* buf,muduo::Timestamp time){// 接收到所有的消息,然后回显muduo::string msg(buf->retrieveAllAsString());LOG_INFO << conn->name() << " echo " << msg.size() << " bytes, "<< "data received at " << time.toString();conn->send(msg);}int main(){LOG_INFO << "pid = " << getpid();muduo::net::EventLoop loop;muduo::net::InetAddress listenAddr(8888);EchoServer server(&loop, listenAddr);server.start();loop.loop();} 使用g++进行编译,注意链接muduo和pthread的库文件,编译命令如下:
g++ main.cpp -lmuduo_net -lmuduo_base -lpthread -std=c++11编译链接完成,生成a.out可执行程序,上面的echo服务器监听8888端口,运行上面的a.out回显服务器如下:
darling@darling:~/桌面$ ./a.out20241221 06:50:24.057765Z 10774 INFOpid = 10774 - test.cpp:61等待客户端连接,可以打开一个新的shell命令行用netcat命令模拟客户端连接echo服务器进行功能测试,命令如下:
darling@darling:~$ nc 127.0.0.1 8888hello worldhello worldnihao anihao a常见问题及解决方案
Muduo 库常见接口
TcpServer类
TcpServer 类负责管理网络服务端的行为,包括启动服务器、设置网络连接的回调函数以及消息处理的回调函数。这样可以灵活地定义在不同网络事件发生时执行的具体操作,例如接受新连接、连接断开或数据接收等。
下面来认识一下 TcpServer 的主要接口:
typedef std::shared_ptrTcpConnectionPtr;typedef std::function ConnectionCallback;typedef std::function MessageCallback;class InetAddress : public muduo::copyable{ public: InetAddress(StringArg ip, uint16_t port, bool ipv6 = false);};class TcpServer : noncopyable{public:enum Option{kNoReusePort,kReusePort,}; TcpServer(EventLoop* loop,const InetAddress& listenAddr,const string& nameArg, Option option = kNoReusePort);void setThreadNum(int numThreads);void start();/// 当⼀个新连接建⽴成功的时候被调⽤void setConnectionCallback(const ConnectionCallback& cb){ connectionCallback_ = cb; }/// 消息的业务处理回调函数---这是收到新连接消息的时候被调⽤的函数void setMessageCallback(const MessageCallback& cb){ messageCallback_ = cb; }}; EventLoop类
EventLoop 类是事件循环的核心,负责启动和管理事件监控循环。通过这个循环,服务器可以非阻塞地监听和响应网络事件(如新的连接请求、数据到达等)。它还支持通过定时任务来调度将来某一时刻执行的任务,这对于需要定时检查或更新状态的应用非常有用。
class EventLoop{void loop();// 开始事件监控循环void quit();// 停止循环Timerld runAfter(delay, cb);// 定时任务};TcpConnection类
TcpConnection 类管理着每个网络连接的状态,提供发送数据、检查连接状态和关闭连接的功能。它的设计使得每个连接可以独立地处理其生命周期内的各种事件。
class TcpConnection{TcpClient(EventLoop* loop, const InetAddress& serverAddr, const string& nameArg);void send(std::string &msg);// 发送数据bool connected();// 当前连接是否连接正常void shutdown();// 关闭连接};TcpClient类
TcpClient 是 Muduo 库中用于处理 TCP 客户端连接的类,它通过 EventLoop 来监控和处理IO事件。用户可以使用 connect() 和 disconnect() 控制连接,并通过 setConnectionCallback() 和 setMessageCallback() 设置回调函数,处理连接状态的变更和消息的接收。
class TcpClient : noncopyable{public: // TcpClient(EventLoop* loop); // TcpClient(EventLoop* loop, const string& host, uint16_t port);TcpClient(EventLoop* loop,const InetAddress& serverAddr,const string& nameArg); ~TcpClient(); // Force out-line dtor, for std::unique_ptr members. void connect();//连接服务器void disconnect();//关闭连接void stop(); //获取客⼾端对应的通信连接Connection对象的接⼝,发起connect后,有可能还没有连接建⽴成功TcpConnectionPtr connection() const{MutexLockGuard lock(mutex_);return connection_;}/// 连接服务器成功时的回调函数void setConnectionCallback(ConnectionCallback cb) { connectionCallback_ = std::move(cb); } /// 收到服务器发送的消息时的回调函数void setMessageCallback(MessageCallback cb){ messageCallback_ = std::move(cb); }private: EventLoop* loop_; ConnectionCallback connectionCallback_; MessageCallback messageCallback_;writeCompleteCallback writeCompleteCallback_;TcpConnectionPtr connection_ GUARDED_BY(mutex_);};/*需要注意的是,因为muduo库不管是服务端还是客⼾端都是异步操作,对于客⼾端来说如果我们在连接还没有完全建⽴成功的时候发送数据,这是不被允许的。因此我们可以使⽤内置的CountDownLatch类进⾏同步控制*/class CountDownLatch : noncopyable{public:explicit CountDownLatch(int count); void wait(){MutexLockGuard lock(mutex_);while (count_ > 0){condition_.wait();}}void countDown(){ MutexLockGuard lock(mutex_);--count_;if (count_ == 0){condition_.notifyAll();}}int getCount() const;private:mutable MutexLock mutex_;Condition condition_ GUARDED_BY(mutex_);int count_ GUARDED_BY(mutex_);}Buffer类
Buffer 类用于高效地管理数据缓冲区。它提供一系列操作来读取和处理存储在缓冲区中的数据,支持网络字节序的转换和数据的基本处理,如读取、检索和删除操作。这是处理TCP流数据的关键部分,因为网络数据可以随机到达,并且可能需要积累足够的数据才能进行处理。
class Buffer{size_t readableBytes() const;// 获取缓冲区大小const char* peek() const;// 获取缓冲区中数据的起始地址int32_t peekInt32() const;// 尝试从缓冲区获取4字节数据,进行网络字节序转换为整型,但不从缓冲区删除void retrieveInt32();// 数据读取位置向后偏移4字节(本质就是删除起始位置的4字节数据)int32_t readInt32();string retrieveAllAsString();// 从缓冲区取出所有数据并删除,以string形式返回string retrieveAsString(size_t len);// 从缓冲区读取len长度的数据并删除,以string形式返回};以上就是在 Ubuntu 上安装 Muduo 网络库的详细指南的详细内容,更多相关资料请阅读主机测评网其它文章!















发表评论