共计 1197 个字符，预计需要花费 3 分钟才能阅读完成。

自动写代码机器人，免费开通

本篇文章给大家分享的是有关 MongoDB 中怎么处理 Mongos 请求，丸趣 TV 小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着丸趣 TV 小编一起来看看吧。

TransportLayer 接收到新连接后，会创建专门的 conn 线程负责处理该连接的后续所有请求，具体逻辑在 ServiceEntryPointMongos 类的_sessionloop 函数中，根据请求的类型循环“收包，处理，回响应”三个步骤，总结状态机转换关系如下：

具体到 Process 业务处理里面，会进一步区分消息类型并走不同处理逻辑，主要分为：查询类（queryop/getmore）, 更新类（insert/update/delete），killcursors，以及其他 ClientCommand 这几种类型。

这几类命令的前半段处理流程基本类似，包括鉴权，语法判断，根据分区视图查找本次操作涉及哪些 shardserver，以及错误重试机制。后半段则和具体业务逻辑相关，存在较大差异。

查询请求处理逻辑

因为是 Sharding 集群模式下的查询，根据查询条件的不同，可能会涉及到多个 Shard Server 的数据，根据分区视图确认涉及的 Shard Server 后，针对每个 ShardServer 生成一个查询任务交由 TaskExecutorPool 执行。TaskExecutorPool 负责维护 mongos 到 ShardServer 的长连接，并包含一个 network 线程池负责执行和 ShardServer 的网络交互。

Conn 线程将查询任务交由 TaskExecutorPool 任务队列后，会 wait 到信号量上阻塞等待，TaskExecutorPool 里的 network 线程完成查询请求后，唤醒 Conn 线程进一步处理查询结果。

Mongos 为每一个 Shard Server 维护一个查询结果缓存队列，并按照 Merge、Skip、Limit、RemoveSortKey 的顺序对查询结果进行逐级处理后返回。其中 Merge 操作负责合并来自多个 Shard Server 的查询结果，根据查询条件是否要求排序有不同的处理逻辑：

需要排序：根据 SortKey 在多个队列中找排最前面的，保证全局有序返回，缓存结果处理完了就触发到对应 ShardServer 查询数据；

不需要排序：一个 Shard Server 查询结果返回完了再返回下一个 ShardServer 的查询结果；

Mongos 还会为每次查询创建一个 ClusterCursor，并维护和每个远程 Shard Server 游标的对应关系，用于后续 getmore 操作进一步获取数据。

以上就是 MongoDB 中怎么处理 Mongos 请求，丸趣 TV 小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注丸趣 TV 行业资讯频道。