详解 mini-redis 复刻 Redis 的 I NCR 指令
发布时间：2025-11-04 19:24:17 来源：技术快报 作者：系统运维
因为近期比较忙碌，详解所以对于mini-redis的详解复刻基本处于一些指令向的完善，而本文将针对字符串操作中介绍笔者近期所复刻的详解键值自增指令的落地思路，以帮助读者更好的详解理解和学习mini-redis。
因为指令是详解基于字符串操作的，所以在执行INCR或者DECR之前我们都必须针对入参的详解键值对进行校验，所以对于以下情况，详解我们都必须采用fail-fast的详解方式提前将失败暴露，将键值对已存在，详解对应的详解值非字符串类型(例如:字典类型)，直接响应错误：
基于上述的详解基本概念，我们给出落地的详解代码,即位于command.go的incrDecrCommand方法，可以看到我们会优先到redis内存中查看是详解否存在对应的key，如果存在则进行必要的详解类型判断，如果非字符串类型即REDIS_STRING则直接响应错误出去，详解并直接返回：
复制func incrDecrCommand(c *redisClient, incr int64) { var value int64 var oldValue int64 var newObj *robj //查看键值对是否存在 o := lookupKeyWrite(c.db, c.argv[1]) //如果键值对存在且类型非字符串类型，直接响应错误并返回 if o != nil && checkType(c, o, REDIS_STRING) { return } //...... }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.对此我们也给出checkType的WordPress模板内部逻辑，可以看到当比对类型不一致时会直接输出错误并返回true，读者可以参考注释了解：
复制func checkType(c *redisClient, o *robj, rType int) bool { //如果类型不一致，则输出-WRONGTYPE Operation against a key holding the wrong kind of value if o.robjType != rType { addReply(c, shared.wrongtypeerr) return true } return false }1.2.3.4.5.6.7.8.其实笔者这里也想吐槽一句redis对于函数设计的语义的不恰当性，理论性合理的函数进行校验时正确的做法应该是：
逻辑校验失败，输出错误返回false。逻辑校验正确，返回true。也只能说因为某些历史原因，或者设计者有着自己的主观编码习惯吧，本着一比一的复刻理念，笔者也沿袭了这样的编码思路。
基于数值池高效完成字符串转换针对字符串类型(可以转数值的情况下，它也会转数值类型)，我们都是通过robj类型创建和维护，因为我们本次所复刻的incr和decr所操作的类型是字符串中可转为数值的对象，所以本着数值类型有迹可循的规律以及空间换时间的思想，免费源码下载我们提出池化思想，即将0-9999数值缓存一份数值池，后续的增减操作后处于该范围的数值都可以直接使用数值池里对应的robj对象，以节约robj对象创建的开销和非必要的内存资源占用：
所以笔者在main.go中声明sharedObjectsStruct 这个结构体中声明了一个integers维护常量池的robj对象：
复制type sharedObjectsStruct struct { //...... integers [REDIS_SHARED_INTEGERS]*robj //通用0~9999常量数值池 //...... }1.2.3.4.5.然后在createSharedObjects方法中完成初始化，后续就可以直接使用了：
复制func createSharedObjects() { //...... var i int64 //初始化常量池对象 for i = 0; i < REDIS_SHARED_INTEGERS; i++ { //基于接口封装数值 num := interface{}(i) //生成string对象 shared.integers[i] = createObject(REDIS_STRING, &num) //声明编码类型为int shared.integers[i].encoding = REDIS_ENCODING_INT} //...... }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.于是我们就得出了后续的编码逻辑：
将value强转为数值判断是否超出范围，如果超了则抛出异常。反之进入步骤2。查看取值范围是否大于10000，如果是则自己生成robj对象，反之采用池化数值池的robj。基于1、2生成的数值对象将键值对更新或者覆盖到内存数据库中。 复制/** 针对字符串类型的值进行如下判断的和转换： 1. 如果为空，说明本次的key不存在，直接初始化一个空字符串，后续会直接初始化一个0值使用 2. 如果是字符串类型，香港云服务器则转为字符串类型 3. 如果是数值类型，则先转为字符串类型进行后续的通用数值转换操作保证一致性 */ var s string if o == nil { s = "" } else if isString(*o.ptr) { s = (*o.ptr).(string) } else { s = strconv.FormatInt((*o.ptr).(int64), 10) } //进行类型强转为数值，如果失败，直接输出错误并返回 if getLongLongFromObjectOrReply(c, s, &value, nil) != REDIS_OK { return } oldValue = value //如果累加超范围则报错 if (incr < 0 && oldValue < 0 && incr < (math.MinInt64-oldValue)) || (incr > 0 && oldValue > 0 && incr > (math.MaxInt64-oldValue)) { errReply := "increment or decrement would overflow" addReplyError(c, &errReply) return } //基于incr累加的值生成value value += incr //如果超常量池范围则封装一个对象使用 if o != nil && (value < 0 || value >= REDIS_SHARED_INTEGERS) && (value > math.MinInt64 || value < math.MaxInt64) { newObj = o i := interface{}(value) o.ptr = &i} else if o != nil {//如果对象存在，且累加结果没超范围则调用createStringObjectFromLongLong获取常量对象 newObj = createStringObjectFromLongLong(value) //将写入结果覆盖 dbOverwrite(c.db, c.argv[1], newObj)} else {//从常量池获取数值，然后添加键值对到数据库中 newObj = createStringObjectFromLongLong(value) dbAdd(c.db, c.argv[1], newObj)}1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45. 通用结果响应完成上述操作后就是将结果按照RESP协议规范将结果响应给客户端，按照协议要求数值类型必须用:号开头，所以假设我们累加结果为10，那么响应给客户端的结果就是10\r\n。
对应我们的给出最后的代码段：
复制//将累加后的结果返回给客户端，按照RESP格式即 :数值\r\n,例如返回10 那么格式就是:10\r\n reply := *shared.colon + strconv.FormatInt(value, 10) + *shared.crlf addReply(c, &reply)1.2.3. 完整的代码实现我们来小结一下上述的实现思路：
键值对查询与校验。数值类型转换与越界判断。字符串类型强转并基于取值范围查看是否通过数值池获取。更新或覆盖键值对。将操作结果返回客户端。完整代码如下：
复制func incrDecrCommand(c *redisClient, incr int64) { var value int64 var oldValue int64 var newObj *robj //查看键值对是否存在 o := lookupKeyWrite(c.db, c.argv[1]) //如果键值对存在且类型非字符串类型，直接响应错误并返回 if o != nil && checkType(c, o, REDIS_STRING) { return } /** 针对字符串类型的值进行如下判断的和转换： 1. 如果为空，说明本次的key不存在，直接初始化一个空字符串，后续会直接初始化一个0值使用 2. 如果是字符串类型，则转为字符串类型 3. 如果是数值类型，则先转为字符串类型进行后续的通用数值转换操作保证一致性 */ var s string if o == nil { s = "" } else if isString(*o.ptr) { s = (*o.ptr).(string) } else { s = strconv.FormatInt((*o.ptr).(int64), 10) } //进行类型强转为数值，如果失败，直接输出错误并返回 if getLongLongFromObjectOrReply(c, s, &value, nil) != REDIS_OK { return } oldValue = value if (incr < 0 && oldValue < 0 && incr < (math.MinInt64-oldValue)) || (incr > 0 && oldValue > 0 && incr > (math.MaxInt64-oldValue)) { errReply := "increment or decrement would overflow" addReplyError(c, &errReply) return } //基于incr累加的值生成value value += incr //如果超常量池范围则封装一个对象使用 if o != nil && (value < 0 || value >= REDIS_SHARED_INTEGERS) && (value > math.MinInt64 || value < math.MaxInt64) { newObj = o i := interface{}(value) o.ptr = &i} else if o != nil { //如果对象存在，且累加结果没超范围则调用createStringObjectFromLongLong获取常量对象 newObj = createStringObjectFromLongLong(value) //将写入结果覆盖 dbOverwrite(c.db, c.argv[1], newObj) } else { //从常量池获取数值，然后添加键值对到数据库中 newObj = createStringObjectFromLongLong(value) dbAdd(c.db, c.argv[1], newObj) } //将累加后的结果返回给客户端，按照RESP格式即 :数值\r\n,例如返回10 那么格式就是:10\r\n reply := *shared.colon + strconv.FormatInt(value, 10) + *shared.crlf addReply(c, &reply) }1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.29.30.31.32.33.34.35.36.37.38.39.40.41.42.43.44.45.46.47.48.49.50.51.52.53.54.55.56.57.58.59.60. 递增递减的复用基于上述函数对应的递增指令INCR就使用incrCommand，入参传1代表加1，而decrCommand则传-1扣减即可：
复制func incrCommand(c *redisClient) { //累加1 incrDecrCommand(c, 1) } func decrCommand(c *redisClient) { //递减1 incrDecrCommand(c, -1) }1.2.3.4.5.6.7.8.9. 最终效果演示最后，我们将服务启动进行测试，可以看到指令正常执行：
复制127.0.0.1:6379> incr k1 (integer) 1 (4.50s) 127.0.0.1:6379> incr k1 (integer) 2 127.0.0.1:6379> incr k1 (integer) 3 127.0.0.1:6379> incr k1 (integer) 4 127.0.0.1:6379> incr k1 (integer) 5 127.0.0.1:6379> incr k1 (integer) 6 127.0.0.1:6379> decr k1 (integer) 5 127.0.0.1:6379> decr k1 (integer) 4 127.0.0.1:6379> decr k1 (integer) 3 127.0.0.1:6379> decr k1 (integer) 2 127.0.0.1:6379> decr k1 (integer) 1 127.0.0.1:6379> decr k1 (integer) 0 127.0.0.1:6379> decr k1 (integer) -1 127.0.0.1:6379>1.2.3.4.5.6.7.8.9.10.11.12.13.14.15.16.17.18.19.20.21.22.23.24.25.26.27.28.- 电脑玩原神遇到的问题及解决方法（探索神奇世界，解决游戏中常见错误）
- 苹果升级10.3.2的新特性与改进（提升用户体验的关键更新及优化）
- 探究联发科MTK6580的性能及特点（MTK6580处理器在智能手机领域的优势和应用）
- 解决无法上网问题的实用技巧（如何处理连接上WiFi却无法正常上网的情况）
- 用手机和电脑制作棉花娃娃教程（简单易学的棉花娃娃制作指南，从手机到电脑全面解析制作过程）
- Excel常用快捷键命令大全（提高工作效率，掌握Excel快捷方式）
- 5y10性能评测（颠覆性的技术创新，赋能未来智能手机）
- 掌握Satellite7的使用教程（了解如何充分利用Satellite7来实现卓越卫星通信）
- 教你如何设置戴尔电脑的启动项（详解戴尔电脑启动设置及常见问题解答）
- 1.准备一个可用的U盘
- OPPOA57自拍效果实测（探秘OPPOA57自拍的魅力与功能）
- G2020核显性能评测及优劣分析（揭秘G2020核显的强项与短板，为您带来全面性能对比）
- 从10.3.3升级为主题（一步步教你如何升级你的设备主题，让它与众不同）
- 佳能142.8二代（佳能142.8二代，画面更清晰，拍摄更出色）
- 佳能50D配18-55镜头的完美搭配（出色成像，多功能应用，超值选择）
- 手机B站缓存视频导出方法（轻松将B站缓存视频保存至手机的完美指南）
- 华硕笔记本如何通过U盘安装系统（详解华硕笔记本使用U盘安装系统的步骤和注意事项）
- 如何制作UEFI启动盘（详细教你制作服务器U盘UEFI启动盘，轻松解决系统安装和维护问题）
- 电脑远程连接显示错误的解决方法（教你如何应对常见的远程连接显示错误）
- 探索Win10自带自动关机系统的功能与设置（利用Win10自带自动关机系统提升计算机使用效率）
随便看看
IT技术网服务器租用益华科技亿华云香港云服务器源码库IT资讯网源码下载企商汇益华科技亿华云计算亿华互联编程之道益强编程舍亿华科技极客编程益强智未来益强编程堂云站无忧码上建站益强智囊团多维IT资讯汇智坊智能时代极客码头亿华智慧云益强IT技术网亿华灵动技术快报创站工坊思维库运维纵横益强前沿资讯全栈开发益强数据堂益强资讯优选亿华智造码力社云智核IT资讯网科技前瞻益强科技
- Copyright © 2025 Powered by 详解 mini-redis 复刻 Redis 的 I NCR 指令,技术快报 滇ICP备2023006006号-46sitemap