文章目录

• • 原因
  • Elasticsearch的术语与关系型数据库的术语相对应
  • 要用到的网站
  • "SpringBoot整合ElasticSearch7.12实现增删改查及高亮分词查询"的代码下载
  • 这里贴一下"SpringBoot整合ElasticSearch7.12实现增删改查及高亮分词查询"的代码
  • • • • • es7.12.0的增删改查：ElasticsearchTests.java
          • DiscussPostRepository
          • application.properties
          • EsConfig
          • DiscussPost
          • pom.xml
          • DiscussPostMapper.java
          • discusspost-mapper.xml
          • 数据库
• es6.4.3与es7.12.0有区别的地方
• • • • • • 普通查询和高亮查询：ElasticsearchTests.java
          • application.properties
          • DiscussPost.java
          • pom.xml
  • 其他

原因

因为看的项目（Java牛客项目课_仿牛客网讨论区）的视频课中，用的6.4.3的ElasticSearch，我下载的7.12.0（最新版）的ElasticSearch，这两个版本的es在结合SpringBoot时，API有些不一样，就用了个demo来测试下，demo用的用7.12.0的es。

Elasticsearch的术语与关系型数据库的术语相对应

在es6.0以前，
关系型数据库的术语和Elasticsearch的术语的对应关系：

es6.0以后废弃了"类型"这个概念，

于是在es6.x和7.x，有如下对应关系：

要用到的网站

1、http://127.0.0.1:9200/：显示出网页，则表明成功安装并运行ElasticSearch。
2、elasticsearch-head http://127.0.0.1:9100/：ES的图形化界面插件客户端，名字是Head。相当于关系型数据库的图形化界面，可以查看es的索引、文档、字段。

"SpringBoot整合ElasticSearch7.12实现增删改查及高亮分词查询"的代码下载

wu/一些测试Demo——gitee

这里贴一下"SpringBoot整合ElasticSearch7.12实现增删改查及高亮分词查询"的代码

es7.12.0的增删改查：ElasticsearchTests.java

