当前位置: 首页 > news >正文

Redis设计与实现第17章 -- 集群 总结2(执行命令 重新分片)

17.3 在集群中执行命令

接收命令的节点会计算出命令要处理的数据库键属于哪个槽,并检查这个槽是否指派给了自己:

  • 如果是的话,直接执行这个命令

  • 否则,节点向客户端返回一个MOVED错误,指引客户端转向redirect至正确的节点,并再次发送之前想要执行的命令

17.3.1 计算键属于哪个槽

节点使用CRC16(key&16383)来计算键key属于哪个槽,其中CRC16语句用于计算键key的CRC-16校验和,而&16383语句则用于计算出一个介于0~16383之间的整数作为键key的槽号

使用CLUSTER KEYSLOT <key>可以查看一个给定键属于哪个槽

17.3.2 判断槽是否由当前节点负责处理

当节点计算出键所属的槽i之后,节点就会检查自己在clusterState.slots数组的项i,判断键所在的槽是否由自己负责:

  • 如果clusterState.slots[i] = clusterState.myself,说明槽i由当前节点负责

  • 否则,节点会根据clusterState.slots[i] 指向的clusterNode结构所记录的节点IP和端口号,向客户端返回MOVED错误,指引客户端转向正确节点。

17.3.3 MOVED错误

MOVED错误的格式为MOVED <slot> <ip>:<port>,其中slot为键所在的槽,而ip/port则是负责处理槽slot的节点的IP地址和端口号。客户端会根据MOVED错误中提供的IP地址和端口号,转向至负责处理槽slot的节点,并向该节点重新发送之前想要执行的命令

一个集群客户端通常会与集群的多个节点创建套接字连接,而所谓的节点转向实际上是换一个套接字来发送命令。如果客户端未与想要转向的节点创建套接字连接,客户端会先根据MOVED错误提供的IP地址和端口号来连接节点,然后再进行转向。

要注意,集群模式的客户端收到MOVED错误后,是根据MOVED错误自动进行节点转向的,并打印出转向信息。但是如果是单机stand alone模式的客户端,MOVED错误就会被客户端打印出来。

17.3.4 节点数据库的实现

节点只能使用0号数据库,而且除了将键值对保存在数据库里面之外,还会用clusterState结构里的slots_to_keys跳跃表来保存槽和键之间的关系,跳跃表里每个节点的分值score都是一个槽号,而每个节点的成员member都是一个数据库键

通过跳跃表,节点可以很方便的对属于某个或某些槽的所有数据库键进行批量操作,例如CLUSTER GETKEYSINSLOT <slot> <count>命令可以返回最多count个属于槽slot的数据库键,就是通过遍历跳跃表实现的

17.4 重新分片

Redis集群的重新分片操作可以将任意数量已经指派给某个节点(源节点)的槽改为指派给另一个节点(目标节点),并且相关槽所属的键值对也会从源节点被移动到目标节点。

重新分片操作可以在线进行,而且源节点和目标节点都可以继续处理命令请求。

是由Redis的集群管理软件redis-trib负责执行的,Redis提供了进行重新分片所需的所有命令,redis-trib则通过向源节点和目标节点发送命令来进行重新分片操作,具体步骤如下:

  1. 对目标节点发送CLUSTER SETSLOT <slot> IMPORTING <source_id> 命令,让目标节点准备好从源节点导入import属于槽slot的键值对

  2. 对源节点发送 CLUSTER SETSLOT <slot> MIGRATE <target_id> 命令,让源节点准备好将属于槽slot的键值对迁移migrate到目标节点

  3. 向源节点发送CLUSTER GETKEYSINSLOT <slot> <count>命令,获得最多count个属于槽slot的键值对的键名key name

  4. 对于步骤3获得的每个键名,redis-trib都向源节点发送一个MIGRATE <target_ip> <target_port> <key_name> 0 <timeout>命令,将被选中的键原子性地从源节点迁移到目标节点

  5. 重复执行步骤3和4,直到源节点保存的所有属于槽slot的键值对都被迁移到目标节点。

  6. redis-trib向集群的任意一个节点发送CLUSTER SETSLOT <slot> NODE <target>命令,将槽slot指派给目标节点,会通过消息发送到整个集群

相关文章:

Redis设计与实现第17章 -- 集群 总结2(执行命令 重新分片)

