muduo是一个基于事件驱动的非阻塞网络库,采用C++和Boost库编写。
(一)使用muduo编写echo回射服务器
在github上下载muduo源码,使用里面的
build.sh
完成编译,查看这个脚本,可以设置debug版本还是release版本,并指定生成路径:默认是release,生成的库和头文件在
${HOME}/build/release-install
目录下,因为muduo是静态链接的C++程序库,因此使用的时候需要指定头文件目录,和库文件目录,并链接相应的静态库文件(
-lmuduo_net -lmuduo_base
)。
echo回射服务器函数我们很熟悉,大体步骤是:
1.创建套接字 socket
2.绑定端口 bind
3.监听套接字 listen
4.阻塞等待客户端连接 accept
5.连接建立accept返回,阻塞等待客户端消息 recv
6.回射消息到客户端 write
基于事件的非阻塞网络编程,是编写高性能并发网络服务器的主流模式,使用这种方式首先要转变一下上述步骤中的思路:把原来的“主动调用recv来接收数据,主动调用accept来接收连接,主动调用send来发送数据”,换成“注册一个收数据的回调,网络库收到数据会调用我,直接把数据提供给我,供我消费;注册一个接收连接的回调,网络库接受了新连接会回调我,供我使用;需要发送数据的时候,只管往连接中写,网络库会负责无阻塞地发送。”
关于怎么去使用epoll轮询,怎么使用线程池分发任务等细节,待后续阅读源码后再仔细学习。首先学会使用muduo库编写一个回射服务器echo程序。
1.1 直接编写回调函数
// echo1/echo.cpp
#include <muduo/base/Logging.h>
#include <muduo/base/Timestamp.h>
#include <muduo/net/TcpServer.h>
#include <muduo/net/EventLoop.h>
#include <muduo/net/TcpConnection.h>
using namespace muduo;
using namespace muduo::net;
//accept的回调函数
void onConnection(const TcpConnectionPtr &conn)
{
LOG_INFO << "EchoServer - " << conn->peerAddress().toIpPort() << " -> "
<< conn->localAddress().toIpPort() << " is "
<< (conn->connected() ? "UP" : "DOWN");
}
//recv的回调函数
void onMessage(const TcpConnectionPtr &conn,
Buffer *buf,
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(int argc, const char *argv[])
{
EventLoop loop;
InetAddress addr("127.0.0.1", );//设置服务端IP/端口
TcpServer server(&loop, addr, "echo");
server.setConnectionCallback(&onConnection);//注册回调
server.setMessageCallback(&onMessage);//注册回调
server.start();
loop.loop();
return ;
}
1.2 面向对象的思路
另一个方法就是将回调函数的注册写到类的构造函数中,书中给出的示例如下:
// echo2/echoserver.h
#ifndef __ECHOSERVER_H__
#define __ECHOSERVER_H__
#include <muduo/net/TcpServer.h>
// RFC 862
class EchoServer
{
public:
EchoServer(muduo::net::EventLoop* loop,
const muduo::net::InetAddress& listenAddr);//构造函数
void start(); // calls server_.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_;
};
#endif
// echo2/echoserver.cpp
#include "echoserver.h"
#include <muduo/base/Logging.h>
#include <boost/bind.hpp>
// using namespace muduo;
// using namespace muduo::net;
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);
}
// echo2/echo2.cpp
#include "echoserver.h"
#include <muduo/base/Logging.h>
#include <muduo/net/EventLoop.h>
int main()
{
LOG_INFO << "pid = " << getpid();
muduo::net::EventLoop loop;
muduo::net::InetAddress listenAddr();
EchoServer server(&loop, listenAddr);
server.start();
loop.loop();
return ;
}
1.3 编写Makefile
muduo是静态链接的C++程序库,需要在Makefile文件中特别指明头文件和库文件路径等。
PROGS+=echo1 echo2
CLEANFILES = core core.* *.core *.o temp.* *.out typescript* \
*.lc *.lh *.bsdi *.sparc *.uw
MUDUO_DIRECTORY = ${HOME}/build/release-install
MUDUO_INCLUDE = $(MUDUO_DIRECTORY)/include
MUDUO_LIBRARY = $(MUDUO_DIRECTORY)/lib
OUTPUT=${PWD}/bin
all :${PROGS}
MAKE_BIN_DIR := $(shell mkdir -p $(OUTPUT) )
CXXFLAGS+=-g -std=c++ -I${MUDUO_INCLUDE}
LDFLAGS+=-L${MUDUO_LIBRARY} -lmuduo_net -lmuduo_base -lpthread -lrt
#所有的输出在bin目录下
echo1:echo1/echo.o
${CXX} ${CXXFLAGS} -o ${OUTPUT}/[email protected] $^ ${LDFLAGS}
@rm echo1/*.o
echo2: echo2/echo2.o echo2/echoserver.o
${CXX} ${CXXFLAGS} -o ${OUTPUT}/[email protected] $^ ${LDFLAGS}
@rm echo2/*.o
clean:
rm -rf ${OUTPUT}
.PHONY: all clean
1.4 测试回射服务器echo
本地运行,使用
netcat
进行测试:
nc localhost
服务器将回射键入的文本:
根据我们的回调函数,服务端也会有相应的信息:
(二)参考
1.《Linux多线程服务端编程 使用muduo C++网络库》
2.http://www.cnblogs.com/inevermore/p/4393309.html