为了在Spring Boot应用程序中使用Spring Data Elasticsearch，需引入相应的Maven依赖项

Bol5261

已于 2025-01-18 22:54:25 修改

阅读量359

点赞数

于 2020-05-27 01:21:45 首次发布

本文链接：https://blog.csdn.net/blog_programb/article/details/106369431

版权

Spring cloud(as vast as cloud) 同时被 3 个专栏收录

2133 篇文章

订阅专栏

Sql(SQL Server Database)

477 篇文章

订阅专栏

NoSQL(Not Only SQL)

88 篇文章

订阅专栏

如何监控 Elasticsearch 集群的健康状态

使用内置 API 进行健康检查

Elasticsearch 提供了多种内置API来帮助管理员了解集群的整体健康状况。通过_cluster/health端点，可以获得关于集群健康的概览信息。

GET /_cluster/health?pretty=true

此命令返回的数据结构中包含了诸如status字段，它能指示当前集群的状态——绿色表示一切正常；黄色意味着虽然所有数据都可用但是存在未分配的副本分片；红色则表明有主分片未能成功分配，这可能会影响某些索引操作的成功执行。

实施资源级别监控

除了利用官方提供的工具外，还应该关注底层硬件资源的表现情况。对于承载Elasticsearch实例的服务器而言，CPU利用率、内存消耗以及I/O读写速度都是重要的考量因素之一。这些基础层面的信息能够揭示潜在瓶颈所在之处并提前预警可能出现的问题。

设置自定义告警规则

基于上述提到的各种度量标准设定合理的阈值范围，并据此触发相应的通知机制是非常必要的。当任何一项关键性能指标偏离预期水平时，及时收到警告可以帮助运维人员迅速做出反应，从而减少故障时间窗口内的损失风险。例如，在Kibana界面内创建Watchers对象实现自动化报警流程。

定期审查日志文件

最后但同样重要的是定期查看由各个节点产生的日志记录。它们不仅记载着日常运作期间发生的各类事件详情，而且往往隐藏着许多有关系统内部行为模式变化的重要线索。借助Logstash或者其他类似的解析引擎处理海量的日志条目，从中挖掘有价值的情报用于改进现有策略或是排查疑难杂症。

分配Elasticsearch集群内不同节点角色的最佳实践

节点类型的概述

在Elasticsearch集群中，存在多种类型的节点，每种节点承担不同的职责。主要的节点类型包括主节点（Master Node）、数据节点（Data Node）、摄取节点（Ingest Node）以及客户端节点（Client Node）。合理分配这些节点的角色对于优化性能至关重要。

主节点配置建议

为了提高系统的稳定性和容错能力，推荐设置专用的主节点来处理集群状态管理和其他协调工作。理想情况下，应该有三个以上的奇数个主选举合格节点以确保高可用性。

数据节点规划指导

当涉及到存储索引的数据时，应专门指定某些节点作为数据节点。考虑到资源消耗较大，特别是内存和磁盘I/O方面的要求，在硬件资源配置上要给予充分重视。如果面临大量写入操作，则可以考虑增加副本数量并启用刷新间隔调整功能；而对于读多于写的场景来说，可以通过预加载缓存机制提升查询效率。

摄取节点的应用场合

针对需要执行复杂文档转换或解析任务的情况，可引入摄取节点来进行前置处理后再转发给其他成员保存。这有助于减轻核心组件的工作负担，并实现更灵活的任务调度策略。

客户端节点的作用范围

虽然现代版本已经不再强制区分这种概念，但在大规模部署环境中仍然可以选择保留少量轻量级实例充当网关入口，负责接收外部请求并将它们分发至合适的内部目标地址完成后续动作。

{
  "node": {
    "master": true,
    "data": false,
    "ingest": false
  }
}

上述JSON片段展示了如何通过修改elasticsearch.yml文件中的参数定义特定类型的节点属性。例如这里创建了一个仅具备成为主节点资格而不参与实际数据存储和服务请求响应过程的新机器加入到现有网络当中去。

关键点概述

在分布式环境中部署多个Elasticsearch实例时，需关注集群的设计、配置以及运维中的各种细节。为了确保系统的稳定性和高效运行，在规划阶段就要考虑硬件资源分配、网络拓扑结构等因素。

集群设计考量因素

对于Elasticsearch集群而言，合理的架构设计至关重要。这涉及到节点角色划分（如主节点、数据节点）、副本数量设定、分片大小调整等方面；同时也要评估预期的数据吞吐量和服务请求模式来决定初始规模和后续扩展策略。