17.3 在集群中执行命令 接收命令的节点会计算出命令要处理的数据库键属于哪个槽&#xff0c;并检查这个槽是否指派给了自己&#xff1a; 如果是的话&#xff0c;直接执行这个命令 否则&#xff0c;节点向客户端返回一个MOVED错误&#xff0c;指引客户端转向redirect至正确的节…...

微服务搭建----springboot接入Nacos2.x

springboot接入Nacos2.x nacos之前用的版本是1.0的&#xff0c;现在重新搭建一个2.0版本的&#xff0c;学如逆水行舟&#xff0c;不进则退&#xff0c;废话不多说&#xff0c;开搞 1、 nacos2.x搭建 1&#xff0c;首先第一步查询下项目之间的版本对照&#xff0c;不然后期会…...

3.建立本地仓库及常用命令

1.建立本地仓库 要使用Git对我们的代码进行版本控制&#xff0c;首先需要获得本地仓库 1&#xff09;在电脑的任意位置创建一个空目录&#xff0c;作为我们的本地Git仓库 2&#xff09;进入这个目录&#xff0c;右键点击Git Bash 窗口 3&#xff09;执行命令git init 4) 如果创…...

linux arm下获取屏幕事件(rk3588)

1、找到屏幕设备名称 cat /proc/bus/input/devices我的屏幕设备是ILITEK ILITEK-TP&#xff0c;它的设备名称是event1. 2、读取屏幕事件。 方法1&#xff1a; cat /dev/input/event1 | hexdump方法2&#xff1a; 3、c代码实现 #include <stdio.h> #include <unis…...

【机器学习】人工智能与气候变化:利用深度学习与机器学习算法预测和缓解环境影响

&#x1f4dd;个人主页&#xff1a;哈__ 期待您的关注 目录 &#x1f525;引言 1.1 背景介绍 1.2 人工智能与机器学习的崛起 1.3 本文内容概述 &#x1f528;气候变化的挑战 2.1 现今气候变化带来的影响和挑战 2.2 引发关注的气候变化趋势和数据 &#x1f916;人工智能…...

物联网射频识别和RFID开发(二):RFID原理及硬件组成

一、RFID无线识别的原理 &#xff08;一&#xff09;读写器与标签之间的无线电波交互方式 1、电感耦合 2、电磁反向散射耦合 &#xff08;二&#xff09;标签是如何将数据反馈给读写器的 1、电感耦合中的负载调试 2、电磁反向散射耦合中的负载调制 二、RFID无线通信中的调制…...

LeetCode763. 划分字母区间(2024冬季每日一题 23)

给你一个字符串 s 。我们要把这个字符串划分为尽可能多的片段&#xff0c;同一字母最多出现在一个片段中。 注意&#xff0c;划分结果需要满足&#xff1a;将所有划分结果按顺序连接&#xff0c;得到的字符串仍然是 s 。 返回一个表示每个字符串片段的长度的列表。 示例 1&a…...

python调用GPT-4o实时音频 Azure OpenAI GPT-4o Audio and /realtime

发现这块网上信息很少&#xff0c;记录一下 微软azure入口 https://learn.microsoft.com/zh-cn/azure/ai-services/openai/realtime-audio-quickstart?pivotsprogramming-language-ai-studio sdk文档 https://github.com/azure-samples/aoai-realtime-audio-sdk?tabread…...

Hadoop生态圈框架部署 伪集群版(四)- Zookeeper单机部署

文章目录 前言一、Zookeeper单机部署&#xff08;手动部署&#xff09;1. 下载Zookeeper安装包到Linux2. 解压zookeeper安装包3. 配置zookeeper配置文件4. 配置Zookeeper系统环境变量5. 启动Zookeeper6. 停止Zookeeper在这里插入图片描述 注意 前言 本文将详细介绍Zookeeper的…...

LuaJava

一、什么是LuaJava LuaJava是一个Java脚本工具。该工具的目标是允许用Lua编写的脚本操纵用 Java开发的组件。LuaJava允许使用与访问Lua的本机对象相同的语法从Lua访问Java组件&#xff0c;而不需要任何声明或任何类型的预处理。 LuaJava还允许在Lua中实现任何Java接口&#x…...

