本篇内容主要讲解“go如何实现Redis读写分离”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“go如何实现Redis读写分离”吧!
我们为什么需要了解RESP协议?
关于这个问题,我想通过一个实例来解释,我们编写
Redis中间件,为什么需要了解
RESP协议。
以上代码是编写了一个非常简单的
TCP服务器,我们监听
8888端口,尝试使用
redis-cli -p 8888连接服务器后,而后查看打印出来的应用层报文。
我们尝试执行下该代码,并且输入
redis-cli -p 8888进行连接。
我们编写的服务器获取
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协议不同的部分使用
(换行符)来进行分割,其支持5种数据类型,分别为: 简单字符串、错误、整数、复杂字符串 和 数组组成,我们列个表格来讲下。
类型 | 前缀 | 备注 |
---|---|---|
简单字符串 | + | 简单字符串以+开头 |
错误数据 | - | 错误数据以-开头 |
整数 | : | 整数以:开头 |
复杂字符串 | $ | 复杂字符串以$开头 |
数组 | * | 数组以*开头 |
我当初看到这个的时候,也是迷迷糊糊的,到底什么意思呢? 哎,我们举个例子你就明白了。
若我们想执行
set juejinName pdudo
若使用
RESP协议应当如何编写呢?应当编写如下:
*3 $3 set $10 juejinName $5 pdudo
那我们来解释一下
*3代表有3个数组,而
$3代表复杂字符串有长度为3,值为
set,
$10代表复杂字符串长度为10,值为
juejinName,
$5代表复杂字符串长度为5,值为
pdudo。
我们结合上述信息,可以画一张图。
这就是协议的内容了。
而协议前缀
+、
-、
:则要简单的多,直接跟数据即可,
例如:
+
+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中执行一下呢
现在回头看看官网文档所提及的,该协议实现简单,直接可阅读,是不是理解的更加深刻了呢?
使用go编写Redis中间件实现读写分离
本篇暂不解释代码,而后单独开一篇谈论中间件代码。
实现该功能,其实本质上是区分命令是查询还是写入,若是查询,则直接转发到从库,而写入,则转发到主库即可,其架构图可以理解为如下:
我们已经有了目前的架构。
主机 | 端口 | 密码 | 角色 |
---|---|---|---|
127.0.0.1 | 6379 | 无 | 主库 |
127.0.0.1 | 7380 | 无 | 从库 |