Elasticsearch连续剧之实战篇Java操作es

news2025/2/23 23:54:36

作者：狮子也疯狂
专栏：《es》
坚持做好每一步，幸运之神自然会驾凌在你的身上

目录

  • 一、🐇前言
  • 二、🐇原生JAVA操作ES_搭建项目
    • Ⅰ、创建项目
    • Ⅱ、索引操作
      • 2.1 创建空索引
      • 2.2 给索引添加结构
      • 2.3 删除索引
    • Ⅲ、文档操作
      • 3.1 新增&修改文档
      • 3.2 根据id查询文档
      • 3.3 删除文档
    • Ⅳ、搜索操作
      • 4.1 搜索所有文档
      • 4.2 根据关键词搜索文档
  • 三、🐇总结

一、🐇前言

大家好！我是狮子，在上几篇文章中，详细介绍了在kibana中操作es，现在我们来看看真实开发中，如何使用Java操作es。

二、🐇原生JAVA操作ES_搭建项目

在这里插入图片描述
咱们先来了解一下，原生Java操作ES api接口，但是原生Java操作es的索引和文档太繁琐，我们只需要稍作了解。

Ⅰ、创建项目

我们先来创建一个普通Maven项目，并且引入以下依赖。

<dependencies>
    <dependency>
      <groupId>org.elasticsearch</groupId>
      <artifactId>elasticsearch</artifactId>
      <version>7.17.0</version>
    </dependency>
    <dependency>
      <groupId>org.elasticsearch.client</groupId>
      <artifactId>elasticsearch-resthigh-level-client</artifactId>
      <version>7.17.0</version>
    </dependency>
    <dependency>
      <groupId>junit</groupId>
      <artifactId>junit</artifactId>
      <version>4.12</version>
    </dependency>
</dependencies>

Ⅱ、索引操作

在原生Java操作es索引的时候，连接es的对象为RestHighLevelClient，其实就五步操作：
1.创建客户端对象，连接ES
2.创建请求对象
3.发送请求
4.操作响应结果
5.关闭客户端

2.1 创建空索引

// 创建空索引
@Test
public void createIndex() throws IOException{
    // 1.创建客户端对象，连接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.0.187", 9200, "http")));
    // 2.创建请求对象
    CreateIndexRequest request = new CreateIndexRequest("student");
    // 3.发送请求
        CreateIndexResponse response = client.indices()
        	.create(request,RequestOptions.DEFAULT);
    // 4.操作响应结果
  	 System.out.println(response.index());
  // 5.关闭客户端
 	 client.close();
}

tips：如果项目初次访问es失败，需要添加外部访问配置
打开Elasticsearch安装路径下config目录下的elasticsearch.yml文件，加入如下配置：

discovery.seed_hosts: ["host1"]
network.host: 0.0.0.0
重新启动ES即可。

2.2 给索引添加结构

@Test
public void mappingIndex() throws IOException {
    // 1.创建客户端对象，连接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.0.187", 9200, "http")));
    // 2.创建请求对象
    PutMappingRequest request = new PutMappingRequest("student");
   			 request.source("{\n" +
                   " \"properties\":{\n" +
                   " \"id\":{\n" +
                   " \"type\":\"integer\"\n" +
                   "   },\n" +
                   " \"name\":{\n" +
                   " \"type\":\"text\"\n" +
                   "   },\n" +
                   " \"age\":{\n" +
                   " \"type\":\"integer\"\n" +
                   "   }\n" +
                   " }\n" +
                   "}", XContentType.JSON);
    // 3.发送请求
      AcknowledgedResponse response = client.indices()
      		.putMapping(request,RequestOptions.DEFAULT);
    // 4.操作响应结果
  		System.out.println(response.isAcknowledged());
    // 5.关闭客户端
    client.close();
}

2.3 删除索引

// 删除索引
@Test
public void deleteIndex() throws IOException{
    // 1.创建客户端对象，连接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    	.builder(new HttpHost("192.168.0.187", 9200, "http")));
    // 2.创建请求对象
    DeleteIndexRequest request = new DeleteIndexRequest("student");
    // 3.发送请求
     AcknowledgedResponse response = client.indices()
     	.delete(request,RequestOptions.DEFAULT);
    // 4.操作响应结果  
	System.out.println(response.isAcknowledged(
));
    // 5.关闭客户端
    client.close();
}

Ⅲ、文档操作

在进行文档操作时，还是老套路，先创建客户端对象，连接es（和前面一样），但是请求对象创建不同，如果是新增或者修改文档，则请求IndexRequest对象，如果是根据id查询，则请求GetRequest,如果是删除，则创建DeleteRequest对象。

