Spring Data Elasticsearch 5.0.x修改数据后无法立即刷新解决方法示例
背景
在项目中用到了Spring Data ElasticSearch,最近更新到了最新版本5.0.x,在数据插入、修改、删除后,紧接着进行查询发现数据并未更新;
解决方法
研究后发现是新版本的spring data es默认的刷新策略是null,代码如下:
@Bean
@ConditionalOnMissingBean(value = ElasticsearchOperations.class, name = "elasticsearchTemplate")
@ConditionalOnBean(ElasticsearchClient.class)
ElasticsearchTemplate elasticsearchTemplate(ElasticsearchClient client, ElasticsearchConverter converter) {
return new ElasticsearchTemplate(client, converter);
}
这里没有给ElasticsearchTemplate设置refreshPolicy属性,点进AbstractElasticsearchTemplate可以看到默认为null,而以前默认是立即刷新IMMEDIATE。
查看Spring官网发现
Refresh configuration
When configuring Spring Data Elasticsearch like described in Elasticsearch Clients by using ElasticsearchConfigurationSupport, AbstractElasticsearchConfiguration or AbstractReactiveElasticsearchConfiguration the refresh policy will be initialized to null. Previously the reactive code initialized this to IMMEDIATE, now reactive and non-reactive code show the same behaviour.
也就是说,对es数据库进行数据变更操作时,默认是按照索引自带的刷新策略(一般情况下是1s以后才会更新索引)
{
"settings": {},
"defaults": {
"index": {
"refresh_interval": "1s"
}
}
}如果想要在Spring data es中更新数据后立即刷新,那么需要如下配置覆盖掉Springboot的Auto Configuration:
@Configuration
@EnableConfigurationProperties(ElasticsearchProperties.class)
public class ElasticsearchConfig extends ElasticsearchConfiguration {
private final ElasticsearchProperties properties;
public ElasticsearchConfig(ElasticsearchProperties properties) {
this.properties = properties;
}
@NotNull
@Override
public ClientConfiguration clientConfiguration() {
List<String> uris = properties.getUris();
String[] uri = uris.toArray(new String[0]);
return ClientConfiguration.builder()
.connectedTo(uri)
.withSocketTimeout(properties.getSocketTimeout())
.withConnectTimeout(properties.getConnectionTimeout())
.build();
}
@NotNull
@Bean(name = { "elasticsearchOperations", "elasticsearchTemplate" })
@Override
public ElasticsearchOperations elasticsearchOperations(@NotNull ElasticsearchConverter elasticsearchConverter,
@NotNull ElasticsearchClient elasticsearchClient) {
ElasticsearchTemplate template = new ElasticsearchTemplate(elasticsearchClient, elasticsearchConverter);
template.setRefreshPolicy(RefreshPolicy.IMMEDIATE);
return template;
}
}以上就是Spring Data Elasticsearch 5.0.x修改数据后无法立即刷新解决方法示例的详细内容,更多关于Spring Data Elasticsearch无法刷新的资料请关注脚本之家其它相关文章!
相关文章
关于spring项目中无法加载resources下文件问题及解决方法
在学习Spring过程中,TestContext框架试图检测一个默认的XML资源位置,再resources下创建了一个com.example的文件夹,执行时,报错,本文给大家介绍spring项目中无法加载resources下文件,感兴趣的朋友跟随小编一起看看吧2023-10-10
SpringBoot后端接收参数优化代码示例(统一处理前端参数)
使用Spring Boot开发API的时候,读取请求参数是服务端编码中最基本的一项操作,下面这篇文章主要给大家介绍了关于SpringBoot后端接收参数优化(统一处理前端参数)的相关资料,需要的朋友可以参考下2024-07-07
吊打Java面试官!整理了一周的Spring面试大全(附答案)
这篇文章主要介绍了Spring面试资料(附答案)建议收藏留存,学Java的小伙伴都知道Spring是面试的必问环节,看完了一天就可掌握数据结构和算法的面试题,快来看看吧2021-08-08


最新评论