大家好，今天给各位分享SpringBoot 与 Elasticsearch 实现复杂数据关联查询的一些知识，其中也会对进行解释，文章篇幅可能偏长，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在就马上开始吧！

那么问题来了，我们如何通过后端的技术手段快速实现es中嵌入对象的数据查询呢？

为了让大家更容易掌握技术，本文主要以通过上一篇介绍的产品找单的案例，利用SpringBoot集成ES来实现这一业务需求，并向大家介绍具体的技术实践解决方案。 es中存储的json数据结构如下：

{

'订单Id':'1',

'订单号':'123456',

'orderUserName':'张三',

'订单项目':[

{

'orderItemId':'12234',

'订单Id':'1',

'产品名称':'火腿肠',

'brandName':'双汇',

'销售价格':'28'

},

{

'orderItemId':'12235',

'订单Id':'1',

'产品名称':'果冻',

'brandName':'汇源',

'销售价格':'12'

}

]

}废话不多说，直接上代码吧！

二、项目实践

2.1添加依赖

在SpringBoot项目中，添加rest-high-level-client客户端，方便与ES服务器通信。这里你需要注意。建议客户端的版本与ES服务器的版本号保持一致，否则会出现错误信息。接口请求错误等异常！

小编这次安装的ES服务器版本号是6.8.2，所以客户端也保持6.8.2，与之一致！

依赖性

groupIdorg.elasticsearchgroupId

神器IdelasticsearchartifactId

版本6.8.2版本

依赖性

依赖性

groupIdorg.elasticsearch.clientgroupId

artifactIdelasticsearchrestclientartifactId

版本6.8.2版本

依赖性

依赖性

groupIdorg.elasticsearch.clientgroupId

artifactIdelasticsearchresthighlevelclientartifactId

版本6.8.2版本

dependency

2.2配置 es 客户端

为了更方便的使用es，我们可以封装其各种配置类，方便后续维护。

在application.properties配置文件中，定义es配置连接地址； # 设置es参数

elasticsearch.schemehttp

弹性搜索.地址127.0.0.1:9200

elasticsearch.用户名

elasticsearch.userPwd

elasticsearch.socketTimeout5000

elasticsearch.connectTimeout5000

elasticsearch.connectionRequestTimeout5000 创建ElasticSearch配置类，方便SpringBoot启动时注入；导入org.apache.http.HttpHost;

导入org.apache.http.auth.AuthScope;

导入org.apache.http.auth.UsernamePasswordCredentials;

导入org.apache.http.client.CredentialsProvider;

导入org.apache.http.impl.client.BasicCredentialsProvider;

导入org.elasticsearch.client.RestClient;

导入org.elasticsearch.client.RestClientBuilder;

导入org.elasticsearch.client.RestHighLevelClient;

导入org.slf4j.Logger;

导入org.slf4j.LoggerFactory;

导入org.springframework.beans.factory.annotation.Value;

导入org.springframework.context.annotation.Bean;

导入org.springframework.context.annotation.Configuration;

导入java.util.Arrays；

导入java.util.Objects；

@配置

