SpringBoot 整合 Elasticsearch 实现海量级数据搜索( 四 ) _小知识

批量添加文档

@RunWith(SpringJUnit4ClassRunner.class)@SpringBootTest(classes = ElasticSearchApplication.class)public class DocJunit {@Autowiredprivate RestHighLevelClient client;/*** 批量添加文档* @throws IOException*/@Testpublic void batchAddDocument() throws IOException {// 批量请求BulkRequest bulkRequest = new BulkRequest();bulkRequest.timeout(TimeValue.timeValueSeconds(10));// 创建对象List<UserDocument> userArrayList = new ArrayList<>();userArrayList.add(new UserDocument("张三", "男", 30, "武汉"));userArrayList.add(new UserDocument("里斯", "女", 31, "北京"));userArrayList.add(new UserDocument("王五", "男", 32, "武汉"));userArrayList.add(new UserDocument("赵六", "女", 33, "长沙"));userArrayList.add(new UserDocument("七七", "男", 34, "武汉"));// 添加请求for (int i = 0; i < userArrayList.size(); i++) {userArrayList.get(i).setId(String.valueOf(i));IndexRequest indexRequest = new IndexRequest();// 外层参数indexRequest.id(String.valueOf(i));indexRequest.index("cs_index");indexRequest.type("_doc");indexRequest.timeout(TimeValue.timeValueSeconds(1));indexRequest.source(JSON.toJSONString(userArrayList.get(i)), XContentType.JSON);bulkRequest.add(indexRequest);}// 执行请求BulkResponse response = client.bulk(bulkRequest, RequestOptions.DEFAULT);System.out.println(response.status());}}

三、小结本文主要围绕 SpringBoot 整合 ElasticSearch 接受数据的插入和搜索使用技巧，在实际的使用过程中，版本号尤其的重要，不同版本的 es ，对应的 api 是不一样的。

原文链接：
https://mp.weixin.qq.com/s?__biz=Mzg2NzYyNjQzNg==&mid=2247498620&idx=1&sn=670a1e52b082adf7d54cd239915af8cf&utm_source=tuicool&utm_medium=referral

【SpringBoot 整合 Elasticsearch 实现海量级数据搜索】