安全措施实施

考虑到安全性问题，在设置访问控制列表(Access Control List, ACL)，启用SSL/TLS加密通信的同时，还应该定期审查日志文件并及时更新软件版本以修复已知漏洞。

性能调优建议

针对不同应用场景下的特殊需求，可以通过修改JVM参数、优化索引映射定义等方式提高查询效率降低延迟时间。另外就是监控系统健康状态指标比如CPU利用率、内存占用率等，并据此做出相应调整。

故障转移机制建立

当某个成员意外离线时能够迅速切换至备用方案从而不影响整体服务连续性非常重要。因此要提前做好灾难恢复预案演练工作，包括但不限于冷热分离架构的应用、快照备份制度的确立等等。

curl -X PUT "localhost:9200/_cluster/settings" -H 'Content-Type: application/json' -d'
{
  "persistent": {
    "discovery.zen.minimum_master_nodes": 2,
    "gateway.recover_after_nodes": 3
  }
}'

上述命令用于设置最小master选举数为2，确保即使有一个master节点失效也能正常选出新的leader继续提供服务；而recover_after_nodes则指定了达到多少个节点后开始尝试从网关恢复集群的状态。

**### Spring Data Elasticsearch Access Driver 使用教程

项目依赖配置

为了在Spring Boot应用程序中使用Spring Data Elasticsearch，需引入相应的Maven依赖项。具体来说，在pom.xml文件内添加如下片段来声明对spring-boot-starter-data-elasticsearch的支持。

<dependencies>
    <!--Spring Data Elasticsearch (Access+Driver)-->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>
</dependencies>

实体类定义

实体对象映射至Elasticsearch中的文档结构时，通常会应用到@Document注解用于指定索引名称以及设置副本数量、分片数目等属性。下面是一个简单的Java Bean实例：

import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;

@Document(indexName = "users", shards = 1, replicas = 0)
public class User {
    
    @Id
    private String id;
    private String name;
    private int age;

    // Getters and Setters...
}

此段代码展示了如何通过@Document注解为名为“users”的索引创建模型，并指定了单一分片无副本来存储用户信息的数据表样式的实体类。

数据访问层实现

借助于Spring Data提供的Repository接口可以轻松完成CRUD操作而无需编写具体的实现逻辑。只需继承自特定类型的仓库接口即可获得基本功能支持。例如针对上述User实体可构建如下形式的仓储服务：

import org.springframework.data.repository.CrudRepository;

public interface UserRepository extends CrudRepository<User, String> {}

这样就自动获得了诸如保存(save)、删除(deleteById)、查找全部记录(findAll)等一系列方法供调用方按需选用。

配置连接客户端

为了让程序能够成功连通远程ES集群并执行命令请求，则还需要适当调整application.properties或yml格式的应用配置文件内容以适应实际环境需求。比如设定节点地址列表、认证凭证等相关参数以便建立稳定可靠的网络通信链路。

spring:
  elasticsearch:
    rest:
      uris: http://localhost:9200
      username: elastic
      password: changeme

以上就是关于利用Spring Data框架下的Elasticsearch模块来进行数据存取交互的主要知识点介绍。希望这些资料能帮助读者快速入门掌握这项技术要点。**

Getting Started

Reference Documentation

For further reference, please consider the following sections:

Guides

The following guides illustrate how to use some features concretely:

/*
 * Copyright 2007-present the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      https://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
import java.net.*;
import java.io.*;
import java.nio.channels.*;
import java.util.Properties;

public class MavenWrapperDownloader {

    private static final String WRAPPER_VERSION = "0.5.6";
    /**
     * Default URL to download the maven-wrapper.jar from, if no 'downloadUrl' is provided.
     */
    private static final String DEFAULT_DOWNLOAD_URL = "https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/"
        + WRAPPER_VERSION + "/maven-wrapper-" + WRAPPER_VERSION + ".jar";

    /**
     * Path to the maven-wrapper.properties file, which might contain a downloadUrl property to
     * use instead of the default one.
     */
    private static final String MAVEN_WRAPPER_PROPERTIES_PATH =
            ".mvn/wrapper/maven-wrapper.properties";

    /**
     * Path where the maven-wrapper.jar will be saved to.
     */
    private static final String MAVEN_WRAPPER_JAR_PATH =
            ".mvn/wrapper/maven-wrapper.jar";

    /**
     * Name of the property which should be used to override the default download url for the wrapper.
     */
    private static final String PROPERTY_NAME_WRAPPER_URL = "wrapperUrl";

    public static void main(String args[]) {
        System.out.println("- Downloader started");
        File baseDirectory = new File(args[0]);
        System.out.println("- Using base directory: " + baseDirectory.getAbsolutePath());

        // If the maven-wrapper.properties exists, read it and check if it contains a custom
        // wrapperUrl parameter.
        File mavenWrapperPropertyFile = new File(baseDirectory, MAVEN_WRAPPER_PROPERTIES_PATH);
        String url = DEFAULT_DOWNLOAD_URL;
        if(mavenWrapperPropertyFile.exists()) {
            FileInputStream mavenWrapperPropertyFileInputStream = null;
            try {
                mavenWrapperPropertyFileInputStream = new FileInputStream(mavenWrapperPropertyFile);
                Properties mavenWrapperProperties = new Properties();
                mavenWrapperProperties.load(mavenWrapperPropertyFileInputStream);
                url = mavenWrapperProperties.getProperty(PROPERTY_NAME_WRAPPER_URL, url);
            } catch (IOException e) {
                System.out.println("- ERROR loading '" + MAVEN_WRAPPER_PROPERTIES_PATH + "'");
            } finally {
                try {
                    if(mavenWrapperPropertyFileInputStream != null) {
                        mavenWrapperPropertyFileInputStream.close();
                    }
                } catch (IOException e) {
                    // Ignore ...
                }
            }
        }
        System.out.println("- Downloading from: " + url);

        File outputFile = new File(baseDirectory.getAbsolutePath(), MAVEN_WRAPPER_JAR_PATH);
        if(!outputFile.getParentFile().exists()) {
            if(!outputFile.getParentFile().mkdirs()) {
                System.out.println(
                        "- ERROR creating output directory '" + outputFile.getParentFile().getAbsolutePath() + "'");
            }
        }
        System.out.println("- Downloading to: " + outputFile.getAbsolutePath());
        try {
            downloadFileFromURL(url, outputFile);
            System.out.println("Done");
            System.exit(0);
        } catch (Throwable e) {
            System.out.println("- Error downloading");
            e.printStackTrace();
            System.exit(1);
        }
    }

    private static void downloadFileFromURL(String urlString, File destination) throws Exception {
        if (System.getenv("MVNW_USERNAME") != null && System.getenv("MVNW_PASSWORD") != null) {
            String username = System.getenv("MVNW_USERNAME");
            char[] password = System.getenv("MVNW_PASSWORD").toCharArray();
            Authenticator.setDefault(new Authenticator() {
                @Override
                protected PasswordAuthentication getPasswordAuthentication() {
                    return new PasswordAuthentication(username, password);
                }
            });
        }
        URL website = new URL(urlString);
        ReadableByteChannel rbc;
        rbc = Channels.newChannel(website.openStream());
        FileOutputStream fos = new FileOutputStream(destination);
        fos.getChannel().transferFrom(rbc, 0, Long.MAX_VALUE);
        fos.close();
        rbc.close();
    }

}

distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.6.3/apache-maven-3.6.3-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/io/takari/maven-wrapper/0.5.6/maven-wrapper-0.5.6.jar

package com.example.demo;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DemoApplication {

	public static void main(String[] args) {
		SpringApplication.run(DemoApplication.class, args);
	}

}

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
	<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>2.3.0.RELEASE</version>
		<relativePath/> <!-- lookup parent from repository -->
	</parent>
	<groupId>com.example</groupId>
	<artifactId>demo</artifactId>
	<version>0.0.1-SNAPSHOT</version>
	<name>demo</name>
	<description>Demo project for Spring Boot</description>

	<properties>
		<java.version>1.8</java.version>
	</properties>

	<dependencies>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-mongodb</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-redis</artifactId>
		</dependency>
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-data-redis-reactive</artifactId>
		</dependency>

		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
			<exclusions>
				<exclusion>
					<groupId>org.junit.vintage</groupId>
					<artifactId>junit-vintage-engine</artifactId>
				</exclusion>
			</exclusions>
		</dependency>
		<dependency>
			<groupId>io.projectreactor</groupId>
			<artifactId>reactor-test</artifactId>
			<scope>test</scope>
		</dependency>
	</dependencies>

	<build>
		<plugins>
			<plugin>
				<groupId>org.springframework.boot</groupId>
				<artifactId>spring-boot-maven-plugin</artifactId>
			</plugin>
		</plugins>
	</build>

</project>