一、问题发现

有段代码更新 ES中的数据状态，将未读置成已读。是查一批，更新一批，再查再更新。

public Boolean updateDealStatus(WarningQuery warningQuery) {

....省略不重要的代码

while (true) {

// 调用服务

// ES查询不分页一次就出来10条

List list = warningEsDao.findByQuery(WarningZsdRiskEsEntity.class, warningZsdRiskQuery, esSort);

// 为空或者null就不继续跑了

if (list == null || list.isEmpty()) {

break;

}

log.info("查询出来的数量" + list.getSize());

// 将一批数据都置成已读

for (WarningZsdRiskEsEntity esEntity : list) {

esEntity.setDealStatus(1);

esEntity.setModified(System.currentTimeMillis());

warningEsDao.save(esEntity);

}

}

return true;

}

在测试的时候发现有问题。

我提前看了ES里这个范围的数据就27条，结果打印查询数量的日志log.info("查询出来的数量" + list.getSize());的结果类似这样。

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 10

查询出来的数量 8

查询出来的数量 7

查询出来的数量 2

查询出来的数量 0

这个肯定是有问题的，27就行了，结果查了这么多次。这个问题的原因就是 –  –ES 更新数据是有延迟的，也就是搜索只能支持“近实时”。

二、ES 近实时搜索介绍

在 Elasticsearch 中，写入和打开一个新段的轻量的过程叫做 refresh 。 默认情况下每个分片会每秒自动刷新一次。这就是为什么我们说 Elasticsearch 是 近 实时搜索:

文档的变化并不是立即对搜索可见，但会在一秒之内变为可见。

这些行为可能会对新用户造成困惑: 他们索引了一个文档然后尝试搜索它，但却没有搜到。这个问题的解决办法是用 refresh API 执行一次手动刷新

POST /_refresh // 刷新(Refresh)所有的索引。

POST /blogs/_refresh // 只刷新(Refresh) blogs 索引

尽管刷新是比提交轻量很多的操作，它还是会有性能开销。当写测试的时候， 手动刷新很有用，但是不要在生产环境下每次索引一个文档都去手动刷新。 相反，你的应用需要意识到 Elasticsearch 的近实时的性质，并接受它的不足。

三、解决问题

好知道了ES 的这个特性，造成了我们的bug 那就 扬长避短。

两种解决方法：

1、更新后等1s在去查。

2、用Scroll 去查，一次查询有个快照。我们只会搂一次快照版本的数据，然后进行写操作置状态。就不用管了。不会把一次已经置了状态的再搂出来的。

第二种方法的代码 。

public Boolean updateDealStatus(WarningQuery warningQuery) {

....省略不重要的代码

// 滑轮初始设置为null

String scrollId = null;

while (true) {

// 调用服务

// ES查询

EsScrollResponse response = warningEsDao.listByQueryScroll(WarningZsdRiskEsEntity.class, warningZsdRiskQuery, scrollId, 200);

// 为空或者null就不继续跑了

if (response == null || response.getData() == null || response.getData().isEmpty()) {

break;

}

// 将一批数据都置成已读

for (WarningZsdRiskEsEntity esEntity : response.getData()) {

esEntity.setDealStatus(1);

esEntity.setModified(System.currentTimeMillis());

warningEsDao.save(esEntity);

}

scrollId = response.getScrollId();

}

return true;

}