package com.nowcoder.community;import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.nowcoder.community.dao.DiscussPostMapper;
import com.nowcoder.community.dao.elasticsearch.DiscussPostRepository;
import com.nowcoder.community.entity.DiscussPost;
import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.action.update.UpdateRequest;
import org.elasticsearch.action.update.UpdateResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.common.xcontent.XContentType;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.builder.SearchSourceBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightBuilder;
import org.elasticsearch.search.fetch.subphase.highlight.HighlightField;
import org.elasticsearch.search.sort.SortBuilders;
import org.elasticsearch.search.sort.SortOrder;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.ContextConfiguration;import java.io.IOException;
import java.util.LinkedList;
import java.util.List;@SpringBootTest
@ContextConfiguration(classes = AllPomApplication.class)
public class ElasticsearchTests {@Autowiredprivate DiscussPostMapper discussMapper;@Autowiredprivate DiscussPostRepository discussRepository;@Qualifier("client")@Autowiredprivate RestHighLevelClient restHighLevelClient;//判断某id的文档（数据库中的行）是否存在@Testpublic void testExist(){boolean exists =discussRepository.existsById(109);System.out.println(exists);}//一次保存一条数据@Testpublic void testInsert() {//把id为241的DiscussPost的对象保存到discusspost索引（es的索引相当于数据库的表）discussRepository.save(discussMapper.selectDiscussPostById(241));}//一次保存多条数据@Testpublic void testInsertList() {//把id为101的用户发的前100条帖子（List）存入es的discusspost索引（es的索引相当于数据库的表）discussRepository.saveAll(discussMapper.selectDiscussPosts(101, 0, 100));}//通过覆盖原内容，来修改一条数据@Testpublic void testUpdate() {DiscussPost post = discussMapper.selectDiscussPostById(230);post.setContent("我是新人,使劲灌水。");post.setTitle(null);//es中的title会设为nulldiscussRepository.save(post);}//修改一条数据//覆盖es里的原内容 与 修改es中的内容 的区别：String类型的title被设为null，覆盖的话，会把es里的该对象的title也设为null；UpdateRequest，修改后该对象的title不变@Testvoid testUpdateDocument() throws IOException{UpdateRequest request = new UpdateRequest("discusspost", "109");request.timeout("1s");DiscussPost post = discussMapper.selectDiscussPostById(230);post.setContent("我是新人,使劲灌水.");post.setTitle(null);//es中的title会保存原内容不变request.doc(JSON.toJSONString(post), XContentType.JSON);UpdateResponse updateResponse = restHighLevelClient.update(request, RequestOptions.DEFAULT);System.out.println(updateResponse.status());}//删除一条数据和删除所有数据@Testpublic void testDelete() {discussRepository.deleteById(109);//删除一条数据//discussRepository.deleteAll();//删除所有数据}//不带高亮的查询@Testpublic void noHighlightQuery() throws IOException {SearchRequest searchRequest = new SearchRequest("discusspost");//discusspost是索引名，就是表名//构建搜索条件SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder()//在discusspost索引的title和content字段中都查询“互联网寒冬”.query(QueryBuilders.multiMatchQuery("互联网寒冬", "title", "content"))// matchQuery是模糊查询，会对key进行分词：searchSourceBuilder.query(QueryBuilders.matchQuery(key,value));// termQuery是精准查询：searchSourceBuilder.query(QueryBuilders.termQuery(key,value));.sort(SortBuilders.fieldSort("type").order(SortOrder.DESC)).sort(SortBuilders.fieldSort("score").order(SortOrder.DESC)).sort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC))//一个可选项，用于控制允许搜索的时间：searchSourceBuilder.timeout(new TimeValue(60, TimeUnit.SECONDS));.from(0)// 指定从哪条开始查询.size(10);// 需要查出的总记录条数searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);System.out.println(JSONObject.toJSON(searchResponse));List<DiscussPost> list = new LinkedList<>();for (SearchHit hit : searchResponse.getHits().getHits()) {DiscussPost discussPost = JSONObject.parseObject(hit.getSourceAsString(), DiscussPost.class);System.out.println(discussPost);list.add(discussPost);}}//带高亮的查询@Testpublic void highlightQuery() throws Exception{SearchRequest searchRequest = new SearchRequest("discusspost");//discusspost是索引名，就是表名//高亮HighlightBuilder highlightBuilder = new HighlightBuilder();highlightBuilder.field("title");highlightBuilder.field("content");highlightBuilder.requireFieldMatch(false);highlightBuilder.preTags("");highlightBuilder.postTags("");//构建搜索条件SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().query(QueryBuilders.multiMatchQuery("互联网寒冬", "title", "content")).sort(SortBuilders.fieldSort("type").order(SortOrder.DESC)).sort(SortBuilders.fieldSort("score").order(SortOrder.DESC)).sort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)).from(0)// 指定从哪条开始查询.size(10)// 需要查出的总记录条数.highlighter(highlightBuilder);//高亮searchRequest.source(searchSourceBuilder);SearchResponse searchResponse = restHighLevelClient.search(searchRequest, RequestOptions.DEFAULT);List<DiscussPost> list = new LinkedList<>();for (SearchHit hit : searchResponse.getHits().getHits()) {DiscussPost discussPost = JSONObject.parseObject(hit.getSourceAsString(), DiscussPost.class);// 处理高亮显示的结果HighlightField titleField = hit.getHighlightFields().get("title");if (titleField != null) {discussPost.setTitle(titleField.getFragments()[0].toString());}HighlightField contentField = hit.getHighlightFields().get("content");if (contentField != null) {discussPost.setContent(contentField.getFragments()[0].toString());}System.out.println(discussPost);list.add(discussPost);}}
}

DiscussPostRepository

package com.nowcoder.community.dao.elasticsearch;import com.nowcoder.community.entity.DiscussPost;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import org.springframework.stereotype.Repository;/*
ElasticsearchRepository
DiscussPost：接口要处理的实体类
Integer：实体类中的主键是什么类型
ElasticsearchRepository：父接口，其中已经事先定义好了对es服务器访问的增删改查各种方法。Spring会给它自动做一个实现，我们直接去调就可以了。*/
@Repository
public interface DiscussPostRepository extends ElasticsearchRepository<DiscussPost, Integer> {}

application.properties

