企业官网建设流程全解析

济南地区做企业网站的公司,自己做装修图网站,仿搜狐视频网站源码,今天的新闻有哪些文章目录 在并发情况下#xff0c;Elasticsearch 如何保证读写一致#xff1f;引言什么是读写一致性#xff1f;Elasticsearch 的架构基础分片与副本的作用 写一致性#xff1a;如何保证写入的数据被所有节点看到#xff1f;1. 索引请求的默认行为代码示例#xff1a;默认…文章目录在并发情况下Elasticsearch 如何保证读写一致引言什么是读写一致性Elasticsearch 的架构基础分片与副本的作用写一致性如何保证写入的数据被所有节点看到1. 索引请求的默认行为代码示例默认行为2. 控制写一致性常见的一致性级别代码示例设置一致性级别3. 索引请求的返回结果代码示例处理写入响应读一致性如何保证读取的数据是最新的1. 默认的读行为代码示例默认的读操作2. 控制读一致性代码示例强制刷新代码示例设置读一致性级别3. 如何选择一致性级别Elasticsearch 的一致性机制背后的技术1. 分片分配策略代码示例查看索引的分片信息2. 写入流程图解写入流程3. 读取流程图解读取流程4. 数据同步机制代码示例查看副本状态总结与最佳实践最佳实践常见问题解答Q1: 什么是最终一致性Q2: 如何确保强一致性Q3: 分片和副本的关系是什么代码示例总结最后的话希望通过这篇文章大家能够对 Elasticsearch 的读写一致性有一个全面的了解。如果还有疑问或者想深入探讨某些部分欢迎随时留言讨论 领取 | 1000 套高质量面试题大合集无套路闫工带你飞一把在并发情况下Elasticsearch 如何保证读写一致引言大家好我是闫工今天我们要聊一个在高并发场景下非常重要的问题——Elasticsearch 的读写一致性。作为一个经常被问到的面试题这个问题背后其实涉及到 Elasticsearch 的很多核心机制。不过别担心我会用最通俗易懂的语言结合一些幽默的比喻带大家一步步搞清楚这个问题。什么是读写一致性首先我得明确一下什么是“读写一致性”。简单来说就是在多节点的分布式系统中如何确保不同节点上的数据是一致的。也就是说在高并发的情况下无论是写入还是查询操作都能保证所有节点看到的数据是相同的。这听起来像是一个很简单的需求但实际上实现起来非常复杂。Elasticsearch 的架构基础在深入读写一致性之前我得先和大家聊一下 Elasticsearch 的基本架构。Elasticsearch 是一个分布式的搜索引擎它通过分片Shard和副本Replica来实现高可用性和负载均衡。每个索引Index会被分成多个分片默认是5个分片。每个分片还可以有多个副本通常情况下是1个副本。分片与副本的作用分片Shard将数据分散到不同的节点上提高查询性能。副本Replica为了保证高可用性当一个节点挂掉时其他节点上的副本可以接替它的工作。举个例子假设你有一个索引叫users它有5个分片和1个副本。那么这个索引总共有10个分片5个主分片 5个副分片。这些分片会被分布到不同的节点上确保数据不会集中在某一个节点上。写一致性如何保证写入的数据被所有节点看到在高并发场景下写操作可能会同时发生在多个节点上。那么如何保证所有的写操作最终都能被所有节点看到呢Elasticsearch 提供了几种一致性级别1. 索引请求的默认行为默认情况下Elasticsearch 的写操作是最终一致性Eventual Consistency的。这意味着当你向某个节点发送一个写入请求时这个节点会将数据写入自己的分片副本并立即返回成功响应。而其他节点可能需要一些时间才能同步到这个新数据。代码示例默认行为// 默认情况下Elasticsearch 是最终一致的client.index(indexRequest,RequestOptions.DEFAULT);2. 控制写一致性不过Elasticsearch 提供了一些参数来控制写操作的一致性级别。最常见的参数是consistencyLevel。常见的一致性级别ONE只要一个副本包括主分片确认了写入就认为成功。QUORUM需要半数以上的副本确认写入才能成功。ALL所有副本都必须确认写入才能成功。代码示例设置一致性级别IndexRequestindexRequestnewIndexRequest(users).id(1).source(jsonBuilder().startObject().field(name,John).field(age,30).endObject()));// 设置一致性级别为 QUORUMindexRequest.setConsistencyLevel(WriteConsistencyLevel.QUORUM);client.index(indexRequest,RequestOptions.DEFAULT);3. 索引请求的返回结果在写操作完成后Elasticsearch 会返回一个响应对象。这个响应中包含了写入是否成功的状态。代码示例处理写入响应IndexResponseresponseclient.index(indexRequest,RequestOptions.DEFAULT);if(response.getResult()DocWriteResult.Result.CREATED){System.out.println(Document created successfully);}elseif(response.getResult()DocWriteResult.Result.UPDATED){System.out.println(Document updated successfully);}读一致性如何保证读取的数据是最新的写操作的一致性我们已经聊完了接下来是读一致性。读一致性主要关注的是在高并发场景下读取到的数据是否是最新的。1. 默认的读行为默认情况下Elasticsearch 的读操作也是最终一致的。这意味着当你向某个节点发起一个查询请求时它可能会返回旧的数据因为其他节点可能还没有同步到最新的写入数据。代码示例默认的读操作SearchRequestsearchRequestnewSearchRequest(users);SearchResponsesearchResponseclient.search(searchRequest,RequestOptions.DEFAULT);// 处理搜索结果2. 控制读一致性为了保证读一致性Elasticsearch 提供了两种主要的机制强制刷新Force Refresh强制 Elasticsearch 刷新所有索引段确保数据立即可见。一致性级别Consistency Level在读操作时设置一致性级别来控制返回的数据版本。代码示例强制刷新// 强制刷新指定的索引client.indices().refresh(newRefreshRequest(users),RequestOptions.DEFAULT);代码示例设置读一致性级别SearchRequestsearchRequestnewSearchRequest(users);searchRequest.setConsistencyLevel(ReadConsistencyLevel.QUORUM);SearchResponsesearchResponseclient.search(searchRequest,RequestOptions.DEFAULT);3. 如何选择一致性级别在实际应用中如何选择读写的一致性级别呢这取决于你的业务需求如果你对实时性要求很高比如电商系统的库存信息那么可能需要使用强一致的方式。如果你对延迟敏感比如日志系统可以选择默认的最终一致性。Elasticsearch 的一致性机制背后的技术现在我们已经了解了读写一致性的基本概念和配置接下来我得和大家聊聊 Elasticsearch 是如何实现这些一致性的。这部分可能会有点复杂但我会尽量用简单易懂的语言解释。1. 分片分配策略Elasticsearch 使用分片Shard来分布数据每个分片都有一个主副本Primary Replica和多个副副本Replica。在写入数据时默认情况下数据会先被写入到主副本然后异步地复制到其他副副本。代码示例查看索引的分片信息// 查看索引的分片分配情况client.indices().getShardallocator(newGetShardAllocatorRequest(users),RequestOptions.DEFAULT);2. 写入流程当一个写入请求到达 Elasticsearch 时会经历以下几个步骤请求被路由到对应的主副本。主副本确认写入成功并将数据写入自己的日志文件。数据被异步地复制到其他副副本。图解写入流程客户端 - 路由器 - 主副本 (写入成功) - 副副本1, 副副本2, ... (异步复制)3. 读取流程当一个读请求到达 Elasticsearch 时会经历以下几个步骤请求被路由到对应的分片。分片返回当前最新的数据版本。图解读取流程客户端 - 路由器 - 分片 (返回数据)4. 数据同步机制Elasticsearch 使用两种主要的数据同步机制全量同步Full Sync在节点加入或离开集群时进行一次性的数据同步。增量同步Incremental Sync在日常运行中通过复制日志来保持副本的一致性。代码示例查看副本状态// 查看索引的副本分配情况client.indices().getShardallocator(newGetShardAllocatorRequest(users),RequestOptions.DEFAULT);总结与最佳实践读写一致性是 Elasticsearch 中非常重要的概念它直接影响了系统的可用性和数据准确性。在实际应用中我们需要根据业务需求来选择合适的一致性级别并合理配置系统参数。最佳实践了解业务需求明确你的系统对一致性的要求。合理配置一致性级别不要一味追求强一致性而牺牲性能。监控集群状态使用 Elasticsearch 的监控工具来实时查看集群的健康状况。优化索引设置根据业务需求调整分片数和副本数。常见问题解答Q1: 什么是最终一致性A: 最终一致性是指在系统中所有节点经过一定时间后能够达到一致的状态。在这种模式下读操作可能不会立即看到最新的写入数据。Q2: 如何确保强一致性A: 在 Elasticsearch 中可以通过设置consistencyLevel参数为QUORUM或ALL来实现强一致性。Q3: 分片和副本的关系是什么A: 每个索引可以被分成多个分片Shard每个分片都有一个主副本和多个副副本。主副本负责处理写入请求而副副本则用于提高读取性能和提供数据冗余。代码示例总结设置一致性级别在写操作时可以通过setConsistencyLevel方法来设置。强制刷新在需要确保数据立即可见时可以使用refreshAPI。最后的话希望通过这篇文章大家能够对 Elasticsearch 的读写一致性有一个全面的了解。如果还有疑问或者想深入探讨某些部分欢迎随时留言讨论 领取 | 1000 套高质量面试题大合集无套路闫工带你飞一把你想做外包吗闫工就是外包出身但我已经上岸了你也想上岸吗闫工精心准备了程序准备面试想系统提升技术实力闫工精心整理了1000 套涵盖前端、后端、算法、数据库、操作系统、网络、设计模式等方向的面试真题 详细解析并附赠高频考点总结、简历模板、面经合集等实用资料✅ 覆盖大厂高频题型✅ 按知识点分类查漏补缺超方便✅ 持续更新助你拿下心仪 Offer免费领取 点击这里获取资料已帮助数千位开发者成功上岸下一个就是你✨