提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 前言 批量写入到Elasticsearch会提高写入性能,减少Elasticsearch io压力。 一、Elasticsearch是什么? Elasticsearch是一个实时的分布式开放源代码全文本搜索和分析引擎。可从RESTful Web服务界面访问它,并使用无模式的JSON(JavaScript对象表示法)文档存储数据。它基于Java编程语言构建,因此Elasticsearch可以在不同平台上运行。它使用户能够以很高的速度浏览大量的数据。 二、实现步骤 BulkProcessor是一个线程安全的批量处理类,允许方便地设置每次写入ES的最大数量,以及超时时间。所谓超时时间,就是在规定的时间内,如果没有请求进来,就把之前累积的请求直接写到ES,不必等待请求数量累积到你规定的最大数量。 代码如下(示例): import org.elasticsearch.action.ActionRequest; import org.elasticsearch.action.DocWriteRequest; import...