Java操作 elasticsearch 8.1，如何实现索引的重建？

2024-04-25 23:52
文章标签 java 实现 操作 elasticsearch 索引 8.1 重建

本文主要是介绍Java操作 elasticsearch 8.1，如何实现索引的重建？，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

🏆本文收录于「Bug调优」专栏，主要记录项目实战过程中的Bug之前因后果及提供真实有效的解决方案，希望能够助你一臂之力，帮你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！

问题描述

Java 操作 elasticsearch 8.1 实现 索引的重建 并且切换到新的别名 不要用elasticsearch-rest-high-level-client

如上问题有来自我自身项目开发，有的收集网站，有的来自读者，如有侵权，立马删除。

解决方案

  如下是上述问题的解决方案，仅供参考：

  在Java中操作Elasticsearch 8.1版本实现索引的重建并切换到新的别名，可以通过使用Elasticsearch的低级客户端（Low-Level REST Client）来完成。以下是实现这一过程的基本步骤：

  1. 创建新的索引：首先，你需要定义新的索引的映射（Mappings）和设置（Settings），并使用低级客户端创建这个索引。

  2. 索引数据：将数据索引到新的索引中。这可以通过批量请求（Bulk Request）来完成，以提高性能。

  3. 等待索引刷新：确保所有文档都被索引并且可见。

  4. 更新别名：一旦新索引中的数据准备就绪，你可以更新别名以指向新索引。

以下是使用Elasticsearch低级客户端实现索引重建的示例代码：