3.1 新增&修改文档

@Test
public void addDocument() throws IOException{
    // 1.创建客户端对象，连接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.0.187", 9200, "http")));
    // 2.创建请求对象
    IndexRequest request = new IndexRequest("student").id("1");
  	request.source(XContentFactory.jsonBuilder()
                   .startObject()
                   .field("id", 1)
                   .field("name", "i love conding")
                   .field("age", 20)
                   .endObject());
    // 3.发送请求
    IndexResponse response = client.index(request,RequestOptions.DEFAULT);
    // 4.操作响应结果
    System.out.println(response.status());
    // 5.关闭客户端
    client.close();
}

3.2 根据id查询文档

// 根据id查询文档
@Test
public void findByIdDocument() throws IOException {
    // 1.创建客户端对象，连接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.0.187", 9200, "http")));
    // 2.创建请求对象
    GetRequest request = new GetRequest("student", "1");
    // 3.发送请求
    GetResponse response = client.get(request, RequestOptions.DEFAULT);
    // 4.操作响应结果
	System.out.println(response.getSourceAsString());
    // 5.关闭客户端
    client.close();
}

3.3 删除文档

// 删除文档
@Test
public void DeleteDocument() throws IOException {
    // 1.创建客户端对象，连接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.0.187", 9200, "http")));
    // 2.创建请求对象
    DeleteRequest request = new DeleteRequest("student", "1");
    // 3.发送请求
    DeleteResponse response = client.delete(request,RequestOptions.DEFAULT);
    // 4.操作响应结果
    System.out.println(response.status());
    // 5.关闭客户端
    client.close();
}

Ⅳ、搜索操作

搜索操作是es的最主要的操作，刚开始的两步和前面一样，但是创建请求对象时，创建的是SearchRequest。使用不同的方法来操作索引。

4.1 搜索所有文档

@Test
public void queryAllDocument() throws IOException {
    // 创建客户端对象，链接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.1.58",9200,"http")));
    // 创建搜索条件
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
  	searchSourceBuilder.query(QueryBuilders.matchAllQuery());
    // 创建请求对象
    SearchRequest request = new SearchRequest("student").source(searchSourceBuilder);
    // 发送请求
     SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    // 输出返回结果
    for (SearchHit hit:response.getHits()) {
      System.out.println(hit.getSourceAsString());
   }
    // 关闭客户端
    client.close();
}

4.2 根据关键词搜索文档

@Test
public void queryTermDocument() throws IOException {
    // 创建客户端对象，链接ES
    RestHighLevelClient client = new RestHighLevelClient(RestClient
    		.builder(new HttpHost("192.168.1.58",9200,"http")));
    // 创建请求条件
    SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
    searchSourceBuilder.query(QueryBuilders.termQuery("info","boy"));
    // 创建请求对象
    SearchRequest request = new SearchRequest("student")
    		.source(searchSourceBuilder);
    // 发送请求
    SearchResponse response = client.search(request,RequestOptions.DEFAULT);
    // 输出返回结果
    for (SearchHit hit:response.getHits()) {
      System.out.println(hit.getSourceAsString());
   }
    // 关闭客户端
    client.close();
}

三、🐇总结

这个部分不难理解，就是搞清楚几个对象之前的作用，准确调用方法就好，咱们只需要了解以下用法，需要使用的时候，再查资料就行。但是真实开发中，一般都是使用框架封装好的对象（为咱么省略了好多繁琐步骤。）

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/189916.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

vCloud删除OVDC网络时提示被vApp网络使用无法删除

vCloud删除OVDC网络时提示被vApp网络使用无法删除

环境 VMware Cloud Director 版本:10.3.2.19375051 现象 在vCloud租户视图删除OVDC网络，提示被vApp网络使用，无法删除。此时通过查看vApp发现并没有残留vApp网络。 解决办法 1、登录vCloud数据库： 登录方法可以参考：VMware Cloud Director数据库操作 2、查逻辑网络： …
阅读更多...
CAN接口电路设计

CAN接口电路设计

CAN总线的全称是控制器局域网络&#xff0c;主要应用在汽车电子和工业控制领域。和485总线一样&#xff0c;CAN总线也是一种半双工的通信。一条CAN总线最多能接110个节点它最高速率能到1Mbps&#xff0c;最远传输距离能到10KMCAN总线有两个信号&#xff0c;一个是CANH&#xff…
阅读更多...
如何在 Linux 命令行中优雅的格式化输出 xml，记住这三种方法！