Maven下载安装、环境配置(超详细)(包括Java环境配置(Windows)、在IDEA中配置Maven)

目录 一、引言 二、下载和安装 Maven &#xff08;1&#xff09;首先保证 Java 的环境是正常的。 1、电脑桌面上右击 " 此电脑 "&#xff0c;点击属性。 2、点击高级系统设置。 3、点击环境变量。 4、找到系统变量中的 Path。 5、点击新建&#xff0c;然后把想要配置…...

Python中的实例方法、静态方法和类方法三者区别?

1、实例方法 不用classmethod和staticmethod修饰的方法为实例方法。在类中定义的方法默认都是实例方法。实例方法最大的特点是它至少要包含一个self参数&#xff0c;用于绑定调用此方法的实例对象&#xff0c;实例方法通常可以用类对象直接调用。 2、类方法 采用classmethod…...

【学习Go编程】

了解Go语言的基本概念&#xff1a; 学习Go的基本语法、数据类型、控制结构等。可以参考官方文档或基础教程来入门。 安装Go环境&#xff1a; 访问Go语言的官方网站&#xff0c;下载并安装适合你操作系统的Go编程环境。配置好环境变量&#xff0c;确保可以在命令行中使用go命令…...

Linux系统:网络

目录 一、网络协议 1.网络协议概念 2.协议分层 3.OSI七层模型和TCP/IP五层&#xff08;或四层&#xff09;模型 4.为什么要有网络协议&#xff1f; 5.网络通信协议的原理 二、网络传输的基本流程 1.局域网的网络传输流程 1.MAC地址 2.局域网通信原理&#xff08;以太网…...

shodan2-批量查找CVE-2019-0708漏洞

声明&#xff01; 学习视频来自B站up主 泷羽sec 有兴趣的师傅可以关注一下&#xff0c;如涉及侵权马上删除文章&#xff0c;笔记只是方便各位师傅的学习和探讨&#xff0c;文章所提到的网站以及内容&#xff0c;只做学习交流&#xff0c;其他均与本人以及泷羽sec团队无关&#…...

面向对象(二)——类和对象(上)

1 类的定义 做了关于对象的很多介绍&#xff0c;终于进入代码编写阶段。 本节中重点介绍类和对象的基本定义&#xff0c;属性和方法的基本使用方式。 【示例】类的定义方式 // 每一个源文件必须有且只有一个public class&#xff0c;并且类名和文件名保持一致&#xff01; …...

Redis3——线程模型与数据结构

Redis3——线程模型与数据结构 本文讲述了redis的单线程模型和IO多线程工作原理&#xff0c;以及几个主要数据结构的实现。 1. Redis的单线程模型 redis6.0之前&#xff0c;一个redis进程只有一个io线程&#xff0c;通过reactor模式可以连接大量客户端&#xff1b;redis6.0为了…...

linux 获取公网流量 tcpdump + python + C++

前言 需求为&#xff0c;统计linux上得上下行公网流量&#xff0c;常规得命令如iftop 、sar、ifstat、nload等只能获取流量得大小&#xff0c;不能区分公私网&#xff0c;所以需要通过抓取网络包并排除私网段才能拿到公网流量。下面提供了一些有效得解决思路&#xff0c;提供了…...

C++知识整理day3类与对象(下)——赋值运算符重载、取地址重载、列表初始化、友元、匿名对象、static

文章目录 1.赋值运算符重载1.1 运算符重载1.2 赋值运算符重载 2.取地址重载2.1 const成员函数2.2 取地址运算符重载 3.类与对象的补充3.1 再探构造函数---初始化列表3.2 类型转换3.3 static成员3.4 友元3.5 内部类3.6 匿名对象3.7 对象拷贝时的编译器优化 1.赋值运算符重载 赋…...

pytest(二)excel数据驱动

一、excel数据驱动 excel文件内容 excel数据驱动使用方法 import openpyxl import pytestdef get_excel():excel_obj openpyxl.load_workbook("../pytest结合数据驱动-excel/data.xlsx")sheet_obj excel_obj["Sheet1"]values sheet_obj.valuescase_li…...

中国科技发展与华人贡献解析

中国科技发展与华人贡献解析纵观全球科技发展的壮阔历程&#xff0c;华人力量始终是不可或缺的核心支柱&#xff0c;中国科技的崛起与腾飞&#xff0c;既离不开本土科研工作者的深耕细作&#xff0c;更得益于海外华人的默默坚守与无私奉献。然而&#xff0c;长期以来&#xff0…...