import org.elasticsearch.client.Request;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.Response;
import org.elasticsearch.client.RestClient;import java.io.IOException;
import java.util.Map;public class ElasticsearchIndexRebuild {private static final String HOST = "localhost";private static final int PORT = 9200;private static final String INDEX_NAME = "your_index";private static final String NEW_INDEX_NAME = "your_index_new";private static final String ALIAS_NAME = "your_alias";public static void main(String[] args) throws IOException {RestClient restClient = RestClient.builder(HOST, PORT).build();// Step 1: Create the new index with the desired mappings and settingsString mappingsAndSettings = "{\n" +"  mappings: {\n" +"    properties: {\n" +"      title: { type: text },\n" +"      date: { type: date }\n" +"    }\n" +"  }\n" +"}";Request createIndexRequest = new Request("PUT", "/" + NEW_INDEX_NAME);createIndexRequest.setJsonEntity(mappingsAndSettings);restClient.performRequest(createIndexRequest);// Step 2: Index data into the new index (this is just an example, you would use your data)// ...// Step 3: Wait for the index to be ready (not shown here)// Step 4: Update the alias to point to the new indexRequest updateAliasRequest = new Request("POST", "/_aliases");updateAliasRequest.setJsonEntity("{\n" +"  actions: [\n" +"    { add: { index: \"" + NEW_INDEX_NAME + "\", alias: \"" + ALIAS_NAME + "\" }},\n" +"    { remove: { index: \"" + INDEX_NAME + "\", alias: \"" + ALIAS_NAME + "\" }}\n" +"  ]\n" +"}");restClient.performRequest(updateAliasRequest);// Close the clientrestClient.close();}
}

  请注意，这里的代码只是一个示例，你需要根据自己的需求来调整索引的映射和设置，以及索引数据的具体逻辑。

  在执行别名更新时，我使用了批量操作（actions），它允许你在单个请求中添加和删除别名。这样，当别名切换完成后，旧的索引将不再通过别名可访问。

  在进行索引重建和别名切换时，请确保你的应用程序能够处理可能的停机时间，或者使用零停机时间的策略，如使用版本化别名或读写分离。

  此外，对于生产环境，建议在执行这些操作之前进行充分的测试，并确保有完整的数据备份。

  希望能够帮到有需要的你。

  PS：如若遇到采纳如下方案还是未解决的同学，希望不要抱怨&&急躁，毕竟影响因素众多，我写出来也是希望能够尽最大努力帮助到同类似问题的小伙伴，即把你未解决或者产生新Bug黏贴在评论区，我们大家一起来努力，一起帮你看看，可以不咯。

  若有对当前Bug有与如下提供的方法不一致，有个不情之请，希望你能把你的新思路或新方法分享到评论区，一起学习，目的就是帮助更多所需要的同学，正所谓「赠人玫瑰，手留余香」。

☀️写在最后

  ok，以上就是我这期的Bug修复内容啦，如果还想查找更多解决方案，你可以看看我专门收集Bug及提供解决方案的专栏「Bug调优」，都是实战中碰到的Bug，希望对你有所帮助。到此，咱们下期拜拜。

码字不易，如果这篇文章对你有所帮助，帮忙给bugj菌来个一键三连(关注、点赞、收藏) ，您的支持就是我坚持写作分享知识点传播技术的最大动力。

同时也推荐大家关注我的硬核公众号:「猿圈奇妙屋」 ；以第一手学习bug菌的首发干货，不仅能学习更多技术硬货，还可白嫖最新BAT大厂面试真题、4000G Pdf技术书籍、万份简历/PPT模板、技术文章Markdown文档等海量资料，你想要的我都有！

📣关于我

我是bug菌，CSDN | 掘金 | InfoQ | 51CTO | 华为云 | 阿里云 | 腾讯云 等社区博客专家，C站博客之星Top30，华为云2023年度十佳博主，掘金多年度人气作者Top40，51CTO年度博主Top12，掘金/InfoQ/51CTO等社区优质创作者；全网粉丝合计 20w+；硬核微信公众号「猿圈奇妙屋」，欢迎你的加入！免费白嫖最新BAT互联网公司面试真题、4000G PDF电子书籍、简历模板等海量资料，你想要的我都有，关键是你不来拿。

这篇关于Java操作 elasticsearch 8.1，如何实现索引的重建？的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/936146。

相关文章

C++对象布局及多态实现探索之内存布局（整理的很多链接）

C++对象布局及多态实现探索之内存布局（整理的很多链接）

本文通过观察对象的内存布局，跟踪函数调用的汇编代码。分析了C++对象内存的布局情况，虚函数的执行方式，以及虚继承，等等 文章链接：http://dev.yesky.com/254/2191254.shtml      论C/C++函数间动态内存的传递 (2005-07-30)   当你涉及到C/C++的核心编程的时候，你会无止境地与内存管理打交道。 文章链接：http://dev.yesky
阅读更多...
Java五子棋之坐标校正

Java五子棋之坐标校正

上篇针对了Java项目中的解构思维，在这篇内容中我们不妨从整体项目中拆解拿出一个非常重要的五子棋逻辑实现：坐标校正，我们如何使漫无目的鼠标点击变得有序化和可控化呢？ 目录 一、从鼠标监听到获取坐标 1.MouseListener和MouseAdapter 2.mousePressed方法 二、坐标校正的具体实现方法 1.关于fillOval方法 2.坐标获取 3.坐标转换 4.坐
阅读更多...
Spring Cloud：构建分布式系统的利器

Spring Cloud：构建分布式系统的利器

引言 在当今的云计算和微服务架构时代，构建高效、可靠的分布式系统成为软件开发的重要任务。Spring Cloud 提供了一套完整的解决方案，帮助开发者快速构建分布式系统中的一些常见模式（例如配置管理、服务发现、断路器等）。本文将探讨 Spring Cloud 的定义、核心组件、应用场景以及未来的发展趋势。 什么是 Spring Cloud Spring Cloud 是一个基于 Spring
阅读更多...
RedHat运维-Linux文本操作基础-AWK进阶

RedHat运维-Linux文本操作基础-AWK进阶

你不用整理，跟着敲一遍，有个印象，然后把它保存到本地，以后要用再去看，如果有了新东西，你自个再添加。这是我参考牛客上的shell编程专项题，只不过换成了问答的方式而已。不用背，就算是我自己亲自敲，我现在好多也记不住。 1. 输出nowcoder.txt文件第5行的内容 2. 输出nowcoder.txt文件第6行的内容 3. 输出nowcoder.txt文件第7行的内容 4. 输出nowcode
阅读更多...
Javascript高级程序设计(第四版)--学习记录之变量、内存

Javascript高级程序设计(第四版)--学习记录之变量、内存

原始值与引用值 原始值：简单的数据即基础数据类型，按值访问。 引用值：由多个值构成的对象即复杂数据类型，按引用访问。 动态属性 对于引用值而言，可以随时添加、修改和删除其属性和方法。 let person = new Object();person.name = 'Jason';person.age = 42;console.log(person.name,person.age);//'J
阅读更多...
java8的新特性之一（Java Lambda表达式）

java8的新特性之一（Java Lambda表达式）

1：Java8的新特性 Lambda 表达式： 允许以更简洁的方式表示匿名函数（或称为闭包）。可以将Lambda表达式作为参数传递给方法或赋值给函数式接口类型的变量。 Stream API： 提供了一种处理集合数据的流式处理方式，支持函数式编程风格。 允许以声明性方式处理数据集合（如List、Set等）。提供了一系列操作，如map、filter、reduce等，以支持复杂的查询和转
阅读更多...
Java面试八股之怎么通过Java程序判断JVM是32位还是64位

Java面试八股之怎么通过Java程序判断JVM是32位还是64位

怎么通过Java程序判断JVM是32位还是64位 可以通过Java程序内部检查系统属性来判断当前运行的JVM是32位还是64位。以下是一个简单的方法： public class JvmBitCheck {public static void main(String[] args) {String arch = System.getProperty("os.arch");String dataM
阅读更多...
详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

详细分析Springmvc中的@ModelAttribute基本知识（附Demo）

目录 前言1. 注解用法1.1 方法参数1.2 方法1.3 类 2. 注解场景2.1 表单参数2.2 AJAX请求2.3 文件上传 3. 实战4. 总结 前言 将请求参数绑定到模型对象上，或者在请求处理之前添加模型属性 可以在方法参数、方法或者类上使用 一般适用这几种场景： 表单处理：通过 @ModelAttribute 将表单数据绑定到模型对象上预处理逻辑：在请求处理之前
阅读更多...
eclipse运行springboot项目，找不到主类

eclipse运行springboot项目，找不到主类

解决办法尝试了很多种，下载sts压缩包行不通。最后解决办法如图： help--->Eclipse Marketplace--->Popular--->找到Spring Tools 3---->Installed。
阅读更多...
mysql索引四（组合索引）

mysql索引四（组合索引）

单列索引，即一个索引只包含单个列，一个表可以有多个单列索引，但这不是组合索引；组合索引，即一个索引包含多个列。 因为有事，下面内容全部转自：https://www.cnblogs.com/farmer-cabbage/p/5793589.html 为了形象地对比单列索引和组合索引，为表添加多个字段： 　　 CREATE TABLE mytable( ID INT NOT NULL, use
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2