如何在 Linux 命令行中优雅的格式化输出 xml，记住这三种方法！

xml&#xff08;可扩展标记语言&#xff09;也是一种人类可读的标记语言&#xff0c;但是如同 json 文件一样&#xff0c;没有缩进格式&#xff08;或者压缩&#xff09;的 xml 文件&#xff0c;读起来那是挺头疼的。 首先来看一下我们这篇文章要达到的目的&#xff0c;如下图…
阅读更多...
代码随想录训练营第十七天|110.平衡二叉树 ● 257. 二叉树的所有路径 ● 404.左叶子之和

代码随想录训练营第十七天|110.平衡二叉树 ● 257. 二叉树的所有路径 ● 404.左叶子之和

110.平衡二叉树 看完题后的思路 int[] f(root)if rootnull return [true,0]left[]f(root.left) if(!left[0]){return [false,-1]} right[]f(root.right) if(!right[0]){return [false,-1]} return[true,math.max(left[1],right[1])1] 思路 上面的过程弄复杂了&#xff0c;其…
阅读更多...
Elasticsearch 入门到精通-Elasticsearch核心倒排索引数据结构

Elasticsearch 入门到精通-Elasticsearch核心倒排索引数据结构

Elasticsearch 简介Elasticsearch 是一个分布式、高扩展、高实时的搜索与数据分析引擎。Elasticsearch 建立在全文搜索引擎 Apache Lucene™ 基础上&#xff0c;通过 Lucene 的倒排索引技术实现比关系型数据库更快的过滤&#xff0c;从而很方便的使大量数据具有搜索、分析和探索…
阅读更多...
vue插槽之插槽的用法及作用域插槽详解

vue插槽之插槽的用法及作用域插槽详解

目录前言一&#xff0c;插槽的基本使用1.1 引出插槽1.2 插槽的基本使用1.3 默认插槽1.4 插槽样式二&#xff0c;具名插槽2.1 引出具名插槽2.2 具名插槽的使用三&#xff0c;template标签3.1 引出template标签3.2 template标签的使用四&#xff0c;作用域插槽4.1 引出作用域插槽…
阅读更多...
C语言小题，有3个学生的信息，放在结构体数组中，要求输出全部学生的信息。（指向结构体数组的指针）

C语言小题，有3个学生的信息，放在结构体数组中，要求输出全部学生的信息。（指向结构体数组的指针）

前言&#xff1a; 此篇是针对 指向结构体数组的指针 方面的练习。 解题思路&#xff1a; 用指向结构体变量的指针来处理&#xff1a; &#xff08;1&#xff09;声明结构体类型 struct Student &#xff0c;并定义结构体数组&#xff0c;同时使之初始化&#xff1b; &#xff…
阅读更多...
【Rust】9. 常见集合

【Rust】9. 常见集合

9.1 Vector 9.1.1 创建 vector vector 只能储存相同类型的值&#xff01;创建空的 vector&#xff1a;Vec::new()创建有值的 vector&#xff1a;vec! 宏 9.1.2 向 vector 中添加元素 9.1.3 读取 vector 的元素 索引语法&#xff1a;当引用一个不存在的元素时 Rust 会造成 pa…
阅读更多...
设计模式-软件设计原则

设计模式-软件设计原则

目录 3.软件设计原则 3.1 开闭原则 3.2 里氏代换原则 3.3 依赖倒转原则 3.4 接口隔离原则 3.5 迪米特法则 3.6 合成复用原则 3.软件设计原则 在软件开发中&#xff0c;为了提高软件系统的可维护性和可复用性&#xff0c;增加软件的可扩展性和灵活性&#xff0c;程序员要…
阅读更多...
【QT5 定时器练习-笔记-样例讲解-实现方式＞＞＞（1）定时器事件方式和（2）定时器绑定函数】

【QT5 定时器练习-笔记-样例讲解-实现方式＞＞＞（1）定时器事件方式和（2）定时器绑定函数】

QT5 -定时器简单应用-样例讲解-实现方式1-定时器事件方式1、前言2、实验环境3、定时器实现方式说明-以及效果3、操作步骤-&#xff08;1&#xff09;定时器事件方式&#xff08;1&#xff09;建立工程&#xff08;2&#xff09;拉控件布局&#xff08;3&#xff09;代码部分编写…
阅读更多...
《深入浅出计算机组成原理》学习笔记 Day16

《深入浅出计算机组成原理》学习笔记 Day16

