使用Java连接Elasticsearch数据库（验证用户/不验证用户）

最近用JAVA连接数据库，特别是在es上踩了很多坑，专门写一篇文章记录一下，这篇文章主要解决下面两个问题：

1.Elasticsearch数据库低级客户端Java Low Level REST Client连接es数据库

2.Elasticsearch数据库使用版本不匹配

首先来说说第一种问题。

因为想测试代码通用性，所以安装了两个es版本，一个为7.x，另一个为6.x版本。一开始我是使用高级客户端进行连接的，因为高级客户端功能比较多，后续也比较容易操作，但由于高级客户端对版本要求比较严格，所以后面选择使用兼容性更强的低级客户端RestClient。

然后就是校验问题，因为只要输入了ip地址和端口号，使用代码就可以构建客户端，所以我通过索引名来进行校验，确保自己真的连接上了es。下面直接上测试代码：

public class Test {public static void main(String[] args) {Test test=new Test();test.testConn();}/**连接es数据库**/public void testConn(){//1.构建没有用户名和密码的客户端RestClient restClient = RestClient.builder(new HttpHost("localhost", 9200, "http")).build();//2.构建有用户名和密码的客户端//设定用户名和密码final CredentialsProvider credentialsProvider = new BasicCredentialsProvider();credentialsProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials("user", "password"));RestClient restClient = RestClient.builder(new HttpHost("localhost", 9200, "http")).setHttpClientConfigCallback(httpClientBuilder -> httpClientBuilder.setDefaultCredentialsProvider(credentialsProvider)).build();//3.进行校验操作//查看索引中节点的信息，可以直接用GET方法得到String method = "GET";String endpoint = "/"+"indexName";Response response = null;try {Request request=new Request(method,endpoint);response = restClient.performRequest(request);System.out.println(response.toString());} catch (Exception e) {//抛出异常throw new RuntimeException("校验不成功", e);}}
}

控制台输出以下，代表连接成功：

至于第二种问题，不知道各位在测试连接的时候有没有遇到过以下报错（提示找不到这个方法）：

java.lang.NoSuchMethodError: org.elasticsearch.client.RestClient.performRequest(Ljava/lang/String;Ljava/lang/String;[Lorg/apache/http/Header;)Lorg/elasticsearch/client/Response

又或者是（参数无法识别）：

Elasticsearch exception [type=illegal_argument_exception, reason=request [/index索引名/_search] contain unrecognized parameter: [ignore_throttled]]

上面两种报错，都是版本不匹配问题。一是因为我们自己导入依赖时没有指定版本，二是spring集成es时都有默认的集成版本，如果搭建版本不匹配就会报错。所以解决这两个问题，首先是在依赖中指定es版本，然后再显式指定es版本（没错我两个都放进去了），我指定的版本是7.4.2：

<dependencies><dependency><groupId>org.elasticsearch</groupId><artifactId>elasticsearch</artifactId><version>7.4.2</version></dependency><dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-client</artifactId><version>7.4.2</version></dependency>
</dependencies>

在项目中显式指定：

<properties><elasticsearch.version>7.4.2</elasticsearch.version>
</properties>

问题到现在就解决结束了，有兴趣的可以看看es和spring对应版本，建议各位做好版本匹配，不然真的会浪费很多时间...TT

使用Java连接Elasticsearch数据库（验证用户/不验证用户）相关推荐

Java连接SQL数据库失败的分析思路
简单的说下java连接SQL数据库的步骤: 1. 首先要有一个jtds.jar数据库驱动包. 2. 可先在项目下新建一个Folder,取名为lib,把jtds驱动包放到lib文件夹下. 3. 在项目上 ...
qt mysql 注册码_QT连接Oracle数据库并实现登录验证的操作步骤
目的: 本文实现QT登录界面,输入账号和密码后,系统连接Oracle数据进行判断账号和密码(MD5加密)是否和数据库一致,如果一致则提示登录成功. 开发环境:Windows10+QT5.14.2+Or ...
java连接mysql数据库 R_Java连接Mysql数据库详细代码实例
这篇文章主要介绍了Java连接Mysql数据库详细代码实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下隔了一段时间没连过数据库,代码都忘记了,网 ...
从零开始的java连接sqlserver数据库教程
通过java连接sqlserver数据库教程使用的数据库是SQL Server 2008,实现利用java对数据库进行操作. 需要做的准备: SQL Server 2008.JDBC驱动包(sqlj ...
Java连接MySQL数据库的超级详细步骤（Windows）
1. 数据准备 1. 下载JDK 下载Java开发工具包JDK,下载地址:https://www.oracle.com/java/technologies/javase-jdk14-downloads ...
Java 连接 Access 数据库
测试代码如下: package com.songyanjun.util;import java.sql.*;/*** @描述: TODO java连接Access数据库 * * <p>* ...
java连接Hbase数据库
java连接Hbase数据库如果是是连接机群上的Hbase服务,需要提前将相关的几个xml文件存放在本地的编程目录下,否则开发端无法获取机群信息及授权: hdfs-site.xml core-sit ...
java连接Orcale数据库并查询、插入、删除数据
java连接Orcale数据库并查询.插入.删除数据 oci和thin是Oracle提供的两套Java访问Oracle数据库方式. thin是一种瘦客户端的连接方式 oci是一种胖客户端的连接方式 J ...
java linux mysql数据库_Linux Java连接MySQL数据库
Linux(Ubuntu平台)Java通过JDBC连接MySQL数据库,与Windows平台类似,步骤如下: 解压 jdbc: tar -zxvf mysql-connector-java-5.1.1 ...

使用Java连接Elasticsearch数据库（验证用户/不验证用户）

使用Java连接Elasticsearch数据库（验证用户/不验证用户）相关推荐

最新文章

热门文章