From 2f180a73edb609c1a5272c026711a75e7e2d6372 Mon Sep 17 00:00:00 2001 From: misworga831 Date: Wed, 11 Dec 2024 16:18:37 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BC=98=E5=8C=96=E7=A7=AF=E5=88=86?= =?UTF-8?q?=E5=95=86=E5=93=81=EF=BC=8C=E7=A7=BB=E9=99=A4=E5=BC=82=E6=AD=A5?= =?UTF-8?q?=E5=88=A0=E9=99=A4=E7=B4=A2=E5=BC=95=20(pg)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 重构deleteByQuery方法，移除异步调用，改为同步处理。 添加了异常处理以记录删除索引时的错误日志。 --- .../serviceimpl/EsGoodsIndexServiceImpl.java | 19 ++++++------------- 1 file changed, 6 insertions(+), 13 deletions(-) diff --git a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java index 291efa1a..89e258d3 100644 --- a/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java +++ b/framework/src/main/java/cn/lili/modules/search/serviceimpl/EsGoodsIndexServiceImpl.java @@ -72,6 +72,7 @@ import org.springframework.data.elasticsearch.core.SearchPage; import org.springframework.data.elasticsearch.core.query.NativeSearchQueryBuilder; import org.springframework.stereotype.Service; +import java.io.IOException; import java.lang.reflect.Field; import java.util.*; import java.util.concurrent.TimeUnit; @@ -484,20 +485,12 @@ public class EsGoodsIndexServiceImpl extends BaseElasticsearchService implements deleteByQueryRequest.setQuery(boolQueryBuilder); deleteByQueryRequest.indices(getIndexName()); deleteByQueryRequest.setConflicts("proceed"); - this.client.deleteByQueryAsync(deleteByQueryRequest, RequestOptions.DEFAULT, new ActionListener() { - @Override - public void onResponse(BulkByScrollResponse bulkByScrollResponse) { - if (bulkByScrollResponse.getVersionConflicts() > 0) { - throw new RetryException("删除索引失败，es内容版本冲突"); - } - } - - @Override - public void onFailure(Exception e) { - throw new RetryException("删除索引失败，" + e.getMessage()); - } - }); + try { + this.client.deleteByQuery(deleteByQueryRequest, RequestOptions.DEFAULT); + } catch (IOException e) { + log.error("删除索引出现异常", e); + } }