百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

从moved、ask到智能客户端:一次彻底搞懂RedisCluster的数据路由

mhr18 2025-08-05 19:38 8 浏览 0 评论

1 moved重定向

每个节点通信共享Redis Cluster中槽和集群中对应节点的关系。

  1. 客户端向Redis Cluster的任一节点发送命令
  2. 接收命令的节点再计算自己的槽和对应节点

如果保存数据的槽被分配给当前节点,则去槽中执行命令,并把命令执行结果返回给客户端:

127.0.0.1:6379> cluster keyslot hello
(integer) 866   # 直接返回

键槽计算公式:

slot = CRC16(key) mod 16384

如果保存数据的槽不在当前节点的管理范围内,则向客户端返回moved重定向异常

  1. 客户端接收到节点返回的结果,如果是moved异常,则从moved异常中获取目标节点的信息
  2. 客户端向目标节点发送命令,获取命令执行结果

重定向流程

  1. 客户端向节点6379发送 'set php best' 命令
  2. 节点6379计算键'php'对应槽位9244
  3. 槽位9244不在节点6379管理范围内(0~5460)
  4. 返回MOVED重定向: 'moved 9244 127.0.0.1:6380'
  5. 客户端根据重定向信息连接节点6380
  6. 节点6380成功执行命令并返回OK

键槽信息:

CRC16('php') mod 16384 = 9244

客户端不会自动找到目标节点执行命令,需要二次执行

2 ask重定向

集群伸缩时,需数据迁移。

当客户端访问某key,节点告诉客户端key在源节点,再去源节点访问时,却发现key已迁移到目标节点,就会返回ask。

![](/Users/javaedge/Library/Application Support/typora-user-images/image-20250710161135067.png)

  1. 客户端向目标节点发送命令,目标节点中的槽已经迁移到其它节点
  2. 目标节点会返回ask转向给客户端
  3. 客户端向新节点发送Asking命令
  4. 再向新节点发送命令
  5. 新节点执行命令,把命令执行结果返回给客户端

为啥不用MOVED重定向?

虽然MOVED意味着我们认为哈希槽由另一节点永久提供,且应对指定节点尝试下一个查询,所以ASK意味着仅将下一个查询发送到指定节点。

需要这样做,是因为下一个关于哈希槽的查询可能是关于仍在A中的键,因此我们始终希望客户端尝试A,然后在需要时尝试B。由于只有16384个可用的哈希槽中有一个发生,因此集群层面的性能下降可接受。

3 moved V.S ask

虽然都是客户端重定向,但是:

  • moved:槽已确定转移
  • ask:槽还在迁移中

4 智能客户端

为追求性能。

4.1 设计思路

  • 从集群中选一个可运行节点,用Cluster slots初始化槽和节点映射
  • 将Cluster slots结果映射在本地,为每个节点创建JedisPool,之后即可进行数据读写操作

4.2 注意

  • 每个JedisPool缓存了slot和节点node的关系
  • key和slot:对key进行CRC16,hash后与16383取余得到的结果就是slot槽
  • JedisCluster启动时,已知key、slot和node之间关系,可找到目标节点
  • JedisCluster对目标节点发送命令,目标节点直接响应给JedisCluster
  • 如果JedisCluster与目标节点连接出错,则JedisCluster会知道连接的节点是一个错误的节点
  • 此时JedisCluster会随机节点发送命令,随机节点返回moved异常给JedisCluster
  • JedisCluster会重新初始化slot与node节点的缓存关系,再向新的目标节点发命令,目标命令执行命令并向JedisCluster响应
  • 若命令发送次数超过5次,抛"Too many cluster redirection!"

架构设计

基图:

全图:

本文已收录在Github,关注我,紧跟本系列专栏文章,咱们下篇再续!

  • 魔都架构师 | 全网30W技术追随者
  • 大厂分布式系统/数据中台实战专家
  • 主导交易系统百万级流量调优 & 车联网平台架构
  • AIGC应用开发先行者 | 区块链落地实践者
  • 以技术驱动创新,我们的征途是改变世界!
  • 实战干货:编程严选网

相关推荐

订单超时自动取消业务的 N 种实现方案,从原理到落地全解析

