用go实现Redis读写分离

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: 用go实现Redis读写分离

本篇文章将介绍Redis通信协议RESP, 而后在使用go来编写一个中间件,从而来完成Redis读写分离。

本篇文章目的为探究RESP协议,而非编写读写中间件,这点要清楚。




我们为什么需要了解RESP协议?


关于这个问题,我想通过一个实例来解释,我们编写Redis中间件,为什么需要了解RESP协议。

image.png


以上代码是编写了一个非常简单的TCP服务器,我们监听8888端口,尝试使用redis-cli -p 8888连接服务器后,而后查看打印出来的应用层报文。


我们尝试执行下该代码,并且输入redis-cli -p 8888进行连接。

image.png

我们编写的服务器获取redis客户端的报文为:

*1
$7
COMMAND

上面这个就是RESP协议的内容了,所以说,我们要编写一个Redis的中间件,我们需要先了解一下RESP协议才行。



什么是RESP协议


官网有相关的解释: https://redis.io/docs/reference/protocol-spec/

RESP协议创建之初是专门为了Redis服务器和客户端的通信而设计的,该协议在Redis 1.2中引入,并且在Redis 2.0中,成为Redis通信的标准协议。该协议有如下优点:


  • 实现简单
  • 快速解析
  • 直接可阅读

RESP根据其协议前缀,可以序列化不同的数据类型,例如: 整数、字符串、数组 等,还能标注 正常输出 和 错误输出等。除了流水线和发布订阅以外,RESP协议应该是最简单的请求-响应协议了。关于更多介绍,大佬们可以看看上面注释的官方文档。



RESP协议规范


RESP协议不同的部分使用\r\n(换行符)来进行分割,其支持5种数据类型,分别为: 简单字符串、错误、整数、复杂字符串 和 数组组成,我们列个表格来讲下。


类型 前缀 备注
简单字符串 + 简单字符串以+开头
错误数据 - 错误数据以-开头
整数 : 整数以:开头
复杂字符串 $ 复杂字符串以$开头
数组 * 数组以*开头


我当初看到这个的时候,也是迷迷糊糊的,到底什么意思呢? 哎,我们举个例子你就明白了。


若我们想执行

set juejinName pdudo


若使用RESP 协议应当如何编写呢?应当编写如下:

*3
$3
set
$10
juejinName
$5
pdudo


那我们来解释一下*3代表有3个数组,而$3代表复杂字符串有长度为3,值为set$10代表复杂字符串长度为10,值为juejinName$5代表复杂字符串长度为5,值为pdudo


我们结合上述信息,可以画一张图。

image.png


这就是协议的内容了。

而协议前缀+-:则要简单的多,直接跟数据即可,例如:

+

+OK

-

-ERR syntax error

:

:3



如何使用该协议请求Redis


我们已经学习了相关的RESP协议,那么我们如何学习呢? 我们可以使用telnet命令来操作即可。

在此,我们准备几条命令,我们会将其转换为RESP格式,且将其发送到redis服务器。

命令

set name pdudo
get name
lpush pn 1
llen pn


转换为RESP格式

*3
$3
set
$4
name
$5
pdudo
*2
$3
get
$4
name
*3
$5
lpush
$2
pn
$1
1
*2
$4
llen
$2
pn

我们将其放置到telnet中执行一下呢


image.png


现在回头看看官网文档所提及的,该协议实现简单,直接可阅读,是不是理解的更加深刻了呢?



使用go编写Redis中间件实现读写分离


本篇暂不解释代码,而后单独开一篇谈论中间件代码。


实现该功能,其实本质上是区分命令是查询还是写入,若是查询,则直接转发到从库,而写入,则转发到主库即可,其架构图可以理解为如下:

image.png

我们已经有了目前的架构。

主机 端口 密码 角色
127.0.0.1 6379 主库
127.0.0.1 7380 从库

相关代码已经放到了 gitee.com/pdudo/golea…

我们来看看实际效果呢:

image.png



总结


其实本篇文章核心的点是探究RESP协议,而我们使用go编写了一个软件,用于解析RESP协议,从而获取执行的命令,再根据命令属性,从而转发从库或者主库,以此来达到读写分离的效果。再次提及一下核心点是拆解RESP协议。


怎么样,好玩吧,动动你的小手指,快来试试吧。



相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
6月前
|
弹性计算 负载均衡 NoSQL
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)(四)
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)
|
6月前
|
弹性计算 负载均衡 NoSQL
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)(二)
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)
|
6月前
|
弹性计算 负载均衡 NoSQL
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)(一)
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)
|
7月前
|
缓存 NoSQL 中间件
redis如何通过读写分离来承载读请求高并发
redis如何通过读写分离来承载读请求高并发
64 0
|
6月前
|
弹性计算 负载均衡 NoSQL
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)(三)
【红包雨功能的】环境部署(弹性伸缩、负载均衡、Redis读写分离、云服务器部署)
|
7月前
|
NoSQL Redis Docker
【Redis从头学-12】Redis主从复制和读写分离的多种部署方式解析(普通方式、Docker搭建方式、Docker-Compose搭建方式)下
【Redis从头学-12】Redis主从复制和读写分离的多种部署方式解析(普通方式、Docker搭建方式、Docker-Compose搭建方式)
148 0
|
7月前
|
存储 NoSQL Redis
【Redis从头学-12】Redis主从复制和读写分离的多种部署方式解析(普通方式、Docker搭建方式、Docker-Compose搭建方式)上
【Redis从头学-12】Redis主从复制和读写分离的多种部署方式解析(普通方式、Docker搭建方式、Docker-Compose搭建方式)
134 0
|
9月前
|
NoSQL Ubuntu Linux
|
5月前
|
缓存 NoSQL 关系型数据库
redis 作为 mysql的缓存服务器(读写分离)
redis 作为 mysql的缓存服务器(读写分离)
51 0
|
6月前
|
NoSQL 关系型数据库 Go
Go 使用三方 Redis 包操作 Redis
Go 使用三方 Redis 包操作 Redis
60 0