1.简介

相信使用springboot 2.0以下的同学都遇到这个坑了。

spring-boot-starter-data-elasticsearch 不支持springboot 版本2.0以下

所以。。。只能自己写client来操作ElasticSearch了

2.依赖。pom.xml

关于ElasticSearch与Springboot的整合，我经历了2次因为reimport线上的包导致项目跑起来报错了。

所以，建议大家能在调试成功后把这部分jar包单独分开。

其中swagger也可以不加入到依赖

<properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding><java.version>1.8</java.version><elasticsearch.version>6.5.1</elasticsearch.version></properties><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope></dependency><!-- Elasticsearch核心依赖包 --><dependency><groupId>org.elasticsearch.client</groupId><artifactId>transport</artifactId><version>${elasticsearch.version}</version></dependency><!-- 日志依赖 --><!-- ===================== @Getter @Setter @Slf4j @Data ======================== --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-beans</artifactId><version>4.3.12.RELEASE</version></dependency><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger2</artifactId><version>2.2.2</version></dependency><dependency><groupId>io.springfox</groupId><artifactId>springfox-swagger-ui</artifactId><version>2.2.2</version></dependency></dependencies>

3.配置类ESConfig

package com.example.elatiscsearch;import org.apache.commons.lang.StringUtils;
import org.elasticsearch.client.transport.TransportClient;
import org.elasticsearch.common.settings.Settings;
import org.elasticsearch.common.transport.TransportAddress;
import org.elasticsearch.transport.client.PreBuiltTransportClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.net.InetAddress;
import java.net.UnknownHostException;/*** @program: elatiscsearch* @description: config* @author: Irving Wei* @create: 2018-12-06 11:00**/
@Configuration
public class ESConfig {@Value("${elasticsearch.host}")private String host;private int port;@Value("${elasticsearch.port}")private void setPort(String str){if(StringUtils.isNotBlank(str)){port = Integer.valueOf(str);}}@Value("${elasticsearch.cluster-name}")private String clusterName;@Beanpublic TransportClient client() throws UnknownHostException {//es集群连接TransportAddress node = new TransportAddress(InetAddress.getByName(host),port);//es集群配置（自定义配置） 连接自己安装的集群名称Settings settings = Settings.builder().put("cluster.name", clusterName).build();PreBuiltTransportClient client = new PreBuiltTransportClient(settings);client.addTransportAddress(node);return client;}
}

4.yml配置文件

elasticsearch:host: #es的IPport: 9300cluster-name: my-application  #这里在es的配置文件查，要保证cluster-name与配置文件相同

5.实体类，省略不写了，根据自己的业务定义实体类

6.Client的使用

@Autowired
private TransportClient client;public void function(){// 单一查询GetResponse result = this.client.prepareGet("index_name", "type_name", id).get();// 新增// entityMap 是一个map参数，将要保存的实体转换为map类型IndexResponse result = this.client.prepareIndex("index_name", "type_name").setSource(entityMap).get();// 删除DeleteResponse result = this.client.prepareDelete("index_name", "type_name",         id).get();// 修改// dataMap: 把需要修改的数据，以key value的形式封装到一个map中UpdateRequestBuilder urb = client.prepareUpdate("index_name", "type_name", id);urb.setDoc(dataMap);urb.execute().actionGet();// 复合查询BoolQueryBuilder boolQuery = QueryBuilders.boolQuery();boolQuery.must(QueryBuilders.matchQuery("filed", value));RangeQueryBuilder rangeQuery =     QueryBuilders.rangeQuery("word_count").from(gtWordCount);if (ltWordCount != null && ltWordCount > 0) {rangeQuery.to(ltWordCount);}boolQuery.filter(rangeQuery);SearchRequestBuilder builder = this.client.prepareSearch("index_name").setTypes("type_name").setSearchType(SearchType.DFS_QUERY_THEN_FETCH).setQuery(boolQuery).setFrom(0).setSize(10);SearchResponse response = builder.get();List<Object> result = new ArrayList<>();for (SearchHit hit : response.getHits()) {try {result.add(hit.getSourceAsMap());} catch (Exception e) {e.printStackTrace();}}}

7.有问题留言，谢谢

6点下班了，我今天一定要准时走，耶稣也拦不住我.gif，手动狗头！

Springboot 整合ElasticSearch（Client篇）相关推荐

es springboot 不设置id_原创 | 一篇解决Springboot 整合 Elasticsearch
ElasticSearch 结合业务的场景,在目前的商品体系需要构建搜索服务,主要是为了提供用户更丰富的检索场景以及高速,实时及性能稳定的搜索服务. ElasticSearch是一个基于Lucene的 ...
【数据篇】SpringBoot 整合 Elasticsearch 实践数据搜索引擎
写在最前 Elasticsearch 入门必读 Docker安装ELK Spring Data Elasticsearch 参考文档版本选择 Spring Data Release Train Sp ...
【十九】springboot整合ElasticSearch实战（万字篇）
本章开始学习springboot整合ElasticSearch 7.X版本并通过小demo实现基本的增删改查.实现如下案例: 1.当向数据新增一个商品信息时,同时向rabbitMQ发起消息(异步实现) ...
SpringBoot整合ElasticSearch实现多版本的兼容
前言在上一篇学习SpringBoot中,整合了Mybatis.Druid和PageHelper并实现了多数据源的操作.本篇主要是介绍和使用目前最火的搜索引擎ElastiSearch,并和Spring ...
SpringBoot整合Elasticsearch详细步骤以及代码示例（附源码）
准备工作# 环境准备# JAVA版本 Copy java version "1.8.0_121" Java(TM) SE Runtime Environment (build 1. ...
七、SpringBoot整合elasticsearch集群
@Author : By Runsen @Date : 2020/6/12 作者介绍:Runsen目前大三下学期,专业化学工程与工艺,大学沉迷日语,Python, Java和一系列数据分析软件.导致翘 ...
SpringBoot整合elasticsearch (java整合es)
欢迎大家进群,一起探讨学习微信公众号,每天给大家提供技术干货博主技术笔记博主网站地址1 博主网站地址2 博主开源微服架构前后端分离技术博客项目源码地址,欢迎各位star SpringBoot整合 ...
Springboot整合Elasticsearch(High-level-Client)
前言通过学习Elasticsearch一小段时间来稍微认识了一点ES的体系架构.发现ES最大的坑就是版本兼容性问题了-在整合Springboot也不例外,但是,有一种方式能较好的解决-通过restc ...
Springboot 整合ElasticSearch 常用的插入查询，模糊查询，范围查询
前言本来该篇教程就应该写到 Springboot 整合 ElasticSearch 入门教学必看 https://blog.csdn.net/qq_35387940/article/details/ ...
Springboot 整合 ElasticSearch 入门教学必看
ElasticSearch 相比搜到这篇文章的人,都已经有过对它的了解, 一种流行的企业级搜索引擎,是一个分布式,高性能.高可用.可伸缩的搜索和分析系统. 那么用我粗俗的言语来说,它就是提供一个存储数 ...

Springboot 整合ElasticSearch（Client篇）