添加刷新机制

src/main/java/com/viontech/match/service/PersonService.java

@@ -175,7 +175,9 @@ public class PersonService {
         if (bulkRequest.requests().size() == 0) {
             return null;
         }
-        return client.bulk(bulkRequest, RequestOptions.DEFAULT);
+        BulkResponse bulk = client.bulk(bulkRequest, RequestOptions.DEFAULT);
+        poolService.refreshPool(poolId);
+        return bulk;
     }
 
     /**

src/main/java/com/viontech/match/service/PoolService.java

@@ -10,6 +10,8 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.http.HttpEntity;
 import org.elasticsearch.ElasticsearchStatusException;
 import org.elasticsearch.action.admin.indices.delete.DeleteIndexRequest;
+import org.elasticsearch.action.admin.indices.refresh.RefreshRequest;
+import org.elasticsearch.action.admin.indices.refresh.RefreshResponse;
 import org.elasticsearch.action.bulk.BulkResponse;
 import org.elasticsearch.action.support.master.AcknowledgedResponse;
 import org.elasticsearch.client.*;
@@ -170,6 +172,12 @@ public class PoolService {
         }
     }
 
+    public void refreshPool(String... poolIds) throws IOException {
+        RefreshRequest refreshRequest = new RefreshRequest(poolIds);
+        RefreshResponse refresh = client.indices().refresh(refreshRequest, RequestOptions.DEFAULT);
+        log.info("刷新索引:{},成功:{},失败:{}", poolIds, refresh.getSuccessfulShards(), refresh.getFailedShards());
+    }
+
 
     public XContentBuilder getCreateIndexContentBuilder() throws IOException {
         XContentBuilder builder = XContentFactory.jsonBuilder();