集成Springboot----ElasticSearch

集成Springboot

官方文档：https://www.elastic.co/guide/en/elasticsearch/client/java-rest/current/index.html

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-7WO11AQr-1610955801732)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210117234918617.png)]

创建一个模块的办法（新）

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-hAbuuaTh-1610955801735)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210117235819775.png)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-mAtpbds5-1610955801739)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210118000624531.png)]

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-RbhSjz3x-1610955801742)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210118001126961.png)]

1、找到原生的依赖

<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.6.1</version>
</dependency><properties><java.version>1.8</java.version><elasticsearch.version>7.6.1</elasticsearch.version></properties>

2、找对象

Initialization

A RestHighLevelClient instance needs a REST low-level client builder to be built as follows:

package com.kuang.config;import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class ElasticSearchClientConfig {@Beanpublic RestHighLevelClient restHighLevelClient(){RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http"),new HttpHost("localhost", 9201, "http")));return client;}
}

The high-level client will internally create the low-level client used to perform requests based on the provided builder. That low-level client maintains a pool of connections and starts some threads so you should close the high-level client when you are well and truly done with it and it will in turn close the internal low-level client to free those resources. This can be done through the close:

client.close();

In the rest of this documentation about the Java High Level Client, the RestHighLevelClient instance will be referenced as client.

3、分析类中的方法

一定要版本一致！默认es是6.8.1，要改成与本地一致的。

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

Java配置类

@Configuration  //xml
public class EsConfig {@Beanpublic RestHighLevelClient restHighLevelClient(){RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http"))); //妈的被这个端口搞了return client;}
}

索引API操作

1、创建索引

@SpringBootTest
class EsApplicationTests {@Autowired@Qualifier("restHighLevelClient")private RestHighLevelClient restHighLevelClient;//创建索引的创建 Request@Testvoid testCreateIndex() throws IOException {//1.创建索引请求CreateIndexRequest request = new CreateIndexRequest("索引名");//2.执行创建请求 indices 请求后获得响应CreateIndexResponse createIndexResponse = restHighLevelClient.indices().create(request, RequestOptions.DEFAULT);System.out.println(createIndexResponse);}}

2、获取索引

	@Testvoid testExistIndex() throws IOException {GetIndexRequest request = new GetIndexRequest("索引名");boolean exist =restHighLevelClient.indices().exists(request,RequestOptions.DEFAULT);System.out.println(exist);}

3、删除索引

	@Testvoid deleteIndex() throws IOException{DeleteIndexRequest request = new DeleteIndexRequest("索引名");AcknowledgedResponse delete = restHighLevelClient.indices().delete(request, RequestOptions.DEFAULT);System.out.println(delete.isAcknowledged());}

文档API操作

package com.kuang.pojo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Data
@AllArgsConstructor
@NoArgsConstructor
@Component
public class User {private String name;private int age;}

1、测试添加文档

导入

<dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.16</version>
</dependency>

	//测试添加文档@Testvoid testAddDocument() throws IOException {//创建对象User user = new User("psz", 22);IndexRequest request = new IndexRequest("ppp");//规则 PUT /ppp/_doc/1request.id("1");request.timeout(timeValueSeconds(1));//数据放入请求IndexRequest source = request.source(JSON.toJSONString(user), XContentType.JSON);//客户端发送请求,获取响应结果IndexResponse indexResponse = restHighLevelClient.index(request, RequestOptions.DEFAULT);System.out.println(indexResponse.toString());System.out.println(indexResponse.status());}

2、获取文档

	//获取文档，判断是否存在 GET /index/doc/1@Testvoid testIsExists() throws IOException {GetRequest getRequest = new GetRequest("ppp", "1");//过滤，不放回_source上下文getRequest.fetchSourceContext(new FetchSourceContext(false));getRequest.storedFields("_none_");boolean exists = restHighLevelClient.exists(getRequest, RequestOptions.DEFAULT);System.out.println(exists);}

3、获取文档信息

	//获取文档信息@Testvoid getDocument() throws IOException {GetRequest getRequest = new GetRequest("ppp", "1");GetResponse getResponse = restHighLevelClient.get(getRequest, RequestOptions.DEFAULT);System.out.println(getResponse.getSourceAsString());System.out.println(getResponse);}
==============输出==========================
{"age":22,"name":"psz"}
{"_index":"ppp","_type":"_doc","_id":"1","_version":2,"_seq_no":1,"_primary_term":1,"found":true,"_source":{"age":22,"name":"psz"}}

4、更新文档信息

	//更新文档信息@Testvoid updateDocument() throws IOException {UpdateRequest updateRequest = new UpdateRequest("ppp","1");updateRequest.timeout("1s");//json格式传入对象User user=new User("新名字",21);updateRequest.doc(JSON.toJSONString(user),XContentType.JSON);//请求，得到响应UpdateResponse updateResponse = restHighLevelClient.update(updateRequest, RequestOptions.DEFAULT);System.out.println(updateResponse);}

5、删除文档信息

//删除文档信息
@Test
void deleteDocument() throws IOException {DeleteRequest deleteRequest = new DeleteRequest("ppp","1");deleteRequest.timeout("1s");DeleteResponse deleteResponse = restHighLevelClient.delete(deleteRequest, RequestOptions.DEFAULT);System.out.println(deleteResponse);
}

批量操作Bulk

  • 真实项目中，肯定用到大批量查询
  • 不写id会随机生成id

[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-CS8wKFqS-1610955801744)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210118104900129.png)]

	@Testvoid testBulkRequest() throws IOException{BulkRequest bulkRequest = new BulkRequest();bulkRequest.timeout("10s");//数据量大的时候，秒数可以增加ArrayList<User> userList = new ArrayList<>();userList.add(new User("psz",11));userList.add(new User("psz2",12));userList.add(new User("psz3",13));userList.add(new User("psz4",14));userList.add(new User("psz5",15));for (int i = 0; i < userList.size(); i++) {bulkRequest.add(new IndexRequest("ppp").id(""+(i+1)).source(JSON.toJSONString(userList.get(i)),XContentType.JSON));}//请求+获得响应BulkResponse bulkResponse = restHighLevelClient.bulk(bulkRequest, RequestOptions.DEFAULT);System.out.println(bulkResponse.hasFailures());//返回false：成功}

搜索

	/*查询:搜索请求：SearchRequest条件构造：SearchSourceBuilder*/@Testvoid testSearch() throws IOException {SearchRequest searchRequest = new SearchRequest("ppp");//构建搜索条件SearchSourceBuilder searchSourceBuilderBuilder = new SearchSourceBuilder();// 查询条件QueryBuilders工具// ：比如：精确查询TermQueryBuilder termQueryBuilder = QueryBuilders.termQuery("name", "psz");searchSourceBuilderBuilder.query(termQueryBuilder);//设置查询时间searchSourceBuilderBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));//设置高亮//searchSourceBuilderBuilder.highlighter()searchRequest.source(searchSourceBuilderBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println(JSON.toJSONString(searchResponse.getHits()));}

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

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

相关文章

消息队列 Kafka 的基本知识及 .NET Core 客户端

消息队列 Kafka 的基本知识及 .NET Core 客户端

前言 最新项目中要用到消息队列来做消息的传输&#xff0c;之所以选着 Kafka 是因为要配合其他 java 项目中&#xff0c;所以就对 Kafka 了解了一下&#xff0c;也算是做个笔记吧。 本篇不谈论 Kafka 和其他的一些消息队列的区别&#xff0c;包括性能及其使用方式。 简介 Kafka…
阅读更多...
javaWeb服务详解【客户端调用】（含源代码，测试通过，注释） ——applicationContext.xml

javaWeb服务详解【客户端调用】（含源代码，测试通过，注释） ——applicationContext.xml

<?xml version"1.0" encoding"UTF-8"?> <beansxmlns"http://www.springframework.org/schema/beans"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xmlns:p"http://www.springframework.org/schema/p"xs…
阅读更多...
深入解读Service Mesh背后的技术细节

深入解读Service Mesh背后的技术细节

转载自 深入解读Service Mesh背后的技术细节 在Kubernetes称为容器编排的标准之后&#xff0c;Service Mesh开始火了起来&#xff0c;但是很多文章讲概念的多&#xff0c;讲技术细节的少&#xff0c;所以专门写一篇文章&#xff0c;来解析Service Mesh背后的技术细节。 一、…
阅读更多...
CentOS7查看和关闭防火墙

CentOS7查看和关闭防火墙

https://blog.csdn.net/ytangdigl/article/details/79796961 CentOS7查看和关闭防火墙 蔚蓝色天空sky 2018-04-02 23:22:21 708762 收藏 236 分类专栏&#xff1a; linux 文章标签&#xff1a; centos 防火墙 CentOS 7.0默认使用的是firewall作为防火墙 查看防火墙状态 f…
阅读更多...
Visual Studio Code 1.8版本添加了Hot Exit、Zen Mode及更多调试选项

Visual Studio Code 1.8版本添加了Hot Exit、Zen Mode及更多调试选项

最新发布的Visual Studio Code 1.8版本有许多改进和新功能&#xff0c;包括防止丢失任何编辑信息的Hot Exit&#xff0c;方便开发人员把注意力集中在代码上的Zen Mode&#xff0c;新的调试功能以及更方便的设置等。 Hot Exit是一项新功能&#xff0c;目的是在应用程序崩溃或退出…
阅读更多...
javaWeb服务详解【客户端调用】（含源代码，测试通过，注释） ——测试

javaWeb服务详解【客户端调用】（含源代码，测试通过，注释） ——测试

Dept测试 Testpublic void test() {ApplicationContext ctx new ClassPathXmlApplicationContext("applicationContext.xml");IDeptService deptService (IDeptService) ctx.getBean("wsClient");List<Dept> depts deptService.getDepts();for (D…
阅读更多...
ElasticSearch（笔记）

ElasticSearch（笔记）

简介 本教程基于ElasticSearch7.6.1, 注意ES7的语法与ES6的API调用差别很大, 教程发布时最新版本为ES7.6.2(20200401更新);ES是用于全文搜索的工具: SQL: 使用like %关键词%来进行模糊搜索在大数据情况下是非常慢的, 即便设置索引提升也有限;ElasticSearch: 搜索引擎(baidu, …
阅读更多...
漫画：什么是冒泡排序

漫画：什么是冒泡排序

转载自 漫画&#xff1a;什么是冒泡排序 什么是冒泡排序&#xff1f; 冒泡排序的英文Bubble Sort&#xff0c;是一种最基础的交换排序。 大家一定都喝过汽水&#xff0c;汽水中常常有许多小小的气泡&#xff0c;哗啦哗啦飘到上面来。这是因为组成小气泡的二氧化碳比水要轻…
阅读更多...
CentOS - 修改主机名教程（将 localhost.localdomain 改成其它名字）

CentOS - 修改主机名教程（将 localhost.localdomain 改成其它名字）

https://www.cnblogs.com/gudi/p/7846978.html 需要关闭防火墙&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01; Linux修改主机名称 碰到这个问题的时候&#xff0c;是在安装Zookeeper集群的时候&#xff0c;碰到如下问题 java.net.U…
阅读更多...
使用JDBCTemplate实现与Spring结合，方法公用

使用JDBCTemplate实现与Spring结合，方法公用

该篇博文主要是体现了接口和类的公用性&#xff0c; Emp的实体类&#xff1a; package org.entity;import java.util.Date;/*** Emp entity. author MyEclipse Persistence Tools*/public class Emp implements java.io.Serializable {// Fieldsprivate Integer empno;private…
阅读更多...
.net core 源码解析-web app是如何启动并接收处理请求(二) kestrel的启动

.net core 源码解析-web app是如何启动并接收处理请求(二) kestrel的启动

上篇讲到.net core web app是如何启动并接受请求的&#xff0c;下面接着探索kestrel server是如何完成此任务的。 1.kestrel server的入口KestrelServer.Start (Microsoft.AspNetCore.Hosting.Server.IHttpApplication ) FrameFactory创建的frame实例最终会交给libuv的loop回调…
阅读更多...
MySQL中的any_value()函数

MySQL中的any_value()函数

https://blog.csdn.net/u014079773/article/details/93722761 https://www.thinbug.com/q/37089347 https://blog.csdn.net/Peacock__/article/details/90608246 https://www.itranslater.com/qa/details/2109775246877262848 4.any_value()会选择被分到同一组的数据里…
阅读更多...
MybatisPlus使用

MybatisPlus使用

Mybatisplus 导入依赖 <dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>org.springframework.boot</gro…
阅读更多...
面试为什么需要了解JVM

面试为什么需要了解JVM

转载自 面试为什么需要了解JVM 说在前面 如果你经常注意面试题&#xff0c;你会发现现在面试题多多少少会含有jvm相关的面试题&#xff0c;那么为什么现在面试需要了解或者问面试题呢&#xff1f; 主题 谈谈自己的理解&#xff0c;概括为以下几个方面&#xff1a; 的确很重…
阅读更多...
使用JDBCTemplate实现与Spring结合，方法公用 ——接口（BaseDao）

使用JDBCTemplate实现与Spring结合，方法公用 ——接口（BaseDao）

/** * Title: BaseDao.java * Package org.dao * Description: TODO该方法的主要作用&#xff1a; * author A18ccms A18ccms_gmail_com * date 2017-6-3 下午2:40:13 * version V1.0 */ package org.dao;import java.io.Serializable; import java.util.List;/** * …
阅读更多...
Centos7安装apt-get 在centos下用yum install xxx        不是使用apt-get

Centos7安装apt-get 在centos下用yum install xxx        不是使用apt-get

https://www.cnblogs.com/yadongliang/p/8660046.html centos中执行apt-get命令提示apt-get command not found 先说结论: 在centos下用yum install xxx 不是使用apt-getyum和apt-get的区别: 一般来说著名的linux系统基本上分两大类&#xff1a; RedHat系列&#xf…
阅读更多...
.net core 源码解析-mvc route的注册，激活，调用流程(三)

.net core 源码解析-mvc route的注册，激活，调用流程(三)

.net core mvc route的注册&#xff0c;激活&#xff0c;调用流程 mvc的入口是route&#xff0c;当前请求的url匹配到合适的route之后&#xff0c;mvc根据route所指定的controller和action激活controller并调用action完成mvc的处理流程。下面我们看看服务器是如何调用route的。…
阅读更多...
高可用性的几个级别

高可用性的几个级别

转载自 高可用性的几个级别 大家常说高可用&#xff0c;High Availablility&#xff0c;但是一般说到这个词的时候&#xff0c;具体指的什么方案呢&#xff1f; 级别一&#xff1a;FT (Fault Tolerance) 双击热备 通过创建与主实例保持虚拟同步的虚拟机&#xff0c;使应用在服…
阅读更多...
使用JDBCTemplate实现与Spring结合，方法公用 ——共用实现类（BaseImpl）

使用JDBCTemplate实现与Spring结合，方法公用 ——共用实现类（BaseImpl）

/** * Title: BaseImpl.java * Package org.dao.impl * Description: TODO该方法的主要作用&#xff1a; * author A18ccms A18ccms_gmail_com * date 2017-6-6 下午4:12:02 * version V1.0 */ package org.dao.impl;import java.io.Serializable; import java.lang.refl…
阅读更多...
后端讲师管理模块

后端讲师管理模块

后端讲师管理模块 后端项目的结构 [外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-hTdcdNmT-1611036676306)(C:\Users\王东梁\AppData\Roaming\Typora\typora-user-images\image-20210118223028941.png)] [外链图片转存失败,源站可能有防盗链机制,…
阅读更多...
最新文章

Copyright @ 2022~2023