Java操作es插入数据后，立即查询没结果解决办法-Toy模板网

这篇具有很好参考价值的文章主要介绍了Java操作es插入数据后，立即查询没结果解决办法。希望对大家有所帮助。如果存在错误或未考虑完全的地方，请大家不吝赐教，您也可以点击"举报违法"按钮提交疑问。

一、为什么每次在批量添加或者删除完成之后查询结果没有更新？

原因：ES默认不执行刷新操作，需要手动设置参数才能在更新文档后立即刷新。
从以下源码中可以看出刷新策略有三种： NONE(“false”)、IMMEDIATE(“true”)、WAIT_UNTIL(“wait_for”)

 public static enum RefreshPolicy implements Writeable {
 		/**
 		 *请求向Elasticsearch提交了数据，不进行数据刷新，直接结束请求。
 		 *这种策略的优点是资源消耗低、写入性能高，缺点是实时性低、数据安全性差。
 		**/
        NONE("false"),
        /**
 		 *请求向Elasticsearch提交了数据，立即进行数据刷新，然后再结束请求。
 		 *这种策略的优点是实时性高、操作延时短，缺点是资源消耗高。
 		**/
        IMMEDIATE("true"),
        /**
 		 *请求向Elasticsearch提交了数据，等待数据完成刷新，然后再结束请求。
 		 *这种策略的优点是实时性和资源消耗之间有一个平衡，缺点是操作延时较长。
 		**/
        WAIT_UNTIL("wait_for");
        private final String value;

        private RefreshPolicy(String value) {
            this.value = value;
        }

        public String getValue() {
            return this.value;
        }

        public static WriteRequest.RefreshPolicy parse(String value) {
            WriteRequest.RefreshPolicy[] var1 = values();
            int var2 = var1.length;

            for(int var3 = 0; var3 < var2; ++var3) {
                WriteRequest.RefreshPolicy policy = var1[var3];
                if (policy.getValue().equals(value)) {
                    return policy;
                }
            }

            if ("".equals(value)) {
                return IMMEDIATE;
            } else {
                throw new IllegalArgumentException("Unknown value for refresh: [" + value + "].");
            }
        }

        public static WriteRequest.RefreshPolicy readFrom(StreamInput in) throws IOException {
            return values()[in.readByte()];
        }

        public void writeTo(StreamOutput out) throws IOException {
            out.writeByte((byte)this.ordinal());
        }
    }

二、具体操作：

request.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);//插入完成后立即强制刷新索引

添加位置如下：

 //单条增加
 IndexRequest request = new IndexRequest();
 request.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
 //后面省略。。。。。
 


//批量增加
BulkRequest bulkRequest = new BulkRequest();
bulkRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);
//同上