【Elasticsearch】retry_on_conflict
在 Elasticsearch 中，`retry_on_conflict` 是 `_update` 和 `_update_by_query` API 的一个参数，用于处理并发冲突。当多个客户端同时尝试更新同一个文档时，可能会发生版本冲突（version conflict）。`retry_on_conflict` 参数允许 Elasticsearch 在遇到冲突时自动重试更新操作。
版本冲突的背景
Elasticsearch 使用乐观锁机制来处理并发更新。每个文档都有一个版本号（`_version`），每次更新文档时，版本号会递增。如果在更新操作期间，文档的版本号发生了变化（即其他客户端已经更新了该文档），Elasticsearch 会抛出一个版本冲突错误。
`retry_on_conflict` 的作用
`retry_on_conflict` 参数允许你指定在遇到版本冲突时，Elasticsearch 应该重试更新操作的次数。如果重试次数耗尽后仍然发生冲突，更新操作将失败。
使用场景
- 高并发环境：在多用户同时更新同一个文档的场景中，`retry_on_conflict` 可以减少因版本冲突导致的更新失败。
- 自动重试机制：通过设置 `retry_on_conflict`，可以简化客户端的逻辑，让 Elasticsearch 自动处理冲突。
示例
单文档更新（`_update` API）
假设你希望在更新文档时，如果发生版本冲突，Elasticsearch 自动重试最多 3 次：
```json
POST /my_index/_update/1
{
"retry_on_conflict": 3,
"doc": {
"age": 30
}
}
```
批量更新（`_update_by_query` API）
在批量更新操作中，`retry_on_conflict` 也可以用来处理冲突：
```json
POST /my_index/_update_by_query
{
"script": {
"source": "ctx._source.age += params.increment",
"lang": "painless",
"params": {
"increment": 5
}
},
"query": {
"match_all": {}
},
"retry_on_conflict": 3
}
```
参数说明
- `retry_on_conflict`：一个整数值，表示在遇到版本冲突时，Elasticsearch 将重试更新操作的次数。
- 默认值为 `0`，即不自动重试。
- 如果设置为 `3`，Elasticsearch 将在第一次冲突后重试最多 3 次。
注意事项
1. 重试次数的限制：
- 虽然 `retry_on_conflict` 可以减少因冲突导致的失败，但过多的重试可能会导致性能问题，尤其是在高并发场景下。
- 建议根据实际场景合理设置重试次数。
2. 客户端逻辑：
- 如果 `retry_on_conflict` 无法解决冲突问题，客户端可能需要实现自己的重试逻辑，或者在更新操作失败后采取其他措施。
3. 版本冲突的根本原因：
- 如果频繁发生版本冲突，可能需要检查应用逻辑，避免多个客户端同时更新同一个文档。例如，可以通过合理的数据设计或锁机制来减少冲突。
总结
`retry_on_conflict` 是一个非常实用的参数，用于在更新操作中自动处理版本冲突。通过合理设置该参数，可以减少因并发更新导致的失败，提高系统的健壮性。