转载

Mongodb 请求处理流程

QQ群288567073

微信订阅号见文末二维码

荔枝FM手机客户端搜索“挨踢脱口秀”订阅即可

视频汇总首页： http://edu.51cto.com/lecturer/index/user_id-4626073.html

======================================

Mongodb多存储引擎支持机制介绍了Mongodb存储层创建数据库、创建集合、插入文档等数据库操作接口，本文将介绍mongodb处理客户端请求的模型。

Mongodb 请求处理流程

Mongod在启动时会调用createServer创建一个PortMessageServer对象，其继承MessageServer和Listener两个类，并依赖MyMessageHandler来处理请求。

class PortMessageServer: public MessageServer, public Listener { public:     void accepted(boost::shared_ptr psocket, long long connectionId );     void setupSockets();     void run(); private:    MessageHandler* _handler; };

PortMessageServer

调用setupSockets为mongod配置的每个地址创建一个socket，并调用bind绑定地址。
调用initAndListen监听所有的地址，调用select等待监听fd上发生连接事件，调用accept系统调用接受新的连接请求，并为每个新连接创建一个线程，该线程执行handleIncomingMsg方法，不断处理该连接上的客户端请求。

handleIncomingMsg

连接建立时，调用MyMessageHander::connected方法，初始化一个新的Client对象，Client对象包含DB操作的上下文。
不断调用recv从连接上读取请求，当读取到一个完整请求时，其将请求反序列化为一个Message对象，并调用MyMessageHandler::process方法处理请求，处理完后给客户端发送应答。
连接断开时，调用MyMessageHander::disconnected方法停止该连接对应的线程，释放Client对象。