# ServerProperties
server.port=8080
server.servlet.context-path=/community# ThymeleafProperties
spring.thymeleaf.cache=false# DataSourceProperties
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://localhost:3306/community?characterEncoding=utf-8&useSSL=false&serverTimezone=Hongkong
spring.datasource.username=root
spring.datasource.password=a1b2c3
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
spring.datasource.hikari.maximum-pool-size=15
spring.datasource.hikari.minimum-idle=5
spring.datasource.hikari.idle-timeout=30000# MybatisProperties
mybatis.mapper-locations=classpath:mapper/*.xml
mybatis.type-aliases-package=com.nowcoder.community.entity
mybatis.configuration.useGeneratedKeys=true
mybatis.configuration.mapUnderscoreToCamelCase=true# ElasticsearchProperties
# spring.data.elasticsearch.cluster-name=my-application
# spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300
elasticSearch.url=127.0.0.1:9200

EsConfig

package com.nowcoder.community.config;import org.elasticsearch.client.RestHighLevelClient;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.elasticsearch.client.ClientConfiguration;
import org.springframework.data.elasticsearch.client.RestClients;@Configuration
public class  EsConfig{@Value("${elasticSearch.url}")private String esUrl;//localhost:9200 写在配置文件中就可以了@BeanRestHighLevelClient client() {ClientConfiguration clientConfiguration = ClientConfiguration.builder().connectedTo(esUrl)//elasticsearch地址.build();return RestClients.create(clientConfiguration).rest();}
}

DiscussPost

package com.nowcoder.community.entity;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import org.springframework.data.annotation.Id;
import org.springframework.data.elasticsearch.annotations.Document;
import org.springframework.data.elasticsearch.annotations.Field;
import org.springframework.data.elasticsearch.annotations.FieldType;import java.util.Date;@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(indexName = "discusspost", /*type = "_doc",*/ shards = 6, replicas = 3)
public class DiscussPost {@Idprivate int id;@Field(type = FieldType.Integer)private int userId;// 互联网校招@Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_smart")private String title;@Field(type = FieldType.Text, analyzer = "ik_max_word", searchAnalyzer = "ik_smart")private String content;@Field(type = FieldType.Integer)private int type;@Field(type = FieldType.Integer)private int status;@Field(type = FieldType.Date)private Date createTime;@Field(type = FieldType.Integer)private int commentCount;@Field(type = FieldType.Double)private double score;
}

pom.xml

<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.0modelVersion><parent><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-parentartifactId><version>2.4.3version><relativePath/> parent><groupId>com.kuanggroupId><artifactId>all-pomartifactId><version>0.0.1-SNAPSHOTversion><name>all-pomname><description>Demo project for Spring Bootdescription><properties><java.version>1.8java.version><elasticsearch.version>7.12.0elasticsearch.version>properties><dependencies><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-data-elasticsearchartifactId>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-data-redisartifactId>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-securityartifactId>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-thymeleafartifactId>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-webartifactId>dependency><dependency><groupId>org.thymeleaf.extrasgroupId><artifactId>thymeleaf-extras-springsecurity5artifactId>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-devtoolsartifactId><scope>runtimescope><optional>trueoptional>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-configuration-processorartifactId><optional>trueoptional>dependency><dependency><groupId>org.projectlombokgroupId><artifactId>lombokartifactId><optional>trueoptional>dependency><dependency><groupId>org.springframework.bootgroupId><artifactId>spring-boot-starter-testartifactId><scope>testscope>dependency><dependency><groupId>org.springframework.securitygroupId><artifactId>spring-security-testartifactId><scope>testscope>dependency><dependency><groupId>com.alibabagroupId><artifactId>fastjsonartifactId><version>1.2.59version>dependency><dependency><groupId>mysqlgroupId><artifactId>mysql-connector-javaartifactId>dependency><dependency><groupId>org.mybatis.spring.bootgroupId><artifactId>mybatis-spring-boot-starterartifactId><version>2.1.0version>dependency>dependencies><build><plugins><plugin><groupId>org.springframework.bootgroupId><artifactId>spring-boot-maven-pluginartifactId><configuration><excludes><exclude><groupId>org.projectlombokgroupId><artifactId>lombokartifactId>exclude>excludes>configuration>plugin>plugins>build>project>

DiscussPostMapper.java

package com.nowcoder.community.dao;import com.nowcoder.community.entity.DiscussPost;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;import java.util.List;@Mapper
@Repository
public interface DiscussPostMapper {List<DiscussPost> selectDiscussPosts(int userId, int offset, int limit);// @Param注解用于给参数取别名,// 如果只有一个参数,并且在里使用,则必须加别名.int selectDiscussPostRows(@Param("userId") int userId);int insertDiscussPost(DiscussPost discussPost);DiscussPost selectDiscussPostById(int id);int updateCommentCount(int id, int commentCount);
}