公共类ElasticSearchConfiguration{

私有静态最终记录器logLoggerFactory.getLogger(ElasticSearchConfiguration.class);

私有静态finalintADDRESS_LENGTH2；

@Value('${elasticsearch.scheme:http}')

私有字符串方案；

@Value('${elasticsearch.address}')

私有字符串地址；

@Value('${elasticsearch.userName}')

私有字符串用户名；

@Value('${elasticsearch.userPwd}')

私有字符串用户密码；

@Value('${elasticsearch.socketTimeout:5000}')

privateIntegerSocketTimeout；

@Value('${elasticsearch.connectTimeout:5000}')

privateIntegerconnectTimeout；

@Value('${elasticsearch.connectionRequestTimeout:5000}')

privateIntegerconnectionRequestTimeout；

/**

* 初始化客户端

* @返回

*/

@Bean(名称'restHighLevelClient')

公共RestHighLevelClient RestClientBuilder(){

HttpHost[]hostsArrays.stream(address.split(','))

.map(this:buildHttpHost)

.filter(对象：nonNull)

.toArray(HttpHost[]:new);

RestClientBuilder RestClientBuilderRestClient.builder(主机);

//异步参数配置

restClientBuilder.setHttpClientConfigCallback(httpClientBuilder-{

httpClientBuilder.setDefaultCredentialsProvider(buildCredentialsProvider());

返回httpClientBuilder；

});

//异步连接延迟配置

restClientBuilder.setRequestConfigCallback(requestConfigBuilder-{

requestConfigBuilder.setConnectionRequestTimeout(connectionRequestTimeout);

requestConfigBuilder.setSocketTimeout(socketTimeout);

requestConfigBuilder.setConnectTimeout(connectTimeout);

返回requestConfigBuilder；

});

返回新的RestHighLevelClient(restClientBuilder);

}

/**

* 根据配置创建HttpHost

* @参数

* @返回

*/

私有HttpHost buildHttpHost(String s){

String[]addresss.split(':');

if(地址.lengthADDRESS_LENGTH){

字符串ip地址[0]；

intportInteger.parseInt(地址[1]);

返回新的HttpHost(ip,端口，方案);

}别的{

返回空；

}

}

/**

* 构建认证服务

* @返回

*/

私人CredentialsProvider buildCredentialsProvider(){

最终CredentialsProvider credentialsProvidernew BasicCredentialsProvider();

credentialProvider.setCredentials(AuthScope.ANY,new UsernamePasswordCredentials(userName,

用户密码））；

返回凭证提供者；

}

}封装ElasticSearch客户端服务类，方便公共调用处理import com.fasterxml.jackson.databind.ObjectMapper;

导入org.example.es.exception.CommonException;

导入org.apache.commons.lang3.StringUtils;

导入org.elasticsearch.action.admin.indices.alias.get.GetAliasesRequest;

导入org.elasticsearch.action.admin.indices.create.CreateIndexRequest;

导入org.elasticsearch.action.admin.indices.create.CreateIndexResponse;

导入org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;

导入org.elasticsearch.action.admin.indices.get.GetIndexRequest;

导入org.elasticsearch.action.admin.indices.get.GetIndexResponse;

导入org.elasticsearch.action.admin.indices.mapping.get.GetMappingsRequest;

导入org.elasticsearch.action.admin.indices.mapping.get.GetMappingsResponse;

导入org.elasticsearch.action.admin.indices.mapping.put.PutMappingRequest;

导入org.elasticsearch.action.delete.DeleteRequest;

导入org.elasticsearch.action.delete.DeleteResponse;

导入org.elasticsearch.action.get.GetRequest;

导入org.elasticsearch.action.get.GetResponse;

导入org.elasticsearch.action.index.IndexRequest;

导入org.elasticsearch.action.index.IndexResponse;

导入org.elasticsearch.action.search.SearchRequest;

导入org.elasticsearch.action.search.SearchResponse;

导入org.elasticsearch.action.support.master.AcknowledgedResponse;

导入org.elasticsearch.action.update.UpdateRequest;

导入org.elasticsearch.action.update.UpdateResponse;

导入org.elasticsearch.client.GetAliasesResponse;

导入org.elasticsearch.client.RequestOptions;

导入org.elasticsearch.client.RestHighLevelClient;

导入org.elasticsearch.common.settings.Settings；

导入org.elasticsearch.common.xcontent.XContentType;

导入org.elasticsearch.search.builder.SearchSourceBuilder;

导入org.slf4j.Logger;

导入org.slf4j.LoggerFactory;

导入org.springframework.beans.factory.annotation.Autowired;

导入org.springframework.stereotype.Component;

导入java.io.IOException；

导入java.util.Collections；

导入java.util.Map；

导入java.util.Set；

@成分

公共类ElasticSearchClient{

私有静态最终记录器logLoggerFactory.getLogger(ElasticSearchClient.class);

私有静态最终ObjectMapper objectMappernew ObjectMapper();

@Autowired

私有RestHighLevelClient 客户端；

/**

* 查询所有索引

* @返回

*/

publicSetStringgetAlias(){

尝试{

GetAliasesRequest 请求new GetAliasesRequest();

GetAliasesResponse 响应client.indices().getAlias(request,RequestOptions.DEFAULT);

返回response.getAliases().keySet();

}catch(IOException e){

log.error('向es查询所有索引信息的请求失败',e);

}

返回Collections.emptySet();

}

/**

* 检查索引是否存在

* @参数索引名称

* @返回

*/

publicbooleanexistsIndex(字符串索引名称){

尝试{

//创建请求

GetIndexRequest 请求new GetIndexRequest().indices(indexName);

//执行请求并获取响应

booleanresponseclient.indices().exists(request,RequestOptions.DEFAULT);

返回响应；

}捕获（异常e）{

log.error('查询es索引是否存在的请求失败，请求参数：'+indexName,e);

}

返回假；

}

/**

* 查询索引

* @参数索引名称

* @返回

*/

公共字符串getIndex(字符串索引名称){

尝试{

//创建请求

GetIndexRequest 请求new GetIndexRequest().indices(indexName);

//执行请求并获取响应

GetIndexResponse responseclient.indices().get(request,RequestOptions.DEFAULT);

返回response.toString();

}捕获（异常e）{

log.error('对es的索引查询请求失败，请求参数：'+indexName,e);

}

返回StringUtils.EMPTY；

}

/**

* 创建索引

* @参数索引名称

* @参数映射

* @返回

*/

公共无效createIndex（字符串索引名称，MapString，对象映射）{

尝试{

CreateIndexRequest 请求new CreateIndexRequest();

//索引名称

request.index(indexName);

//索引配置

设置settings.builder()

.put('index.number_of_shards',3)

.put('index.number_of_replicas',1)

.put('index.max_inner_result_window',5000)。建造（）;

请求.设置（设置）；

//索引结构

request.mapping('_doc',mapping);

//执行请求并获取响应

CreateIndexResponse responseclient.indices().create(request,RequestOptions.DEFAULT);

if(!response.isAcknowledged()){

throw new CommonException('从es 创建索引的请求失败');

}

log.info('向es请求创建索引成功，返回参数：{}', response.index());

}捕获（异常e）{

log.error('请求es创建索引失败，请求参数：'+indexName,e);

throw new CommonException('从es创建索引的请求失败');

}

}

/**

* 删除索引

* @参数索引名称

* @返回

*/

公共无效deleteIndex（字符串索引名称）{

尝试{

DeleteIndexRequest requestnew DeleteIndexRequest(indexName);

AcknowledgedResponse responseclient.indices().delete(request,RequestOptions.DEFAULT);

if(!response.isAcknowledged()){

throw new CommonException('请求从es中删除索引失败');

}

log.info('请求从es删除索引成功，请求参数：{}',indexName);

}捕获（异常e）{

log.error('请求从es中删除索引失败，请求参数：'+indexName,e);

throw new CommonException('请求从es中删除索引失败');

}

}

/**

* 查询索引映射字段

* @参数索引名称

* @返回

*/

公共字符串getMapping(字符串索引名称){

尝试{

GetMappingsRequest 请求new GetMappingsRequest().indices(indexName).types('_doc');

GetMappingsResponse 响应client.indices().getMapping(request,RequestOptions.DEFAULT);

返回response.toString();

}捕获（异常e）{

log.error('向es查询索引映射字段的请求失败，请求参数：'+indexName,e);

}

返回StringUtils.EMPTY；

}

/**

* 添加索引映射字段

* @参数索引名称

* @返回

*/

公共无效addMapping（字符串索引名称，MapString，对象映射）{

尝试{

PutMappingRequest 请求new PutMappingRequest();

request.indices(indexName);

request.type('_doc');

//添加字段

请求源（映射）；

AcknowledgedResponse responseclient.indices().putMapping(request,RequestOptions.DEFAULT);

if(!response.isAcknowledged()){

throw new CommonException('向es添加索引映射字段的请求失败');

}

log.info('向es添加索引映射字段的请求成功，请求参数：{}',toJson(request));

}捕获（异常e）{

log.error('向es添加索引映射字段的请求失败，请求参数：'+indexName,e);

throw new CommonException('向es添加索引映射字段的请求失败');

}

}

/**

* 添加文档到索引

* @参数索引名称

* @参数id

* @参数对象

*/

公共无效addDocument（字符串索引名称，字符串id，对象obj）{

尝试{

//将文档添加到索引中

索引请求

t requestnew IndexRequest(); //外层参数 request.id(id); request.index(indexName); request.type("_doc"); //存入对象 request.source(toJson(obj),XContentType.JSON); //发送请求 IndexResponse responseclient.index(request,RequestOptions.DEFAULT); if(response.status().getStatus()>=400){ log.warn("向es发起添加文档数据请求失败，请求参数：{}，返回参数：{}",request.toString(),response.toString()); throw new CommonException("向es发起添加文档数据请求失败"); } }catch(Exception e){ log.error("向es发起添加文档数据请求失败，请求参数："+indexName,e); throw new CommonException("向es发起添加文档数据请求失败"); } } /** * 修改索引中的文档数据 * @param indexName * @param id * @param obj */ public void updateDocument(String indexName,String id,Map<String,Object>obj){ try{ //修改索引中的文档数据 UpdateRequest requestnew UpdateRequest(); //外层参数 request.id(id); request.index(indexName); request.type("_doc"); //存入对象 request.doc(obj); request.doc(toJson(obj),XContentType.JSON); //发送请求 UpdateResponse responseclient.update(request,RequestOptions.DEFAULT); if(response.status().getStatus()>=400){ log.warn("向es发起修改文档数据请求失败，请求参数：{}，返回参数：{}",request.toString(),response.toString()); throw new CommonException("向es发起修改文档数据请求失败"); } }catch(Exception e){ log.error("向es发起修改文档数据请求失败，请求参数："+indexName,e); throw new CommonException("向es发起修改文档数据请求失败"); } } /** * 删除索引中的文档数据 * @param indexName * @param id */ public void deleteDocument(String indexName,String id){ try{ //删除索引中的文档数据 DeleteRequest requestnew DeleteRequest(); //外层参数 request.id(id); request.index(indexName); request.type("_doc"); //发送请求 DeleteResponse responseclient.delete(request,RequestOptions.DEFAULT); if(response.status().getStatus()>=400){ log.warn("向es发起删除文档数据请求失败，请求参数：{}，返回参数：{}",request.toString(),response.toString()); throw new CommonException("向es发起删除文档数据请求失败"); } }catch(Exception e){ log.error("向es发起删除文档数据请求失败，请求参数："+indexName,e); throw new CommonException("向es发起删除文档数据请求失败"); } } /** * 查询索引中的文档数据 * @param indexName * @param id */ public String getDocumentById(String indexName,String id){ try{ GetRequest requestnew GetRequest(); //外层参数 request.id(id); request.index(indexName); request.type("_doc"); //发送请求 GetResponse responseclient.get(request,RequestOptions.DEFAULT); response.getSourceAsString(); }catch(Exception e){ log.error("向es发起查询文档数据请求失败，请求参数："+indexName,e); } return StringUtils.EMPTY; } /** * 索引高级查询 * @param indexName * @param source * @return */ public SearchResponse searchDocument(String indexName,SearchSourceBuilder source){ //搜索 SearchRequest searchRequestnew SearchRequest(); searchRequest.indices(indexName); searchRequest.source(source); try{ //执行请求 SearchResponse responseclient.search(searchRequest,RequestOptions.DEFAULT); return response; }catch(Exception e){ log.warn("向es发起查询文档数据请求失败，请求参数："+searchRequest.toString(),e); } returnnull; } /** * 将对象格式化成json，并保持原字段类型输出 * @param object * @return */ private String toJson(Object object){ try{ return objectMapper.writeValueAsString(object); }catch(Exception e){ throw new CommonException(e); } } }

2.3初始化索引结构

在使用 es 对订单进行查询搜索时，我们需要先定义好对应的订单索引结构，内容如下： @ActiveProfiles("dev") @RunWith(SpringRunner.class) @SpringBootTest public class OrderIndexServiceJunit{ @Autowired private ElasticSearchClient elasticSearchClient; /** * 初始化索引结构 * @return */ @Test public void initIndex(){ String indexName"orderIndex-2022-07"; //创建请求 booleanexistsIndexelasticSearchClient.existsIndex(indexName); if(!existsIndex){ Map<String,Object>propertiesbuildMapping(); elasticSearchClient.createIndex(indexName,properties); } } /** * 构建索引结构 * @return */ private Map<String,Object>buildMapping(){ Map<String,Object>propertiesnew HashMap(); //订单id 唯一键ID properties.put("orderId",ImmutableBiMap.of("type","keyword")); //订单号 properties.put("orderNo",ImmutableBiMap.of("type","keyword")); //客户姓名 properties.put("orderUserName",ImmutableBiMap.of("type","text")); //订单项 Map<String,Object>orderItemsnew HashMap(); //订单项ID orderItems.put("orderItemId",ImmutableBiMap.of("type","keyword")); //产品名称 orderItems.put("productName",ImmutableBiMap.of("type","text")); //品牌名称 orderItems.put("brandName",ImmutableBiMap.of("type","text")); //销售金额,单位分100 orderItems.put("sellPrice",ImmutableBiMap.of("type","integer")); properties.put("orderItems",ImmutableBiMap.of("type","nested","properties",orderItems)); //文档结构映射 Map<String,Object>mappingnew HashMap(); mapping.put("properties",properties); return mapping; } }

2.4向 es 中同步文档数据

索引结构创建好之后，我们需要将支持 es 搜索的订单数据同步进去。 将指定的订单 ID 从数据库查询出来，并封装成 es 订单数据结构，保存到 es 中！ @ActiveProfiles("dev") @RunWith(SpringRunner.class) @SpringBootTest public class OrderIndexServiceJunit { @Autowired private ElasticSearchClient elasticSearchClient; /** * 保存订单到ES中 * @param request */ @Test public void saveDocument(){ String indexName = "orderIndex-2022-07"; //从数据库查询最新订单数据，并封装成对应的es订单结构 String orderId = "202202020202"; OrderIndexDocDTO indexDocDTO = buildOrderIndexDocDTO(orderId); //保存数据到ES中 elasticSearchClient.addDocument(indexName, indexDocDTO.getOrderId(), indexDocDTO); } }

2.5内嵌对象查询

内嵌对象查询分两种形式，比如，第一种通过商品、品牌、价格等条件，分页查询订单数据；第二种是通过订单ID、商品、品牌、价格等，分页查询订单项数据。具体的实践，请看下文。 通过商品、品牌、价格等条件，分页查询订单数据； @ActiveProfiles("dev") @RunWith(SpringRunner.class) @SpringBootTest public class OrderIndexServiceJunit{ @Autowired private ElasticSearchClient elasticSearchClient; /** * 通过商品、品牌、价格等条件，分页查询订单数据 * @param request */ @Test public void search1(){ //查询索引，支持通配符 String indexName"orderIndex-*"; String orderUserName"张三"; String productName"薯条"; //条件搜索 SearchSourceBuilder buildernew SearchSourceBuilder(); //组合搜索 BoolQueryBuilder mainBoolQuerynew BoolQueryBuilder(); mainBoolQuery.must(QueryBuilders.matchQuery("orderUserName",orderUserName)); //订单项相关信息搜索 BoolQueryBuilder nestedBoolQuerynew BoolQueryBuilder();nestedBoolQuery.must(QueryBuilders.matchQuery("orderItems.productName",productName)); //内嵌对象搜索，需要指定path NestedQueryBuilder nestedQueryBuilderQueryBuilders.nestedQuery("orderItems",nestedBoolQuery,ScoreMode.None); //子表查询 mainBoolQuery.must(nestedQueryBuilder); //封装查询参数 builder.query(mainBoolQuery); //返回参数 builder.fetchSource(new String[]{},new String[]{}); //结果集合分页，从第一页开始，返回最多四条数据 builder.from(0).size(4); //排序 builder.sort("orderId",SortOrder.DESC); log.info("dsl：{}",builder.toString()); //执行请求 SearchResponse responseelasticSearchClient.searchDocument(indexName,builder); //当前返回的总行数 longcountresponse.getHits().getTotalHits(); //返回的具体行数 SearchHit[]searchHitsresponse.getHits().getHits(); log.info("response：{}",response.toString()); } }通过订单ID、商品、品牌、价格等，分页查询订单项数据； @ActiveProfiles("dev") @RunWith(SpringRunner.class) @SpringBootTest public class OrderIndexServiceJunit{ @Autowired private ElasticSearchClient elasticSearchClient; /** * 通过订单ID、商品、品牌、价格等，分页查询订单项数据 * @param request */ @Test public void search2(){ //查询索引，支持通配符 String indexName"orderIndex-*"; String orderId"202202020202"; String productName"薯条"; //条件搜索 SearchSourceBuilder buildernew SearchSourceBuilder(); //组合搜索 BoolQueryBuilder mainBoolQuerynew BoolQueryBuilder(); mainBoolQuery.must(QueryBuilders.termQuery("_id",orderId)); //订单项相关信息搜索 BoolQueryBuilder nestedBoolQuerynew BoolQueryBuilder();nestedBoolQuery.must(QueryBuilders.matchQuery("orderItems.productName",productName)); //内嵌对象搜索，需要指定path NestedQueryBuilder nestedQueryBuilderQueryBuilders.nestedQuery("orderItems",nestedBoolQuery,ScoreMode.None); //内嵌对象分页查询 InnerHitBuilder innerHitBuildernew InnerHitBuilder(); //结果集合分页，从第一页开始，返回最多四条数据 innerHitBuilder.setFrom(0).setSize(4); //只返回订单项id innerHitBuilder.setFetchSourceContext(new FetchSourceContext(true,new String[]{"orderItems.orderItemId"},new String[]{})); innerHitBuilder.addSort(SortBuilders.fieldSort("orderItems.orderItemId").order(SortOrder.DESC)); nestedQueryBuilder.innerHit(innerHitBuilder); //子表查询 mainBoolQuery.must(nestedQueryBuilder); //封装查询参数 builder.query(mainBoolQuery); //返回参数 builder.fetchSource(new String[]{},new String[]{}); //结果集合分页，从第一页开始，返回最多四条数据 builder.from(0).size(4); //排序 builder.sort("orderId",SortOrder.DESC); log.info("dsl：{}",builder.toString()); //执行请求 SearchResponse responseelasticSearchClient.searchDocument(indexName,builder); //当前返回的订单主表总行数 longcountresponse.getHits().getTotalHits(); //返回的订单主表数据 SearchHit[]searchHitsresponse.getHits().getHits(); //返回查询的的订单项分页数据 Map<String,SearchHits>searchHit[0].getInnerHits(); log.info("response：{}",response.toString()); } }

三、小结

本文主要以通过商品名称查询订单数据为案例，介绍利用 SpringBoot 整合 es 实现数据的高效搜索，内容如果难免有些遗漏，欢迎网友指出！

关于SpringBoot 与 Elasticsearch 实现复杂数据关联查询，的介绍到此结束，希望对大家有所帮助。

用户评论

心脏偷懒

我也正在学习 Elasticsearch，想了解一下SpringBoot和ES怎么结合起来做联表操作。

    有20位网友表示赞同！

(り。薆情海

springboot开发框架好强大啊，听说现在可以用它来操作ES数据库了，还挺期待的！

    有6位网友表示赞同！

青瓷清茶倾城歌

想问一下类似连表的查询在实际项目中遇到的场景有哪些？

    有20位网友表示赞同！

海盟山誓总是赊

这篇文章能解决我的一个痛点！之前一直用分页查询，数据量大了会很慢。

    有18位网友表示赞同！

半梦半醒半疯癫

ES本身是不是就有支持联表查询的功能呢？还是需要通过SpringBoot中间件来实现？

    有17位网友表示赞同！

迁心

学习一下SpringBoot结合ES的查询技巧，可以让我开发更高效的应用系统。

    有20位网友表示赞同！

坏小子不坏

文中提到的策略有哪些具体操作步骤？有没有详细的代码示例？

    有14位网友表示赞同！

有恃无恐

我比较想要知道如何在Elasticsearch里定义多字段索引，方便做联表查询。

    有10位网友表示赞同！

放肆丶小侽人

SpringBoot和ES的结合确实很强大，让我在开发过程中更加灵活！

    有20位网友表示赞同！

爱情的过失

这篇文章很有用，希望能看到更多关于SpringBoot和ES的实战案例分享。

    有15位网友表示赞同！

作业是老师的私生子

学习了这个知识点以后，可以更快地响应用户请求，提升系统的性能吧？

    有12位网友表示赞同！

空巷

对于复杂的多表联查询，用SpringBoot实现会有哪些优缺点？

    有9位网友表示赞同！

情字何解ヘ

这篇文章写的挺详细的，让我对如何利用SpringBoot在ES中实现类似连表的查询有了更深入的理解。

    有9位网友表示赞同！

来瓶年的冰泉

现在很多公司都已经把数据存储到Elasticsearch里了，学习这种技术真的很有价值！

    有16位网友表示赞同！

西瓜贩子

我想问一下，如果数据量过大会影响查询效率吗？有没有相应的优化方法？

    有19位网友表示赞同！

我就是这样一个人

这个知识点对前端开发也有帮助吗？能否利用Spring Boot和ES构建一些动态的界面展示？

    有8位网友表示赞同！

强辩

除了联表查询以外，SpringBoot还有哪些其他功能可以用来操作ES？

    有8位网友表示赞同！

拥抱

这篇文章让我更深入地了解了SpringBoot的强大之处，它不仅仅是后台开发框架，也可以用于数据处理！

    有8位网友表示赞同！

放血

我需要学习一下Springboot和ES的相关知识，看看如何应用到我的项目中去。

    有15位网友表示赞同！

繁华若梦

感谢作者分享这方面的经验，我会认真研读文章并进行实践！

    有20位网友表示赞同！