冒险和预测&#xff08;一&#xff09;1. 超长流水线的缺点2. 冒险和分支预测参考1. 超长流水线的缺点 增加流水线的深度&#xff0c;在同主频下&#xff0c;其实就是降低了 CPU 的性能。 一个 Pipeline Stage&#xff0c;就需要一个时钟周期。如果我们把任务分成 31 个阶段&…
阅读更多...
2014年408专业算法题

2014年408专业算法题

文章目录0 结果1 题目2 思路附录0 结果 1 题目 2 思路 二叉树的带权路径长度&#xff08;WPL&#xff09;的计算方法有两种&#xff1a; 1&#xff0c;定义&#xff1a;WPL所有叶结点的权值Wi∗该结点深度Di求和WPL所有叶结点的权值W_i*该结点深度D_i求和WPL所有叶结点的权值…
阅读更多...
如何管理IC研发过程产生的bug

如何管理IC研发过程产生的bug

一款芯片的研发过程中总是伴随着bug、bug和bug&#xff0c;研发线上各端的IC工程师也是全程在debug、debug和debug&#xff0c;直到最终的GDSII文件交给Founry工厂加工&#xff0c;全程都是为了保证芯片最终能够安全保质的tape-out成功。由此可见&#xff0c;bug的跟踪管理是至…
阅读更多...
【数据结构】题解：二叉树的非递归遍历

【数据结构】题解：二叉树的非递归遍历

【数据结构】题解&#xff1a;二叉树的非递归实现 文章目录【数据结构】题解&#xff1a;二叉树的非递归实现一、问题描述二、递归实现三、非递归实现3.1 前序遍历3.2 中序遍历3.3 后序遍历一、问题描述 二叉树的前序遍历&#xff0c;非递归迭代实现 &#xff0c;二叉树的前序遍…
阅读更多...
Synology群晖小技巧之百度网盘远程下载同步

Synology群晖小技巧之百度网盘远程下载同步

&#x1f388; 作者&#xff1a;互联网-小啊宇 &#x1f388; 简介&#xff1a; CSDN 运维领域创作者、阿里云专家博主。目前从事 Kubernetes运维相关工作&#xff0c;擅长Linux系统运维、开源监控软件维护、Kubernetes容器技术、CI/CD持续集成、自动化运维、开源软件部署维护…
阅读更多...
[HCTF 2018]WarmUp1

[HCTF 2018]WarmUp1

http://ca039961-2ebb-4acd-8107-ece077539106.node4.buuoj.cn:81/ 按F12查看源码 根据提示访问source.php 分析源码&#xff0c;搞懂其中几个函数 mb_strpos() &#xff1a;返回要查找的字符串在要检查的字符串中首次出现的位置 mb_strpos (haystack ,needle) //haystack&…
阅读更多...
AVS3变换系数编码：SRCC

AVS3变换系数编码：SRCC

AVS3摒弃了HEVC和AVS2中的基于CG(Coefficient Group)的变换系数编码方式&#xff0c;使用基于扫描区域的变换系数编码方法Scan Region-based Coefficient Coding(SRCC)。在基于块的预测变换混合编码框架里&#xff0c;当一个块完成预测、变换和量化后会获得相应的变换系数&…
阅读更多...
盘点2022十大热门编程语言（上）

盘点2022十大热门编程语言（上）

全球知名代码托管平台 GitHub发布的2022年GitHub Octoverse年度报告公布了全球最流行的十大编程语言&#xff0c;其中JavaScript蝉联第一&#xff0c;Python位列次席。 编程是技术革新的核心&#xff0c;对于所有的编程开发人员来说&#xff0c;对世界范围内编程语言发展和趋势…
阅读更多...
APP UI自动化测试思路总结

APP UI自动化测试思路总结

pythonappium自动化测试系列就要告一段落了&#xff0c;本篇博客咱们做个小结。 首先想要说明一下&#xff0c;APP自动化测试可能很多公司不用&#xff0c;但也是大部分自动化测试工程师、高级测试工程师岗位招聘信息上要求的&#xff0c;所以为了更好的待遇&#xff0c;我们还…
阅读更多...
算法该不该刷？如何高效刷算法？

算法该不该刷？如何高效刷算法？

一、算法该不该刷&#xff1f;最近有小伙伴向我咨询一个问题&#xff0c;就是算法该不该刷&#xff0c;该如何刷算法呢&#xff1f;这个问题可谓太大众化了&#xff0c;只要你去某乎、某度搜索一下相关的解答&#xff0c;会有无数种回答&#xff0c;可见这个问题困扰了多少学习…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023