discusspost-mapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.nowcoder.community.dao.DiscussPostMapper"><sql id="selectFields">id, user_id, title, content, type, status, create_time, comment_count, score</sql><sql id="insertFields">user_id, title, content, type, status, create_time, comment_count, score</sql><select id="selectDiscussPosts" resultType="DiscussPost">select <include refid="selectFields"></include>from discuss_postwhere status != 2<if test="userId!=0">and user_id = #{userId}</if>order by type desc, create_time desclimit #{offset}, #{limit}</select><select id="selectDiscussPostRows" resultType="int">select count(id)from discuss_postwhere status != 2<if test="userId!=0">and user_id = #{userId}</if></select><insert id="insertDiscussPost" parameterType="DiscussPost" keyProperty="id">insert into discuss_post(<include refid="insertFields"></include>)values(#{userId},#{title},#{content},#{type},#{status},#{createTime},#{commentCount},#{score})</insert><select id="selectDiscussPostById" resultType="DiscussPost">select <include refid="selectFields"></include>from discuss_postwhere id = #{id}</select><update id="updateCommentCount">update discuss_post set comment_count = #{commentCount} where id = #{id}</update></mapper>

数据库

CREATE DATABASE /*!32312 IF NOT EXISTS*/`community` /*!40100 DEFAULT CHARACTER SET utf8 */;USE `community`;/*Table structure for table `discuss_post` */DROP TABLE IF EXISTS `discuss_post`;CREATE TABLE `discuss_post` (`id` int(11) NOT NULL AUTO_INCREMENT,`user_id` varchar(45) DEFAULT NULL COMMENT '哪个用户发布的',`title` varchar(100) DEFAULT NULL,`content` text,`type` int(11) DEFAULT NULL COMMENT '0-普通; 1-置顶;',`status` int(11) DEFAULT NULL COMMENT '0-正常; 1-精华; 2-拉黑;',`create_time` timestamp NULL DEFAULT NULL,`comment_count` int(11) DEFAULT NULL,`score` double DEFAULT NULL,PRIMARY KEY (`id`),KEY `index_user_id` (`user_id`)
) ENGINE=InnoDB AUTO_INCREMENT=281 DEFAULT CHARSET=utf8;/*Data for the table `discuss_post` */insert  into `discuss_post`(`id`,`user_id`,`title`,`content`,`type`,`status`,`create_time`,`comment_count`,`score`) values (109,'101','因特网求职暖春计划','今年的就业形势，确实不容乐观。过了个年，仿佛跳水一般，整个讨论区哀鸿遍野！19届真的没人要了吗？！18届被优化真的没有出路了吗？！大家的“哀嚎”与“悲惨遭遇”牵动了每日潜伏于讨论区的牛客小哥哥小姐姐们的心，于是牛客决定：是时候为大家做点什么了！为了帮助大家度过“寒冬”，牛客网特别联合60+家企业，开启互联网求职暖春计划，面向18届&19届，拯救0 offer！',0,0,'2019-04-04 11:53:36',0,0),(275,'11','我是管理员','我是管理员，你们都老实点！',1,1,'2019-05-16 18:58:44',12,1751.2900346113624),(276,'149','新人报道','新人报道，请多关照！',0,0,'2019-05-17 15:50:18',6,1751.806179973984),(277,'149','Spring Cache','Spring Cache RedisCacheManager',0,0,'2019-05-17 17:06:54',38,1752.5797835966168),(280,'149','事务','事务的4个特性，包括原子性、一致性、隔离性、持久性。',0,0,'2019-05-20 17:41:30',16,1755.2095150145426);

es6.4.3与es7.12.0有区别的地方

在增删改方面，6.x和7.x是一样的。
在查找方面（分为普通查找和有高亮的查找），6.x和7.x有区别。
在7.x的es中，org.springframework.data.elasticsearch.core.SearchResultMapper没有这个类了，‘org.springframework.data.elasticsearch.core.ElasticsearchTemplate’ is deprecated已废弃，‘org.springframework.data.elasticsearch.repository.ElasticsearchRepository.search(org.springframework.data.elasticsearch.core.query.Query)’ is deprecated已废弃，于是在普通查找和带高亮的查找方面，es6.x和7.x不一样。下面只列出区别部分。

