1. 概述

今天我们来聊一下Elasticsearch（ES）的滚动搜索与批量操作。

2. Elasticsearch（ES）的滚动搜索

2.1 概述

滚动搜索我们经常能够用到，例如：推荐列表，此类列表通常不需要分页，而是一直上滑刷新。

滚动搜索的原理是根据固定的排序规则先加载一部分数据，当用户再刷新时，从上次加载的最后一条数据的位置再加载同样数量的数据，下一次刷新同理。

2.2 第一次搜索请求

第一次搜索的请求比较特殊，与之后的搜索请求的url和参数不同。

参数中的 scroll=1m，是指滚动搜索的下一次搜索，必须在1分钟之内。

size是每次滚动显示的条数。

POST http://192.168.1.8:9200/index_user/_search?scroll=1m

参数：

{
    "query": {
        "match_all": {}
    },
    "sort": [
        {
            "age": "desc"
        }
    ],
    "size": 1
}

响应：

{
    "_scroll_id": "FGluY2x1ZGVfY29udGV4dF91dWlkDnF1ZXJ5VGhlbkZldGNoBRZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHAWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHEWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG8WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG0WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG4WejhoNTc2clNScU9NWlpHQ3A4VXJGUQ==",
"took": 7,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": {
            "value": 3,
            "relation": "eq"
        },
        "max_score": null,
        "hits": [
            {
                "_index": "index_user",
                "_type": "_doc",
                "_id": "2",
                "_score": null,
                "_source": {
                    "user_id": "2",
                    "name": "夏维尔",
                    "login_name": "xwe",
                    "age": 28,
                    "birthday": "1992-06-06",
                    "desc": "我是一名高级开发经理，每天坐地铁上班，在北京住，从不堵车",
                    "head_url": "https://www.zhuifengren.cn/img/xwe.jpg"
                },
                "sort": [
                    28
                ]
            }
        ]
    }
}

2.3 之后的搜索

参数中 scroll_id 是第一次搜索返回的。

POST http://192.168.1.8:9200/_search/scroll

参数：

{
    "scroll_id": "FGluY2x1ZGVfY29udGV4dF91dWlkDnF1ZXJ5VGhlbkZldGNoBRZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHAWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAHEWejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG8WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG0WejhoNTc2clNScU9NWlpHQ3A4VXJGURZhVFFQSDRqeVJQZXlNZ2U1VXFyaHZBAAAAAAAAAG4WejhoNTc2clNScU9NWlpHQ3A4VXJGUQ==",
    "scroll":"1m"
}

响应：

{
    "_scroll_id": "FGluY2x1ZGVfY29udGV4dF91dWlkDnF1ZXJ5VGhlbkZldGNoBRYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAG8WejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAHEWejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAHIWejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAHAWejhoNTc2clNScU9NWlpHQ3A4VXJGURYxMDBJOHhrUFJwdUdkUHJpbE52VjlBAAAAAAAAAG4WejhoNTc2clNScU9NWlpHQ3A4VXJGUQ==",
    "took": 12,
    "timed_out": false,
    "_shards": {
        "total": 5,
        "successful": 5,
        "skipped": 0,
        "failed": 0
    },
    "hits": {
        "total": {
            "value": 6,
            "relation": "eq"
        },
        "max_score": null,
        "hits": [
            {
                "_index": "index_user",
                "_type": "_doc",
                "_id": "1",
                "_score": null,
                "_source": {
                    "user_id": "1",
                    "name": "僵尸猎手",
                    "login_name": "jsls",
                    "age": 25,
                    "birthday": "1990-03-01",
                    "desc": "我是一名房产经纪人，现在转行了，目前是一名运输工人",
                    "head_url": "https://www.zhuifengren.cn/img/jsls.jpg"
                },
                "sort": [
                    25
                ]
            }
        ]
    }
}

3. Elasticsearch（ES）的文档批量操作

3.1 批量依据ID查询文档

POST http://192.168.1.8:9200/index_user/_doc/_mget

参数：

{
    "ids":["1", "3"]
}

3.2 批量新增文档1

注意：参数的最后一行，需要以回车（'\n'）结尾。

其中一条报错，不会影响其他数据正常执行。

如果新增数据的id已存在会报错。

POST http://192.168.1.8:9200/_bulk

参数：

{"create":{"_index":"index_user", "_type":"_doc", "_id": "5"}}
{"user_id":"5", "name":"姓名5"}
{"create":{"_index":"index_user", "_type":"_doc", "_id": "6"}}
{"user_id":"6", "name":"姓名6"}
{"create":{"_index":"index_user", "_type":"_doc", "_id": "7"}}
{"user_id":"6", "name":"姓名7"}

3.3 批量新增文档2

批量新增文档的第二种写法。

POST http://192.168.1.8:9200/index_user/_doc/_bulk

参数：

{"create":{"_id": "5"}}
{"user_id":"5", "name":"姓名5"}
{"create":{"_id": "6"}}
{"user_id":"6", "name":"姓名6"}
{"create":{"_id": "7"}}
{"user_id":"6", "name":"姓名7"}

3.4 批量新增或更新文档

当id不存在，会新增文档，id已存在，会更新文档。

POST http://192.168.1.8:9200/index_user/_doc/_bulk

参数：

{"index":{"_id": "5"}}
{"user_id":"5", "name":"姓名5_1"}
{"index":{"_id": "6"}}
{"user_id":"6", "name":"姓名6_1"}
{"index":{"_id": "8"}}
{"user_id":"8", "name":"姓名8_1"}

3.5 批量局部更新文档

当id不存在，会报错。

POST http://192.168.1.8:9200/index_user/_doc/_bulk

参数：

{"update":{"_id": "5"}}
{"doc": {"user_id":"5", "name":"姓名5_2"}}
{"update":{"_id": "6"}}
{"doc": {"user_id":"6", "name":"姓名6_2"}}
{"update":{"_id": "9"}}
{"doc": {"user_id":"9", "name":"姓名9_1"}}

3.6 批量删除文档

POST http://192.168.1.8:9200/index_user/_doc/_bulk

参数：

{"delete":{"_id": "5"}}
{"delete":{"_id": "6"}}

3.7 其他说明

批量新增、更新、删除的操作，可以在一次请求完成。

每次批量新增、更新、删除的请求，请求体不宜过大，控制在1000条之内。

4. 综述

今天简单聊了一下 Elasticsearch（ES）的滚动搜索与批量操作，希望可以对大家的工作有所帮助。

欢迎帮忙点赞、评论、加关注 ：）

关注追风人聊Java，每天更新Java干货。