MongoDB中怎么处理Mongos请求

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

创新互联主营五大连池网站建设的网络公司,主营网站建设方案,APP应用开发,五大连池h5小程序制作搭建,五大连池网站营销推广欢迎五大连池等地区企业咨询

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

MongoDB中怎么处理Mongos 请求

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

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

查询请求处理逻辑

MongoDB中怎么处理Mongos 请求

因为是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 请求，小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。

分享题目：MongoDB中怎么处理Mongos请求
分享URL：https://www.cdcxhl.com/article24/jddece.html

成都网站建设公司_创新互联，为您提供微信公众号、品牌网站制作、网站排名、App设计、软件开发、动态网站

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容