普通查询和高亮查询：ElasticsearchTests.java

@SpringBootTest
@ContextConfiguration(classes = CommunityApplication.class)
public class ElasticsearchTests {@Autowiredprivate DiscussPostMapper discussMapper;@Autowiredprivate DiscussPostRepository discussRepository;@Autowiredprivate ElasticsearchTemplate elasticTemplate;@Testpublic void testSearchByRepository() {SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.multiMatchQuery("互联网寒冬", "title", "content")).withSort(SortBuilders.fieldSort("type").order(SortOrder.DESC)).withSort(SortBuilders.fieldSort("score").order(SortOrder.DESC)).withSort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)).withPageable(PageRequest.of(0, 10)).withHighlightFields(new HighlightBuilder.Field("title").preTags("").postTags(""),new HighlightBuilder.Field("content").preTags("").postTags("")).build();// elasticTemplate.queryForPage(searchQuery, class, SearchResultMapper)// 底层获取得到了高亮显示的值, 但是没有返回.Page<DiscussPost> page = discussRepository.search(searchQuery);System.out.println(page.getTotalElements());System.out.println(page.getTotalPages());System.out.println(page.getNumber());System.out.println(page.getSize());for (DiscussPost post : page) {System.out.println(post);}}@Testpublic void testSearchByTemplate() {SearchQuery searchQuery = new NativeSearchQueryBuilder().withQuery(QueryBuilders.multiMatchQuery("互联网寒冬", "title", "content")).withSort(SortBuilders.fieldSort("type").order(SortOrder.DESC)).withSort(SortBuilders.fieldSort("score").order(SortOrder.DESC)).withSort(SortBuilders.fieldSort("createTime").order(SortOrder.DESC)).withPageable(PageRequest.of(0, 10)).withHighlightFields(new HighlightBuilder.Field("title").preTags("").postTags(""),new HighlightBuilder.Field("content").preTags("").postTags("")).build();Page<DiscussPost> page = elasticTemplate.queryForPage(searchQuery, DiscussPost.class, new SearchResultMapper() {@Overridepublic <T> AggregatedPage<T> mapResults(SearchResponse response, Class<T> aClass, Pageable pageable) {SearchHits hits = response.getHits();if (hits.getTotalHits() <= 0) {return null;}List<DiscussPost> list = new ArrayList<>();for (SearchHit hit : hits) {DiscussPost post = new DiscussPost();String id = hit.getSourceAsMap().get("id").toString();post.setId(Integer.valueOf(id));String userId = hit.getSourceAsMap().get("userId").toString();post.setUserId(Integer.valueOf(userId));String title = hit.getSourceAsMap().get("title").toString();post.setTitle(title);String content = hit.getSourceAsMap().get("content").toString();post.setContent(content);String status = hit.getSourceAsMap().get("status").toString();post.setStatus(Integer.valueOf(status));String createTime = hit.getSourceAsMap().get("createTime").toString();post.setCreateTime(new Date(Long.valueOf(createTime)));String commentCount = hit.getSourceAsMap().get("commentCount").toString();post.setCommentCount(Integer.valueOf(commentCount));// 处理高亮显示的结果HighlightField titleField = hit.getHighlightFields().get("title");if (titleField != null) {post.setTitle(titleField.getFragments()[0].toString());}HighlightField contentField = hit.getHighlightFields().get("content");if (contentField != null) {post.setContent(contentField.getFragments()[0].toString());}list.add(post);}return new AggregatedPageImpl(list, pageable,hits.getTotalHits(), response.getAggregations(), response.getScrollId(), hits.getMaxScore());}});System.out.println(page.getTotalElements());System.out.println(page.getTotalPages());System.out.println(page.getNumber());System.out.println(page.getSize());for (DiscussPost post : page) {System.out.println(post);}}
}

application.properties

es6.x不用配置类EsConfig，在application.properties中的es相关配置和es7.x不同。

# ElasticsearchProperties
spring.data.elasticsearch.cluster-name=my-application
spring.data.elasticsearch.cluster-nodes=127.0.0.1:9300

DiscussPost.java

有type = “_doc”。

@Document(indexName = "discusspost", type = "_doc", shards = 6, replicas = 3)
public class DiscussPost {。。。。。。
}

pom.xml

es导入版本不同。

	<properties><java.version>1.8java.version><elasticsearch.version>6.4.3elasticsearch.version>properties>