在分布式系统架构中,订单超时自动取消机制是保障业务一致性的关键组件。某电商平台曾因超时处理机制缺陷导致日均3000+订单库存锁定异常,直接损失超50万元/天。本文将从技术原理、实现细节、...

使用Spring Boot 3开发时,如何选择合适的分布式技术?

作为互联网大厂的后端开发人员,当你满怀期待地用上SpringBoot3,准备在项目中大显身手时,却发现一个棘手的问题摆在面前:面对众多分布式技术,究竟该如何选择,才能让SpringBoot...

数据库内存爆满怎么办?99%的程序员都踩过这个坑!

你的数据库是不是又双叒叕内存爆满了?!服务器监控一片红色警告,老板在群里@所有人,运维同事的电话打爆了手机...这种场景是不是特别熟悉?别慌!作为一个在数据库优化这条路上摸爬滚打了10年的老司机,今天...

springboot利用Redisson 实现缓存与数据库双写不一致问题

使用了Redisson来操作Redis分布式锁,主要功能是从缓存和数据库中获取商品信息,以下是针对并发时更新缓存和数据库带来不一致问题的解决方案1.基于读写锁和删除缓存策略在并发更新场景下,...

外贸独立站数据库炸了?对象缓存让你起死回生

上周黑五,一个客户眼睁睁看着服务器CPU飙到100%——每次页面加载要查87次数据库。这让我想起2024年Pantheon的测试:Redis缓存能把WooCommerce查询速度提升20倍。跨境电商最...

手把手教你在 Spring Boot3 里纯编码实现自定义分布式锁

为什么要自己实现分布式锁?你是不是早就受够了引入各种第三方依赖时的繁琐?尤其是分布式锁这块,每次集成Redisson或者Zookeeper,都得额外维护一堆配置,有时候还会因为版本兼容问题头疼半...

如何设计一个支持百万级实时数据推送的WebSocket集群架构?

面试解答:要设计一个支持百万级实时数据推送的WebSocket集群架构,需从**连接管理、负载均衡、水平扩展、容灾恢复**四个维度切入:连接层设计-**长连接优化**:采用Netty或Und...

Redis数据结构总结——面试最常问到的知识点

Redis作为主流的nosql存储,面试时经常会问到。其主要场景是用作缓存,分布式锁,分布式session,消息队列,发布订阅等等。其存储结构主要有String,List,Set,Hash,Sort...

skynet服务的缺陷 lua死循环

服务端高级架构—云风的skynet这边有一个关于云风skynet的视频推荐给大家观看点击就可以观看了!skynet是一套多人在线游戏的轻量级服务端框架,使用C+Lua开发。skynet的显著优点是,...

七年Java开发的一路辛酸史:分享面试京东、阿里、美团后的心得

前言我觉得有一个能够找一份大厂的offer的想法,这是很正常的,这并不是我们的饭后谈资而是每个技术人的追求。像阿里、腾讯、美团、字节跳动、京东等等的技术氛围与技术规范度还是要明显优于一些创业型公司...

mysql mogodb es redis数据库之间的区别

1.MySQL应用场景概念:关系型数据库,基于关系模型,使用表和行存储数据。优点:支持ACID事务,数据具有很高的一致性和完整性。缺点:垂直扩展能力有限,需要分库分表等方式扩展。对于复杂的查询和大量的...

redis,memcached,nginx网络组件

1.理解阻塞io,非阻塞io,同步io,异步io的区别2.理解BIO和AIO的区别io多路复用只负责io检测,不负责io操作阻塞io中的write,能写多少是多少,只要写成功就返回,譬如准备写500字...

SpringBoot+Vue+Redis实现验证码功能

一个小时只允许发三次验证码。一次验证码有效期二分钟。SpringBoot整合Redis...

AWS MemoryDB 可观测最佳实践

AWSMemoryDB介绍AmazonMemoryDB是一种完全托管的、内存中数据存储服务,专为需要极低延迟和高吞吐量的应用程序而设计。它与Redis和Memcached相似,但具有更...

从0构建大型AI推荐系统:实时化引擎从工具到生态的演进

在AI浪潮席卷各行各业的今天,推荐系统正从幕后走向前台,成为用户体验的核心驱动力。本文将带你深入探索一个大型AI推荐系统从零起步的全过程,揭示实时化引擎如何从单一工具演进为复杂生态的关键路径。无论你是...

取消回复欢迎 发表评论: