ElastischearchElastischearch bulk 请求源码

Posted 九师兄

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了ElastischearchElastischearch bulk 请求源码相关的知识，希望对你有一定的参考价值。

在这里插入图片描述

1.概述

转载 https://blog.csdn.net/sinat_33760891/article/details/74175981 想基于和这个看看es 7.8的源码，结果相差比较大，没看完

本文基于es 7.8 版本。

接收bulk请求->判断是否需要自动创建index->处理bulk请求（解析request->构建map->循环获取shardId->执行构建index）->写primary ->写replica

bulk请求由多个request的实例组成了一个BulkRequest,入口是org.elasticsearch.rest.action.bulk.RestBulkAction,一个请求会构建一个BulkRequest对象,BulkRequest.add方法会解析提交的文本。

处理路径：

RestBulkAction ->TransportBulkAction<

以上是关于ElastischearchElastischearch bulk 请求源码的主要内容，如果未能解决你的问题，请参考以下文章