其他

1、

更多方法可以这样看：

2、

ES6.x和ES7.x里的application.properties的区别。

可以在IDEA里导入ES包后，查看源码spring-configuration-metadata.json和ElasticsearchRestClientProperties。标记了"deprecated": true就是弃用了的。

## 旧版本以spring.data.elasticsearch.开头;访问地址配置不用声明访问协议,监听es的tcp端口
spring.data.elasticsearch.cluster-nodes=localhost:9300
spring.data.elasticsearch.cluster-name=elasticsearch## 新版本以spring.elasticsearch.rest.开头;访问地址配置需要声明访问协议,直接监听es访问端口
spring.elasticsearch.rest.uris=http://localhost:9200

3、

ES6.x和ES7.x里的Elasticsearch Clients的区别。

下方内容来自官方文档：https://docs.spring.io/spring-data/elasticsearch/docs/4.0.1.RELEASE/reference/html/#reference

ES6.x：Transport Client

@Configuration
public class TransportClientConfig extends ElasticsearchConfigurationSupport {@Beanpublic Client elasticsearchClient() throws UnknownHostException {Settings settings = Settings.builder().put("cluster.name", "elasticsearch").build();        TransportClient client = new PreBuiltTransportClient(settings);client.addTransportAddress(new TransportAddress(InetAddress.getByName("127.0.0.1"), 9300)); return client;}@Bean(name = { "elasticsearchOperations", "elasticsearchTemplate" })public ElasticsearchTemplate elasticsearchTemplate() throws UnknownHostException {return new ElasticsearchTemplate(elasticsearchClient());}
}// ...IndexRequest request = new IndexRequest("spring-data", "elasticsearch", randomID()).source(someObject).setRefreshPolicy(IMMEDIATE);IndexResponse response = client.index(request);

ES7.x：High Level REST Client

@Configuration
public class RestClientConfig extends AbstractElasticsearchConfiguration {@Override@Beanpublic RestHighLevelClient elasticsearchClient() {final ClientConfiguration clientConfiguration = ClientConfiguration.builder()  .connectedTo("localhost:9200").build();return RestClients.create(clientConfiguration).rest();                         }
}// ...@AutowiredRestHighLevelClient highLevelClient;RestClient lowLevelClient = highLevelClient.lowLevelClient();                        // ...IndexRequest request = new IndexRequest("spring-data", "elasticsearch", randomID()).source(singletonMap("feature", "high-level-rest-client")).setRefreshPolicy(IMMEDIATE);IndexResponse response = highLevelClient.index(request);

4、

ES6.x里的cluster-name在ES7.x里用什么对应？

可以在IDEA里导入ES包后，查看源码spring-configuration-metadata.json，发现spring.data.cassandra.cluster-name被弃用了，而spring-configuration-metadata.json里面也没有看到相似的且没被弃用的cluster-name。

官方文档：https://docs.spring.io/spring-data/elasticsearch/docs/4.0.1.RELEASE/reference/html/#reference

里写的：

ES7.x，Secured Elasticsearch cluster support with Basic Authentication and SSL transport.

ES6.x，TransportClient：The TransportClient must be configured with the cluster name.
ES7.x，RestHighLevelClient： ClientConfiguration.builder().connectedTo("localhost:9200"). Use the builder to provide cluster addresses, set default HttpHeaders or enable SSL.

翻译：

ES7.x，安全的Elasticsearch集群支持基本身份验证和SSL传输。

ES6.x的TransportClient：必须使用cluster name配置TransportClient。
ES7.x的RestHighLevelClient： ClientConfiguration.builder().connectedTo("localhost:9200")。 使用builder提供集群地址、设置默认HttpHeaders或启用SSL。

我的理解：ES6.x必须要配置cluster name，但ES7.x不需要配置cluster name了。

最后，管他两个版本（ES6.x和ES7.x）的API有什么区别呢，我们学会学习方法（看源码，看官方文档），能用新版本的ES7.x把Demo跑起来不就行了。

官方文档：

Spring Data Elasticsearch - Reference Documentation：https://docs.spring.io/spring-data/elasticsearch/docs/4.0.1.RELEASE/reference/html/#reference

Getting started | Java REST Client [7.13] | Elastic https://www.elastic.co/guide/en/elasticsearch/client/java-rest/7.13/java-rest-high-getting-started.html

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！