探索三维流固耦合中岩石试样孔隙度变化的奇妙世界

三维流固耦合&#xff0c;考虑岩石试样孔隙度变化在工程和科学研究领域&#xff0c;三维流固耦合问题一直是备受关注的焦点&#xff0c;而当考虑到岩石试样孔隙度变化时&#xff0c;这个问题更是增添了不少复杂性与趣味性。 三维流固耦合基础概念 简单来说&#xff0c;流固耦合…...

Chord视频时空定位惊艳效果:边界框动态跟踪+毫秒级时间戳可视化呈现

Chord视频时空定位惊艳效果&#xff1a;边界框动态跟踪毫秒级时间戳可视化呈现 1. 工具核心能力展示 Chord视频时空理解工具基于先进的Qwen2.5-VL架构开发&#xff0c;专门解决视频内容分析的复杂需求。与传统图像分析工具不同&#xff0c;Chord能够理解视频中的时序信息&…...

BHVCC AI人工智能大鼠八臂视频迷宫实验步骤 八臂迷宫刺激器

八臂迷宫是一种用于研究动物空间记忆的迷宫模型。它由一个中心区和其周围连接的八条臂组成&#xff0c;在其中一些臂的末端放入食饵或将一些臂施以电击&#xff0c;根据动物的取食或逃避策略&#xff08;进入每个臂的次数、时间、错能&#xff08;如动物活动路径、各种时间、次…...

ai辅助开发:为openclawskills网站打造智能个性化教程推荐引擎

最近在帮朋友优化他的技能学习网站openclawskills&#xff0c;想给用户增加个性化推荐功能。作为一个独立开发者&#xff0c;借助InsCode(快马)平台的AI辅助开发能力&#xff0c;整个过程比想象中顺利很多。记录下这个智能推荐系统的实现思路&#xff0c;或许对其他想做类似功能…...

用Python+NumPy手把手实现四足机器人腿部三维运动学(附完整代码与避坑点)

用PythonNumPy手把手实现四足机器人腿部三维运动学&#xff08;附完整代码与避坑点&#xff09; 四足机器人的运动控制一直是机器人学中最具挑战性的领域之一。想象一下&#xff0c;当你看到一只机械狗灵活地穿越复杂地形时&#xff0c;背后其实是数百行精密的运动学代码在实时…...

WarcraftHelper:让经典魔兽争霸3重获现代游戏体验的兼容性增强工具

WarcraftHelper&#xff1a;让经典魔兽争霸3重获现代游戏体验的兼容性增强工具 【免费下载链接】WarcraftHelper Warcraft III Helper , support 1.20e, 1.24e, 1.26a, 1.27a, 1.27b 项目地址: https://gitcode.com/gh_mirrors/wa/WarcraftHelper 魔兽争霸3作为一款经典…...

学习笔记:敢管,会管,善管——学校行政管理的进阶

管理者角色理解一、管理者在组织结构中的位置校级&#xff1a;领导者管理者中层干部&#xff1a;管理者执行者学校教师&#xff1a;执行者&#xff08;班主任对班级兼顾三者&#xff09;二、从普通教师到中层干部的转变&#xff1a;1.工作职责的变化:从运动员向教练员转变运动员…...

程序员别再假装养生:你花3000块买保健品,却舍不得戒掉这3个坏习惯

深夜十一点&#xff0c;某程序员群突然炸了。有人发了张截图&#xff0c;是他双十一的购物记录&#xff1a;护肝片、维生素C、鱼油、钙片、褪黑素、护腰垫、人体工学鼠标......总价&#xff1a;6872元。底下评论清一色的"对自己好一点"、"程序员太难了"、&…...

树莓派 AP 模式作为中继器或子路由器配置

树莓派 AP 模式作为中继器或子路由器配置设备&#xff1a;Raspberry Pi 4B W | 日期&#xff1a;2026-04-02 WiFi 芯片&#xff1a;BCM43455 | 系统&#xff1a;Raspberry Pi OS (64-bit)一、环境信息项目值设备型号Raspberry Pi Zero 2 WWiFi 芯片BCM43455内核版本6.6.x操作系…...