Comment implémenter la séparation de lecture et d'écriture Redis en Go

Pourquoi devons-nous comprendre le protocole REEE ?

Concernant ce problème, j'aimerais utiliser un exemple pour expliquer pourquoi nous devons comprendre le protocole RESP lorsque nous écrivons le middleware Redis. Redis中间件，为什么需要了解RESP协议。

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

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

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

*1

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协议不同的部分使用rn

Ce qui précède le code est écrit Nous avons créé un serveur TCP très simple. Nous écoutons le port 8888, essayons d'utiliser redis-cli -p 8888 pour. connectez-vous au serveur, puis affichez les messages imprimés de la couche application.

Ce qui précède est Le contenu du protocole RESP a été révélé, donc si nous voulons écrire un middleware Redis, nous devons d'abord comprendre le protocole RESP.

Mise en œuvre simple

RESPSelon son préfixe de protocole, différents types de données peuvent être sérialisés, tels que des entiers, des chaînes, des tableaux, etc., et la sortie normale et la sortie d'erreur peuvent également être marquées. En plus des pipelines et de la publication et de l'abonnement, le protocole RESP devrait être le protocole de requête-réponse le plus simple. Pour plus d'introduction, vous pouvez consulter la documentation officielle commentée ci-dessus.

Spécification du protocole RESP

RESPDifférentes parties du protocole sont séparées à l'aide de rn (saut de ligne). Il prend en charge 5 types de données, à savoir : It. se compose de chaînes simples, d'erreurs, d'entiers, de chaînes complexes et de tableaux. Créons un tableau pour l'expliquer. Préfixe+-

Nous essayons d'exécuter ce code et de saisir redis-cli -p 8888 pour nous connecter.	Le serveur que nous avons écrit reçoit le message du client redis sous la forme :	*1 $7 COMMAND
Qu'est-ce que le protocole RESP	Le site officiel contient des explications pertinentes : https://redis.io/docs/reference/protocol-spec/	RESPLe protocole a été créé à l'origine spécifiquement pour Conçu pour la communication entre les serveurs et les clients Redis, le protocole a été introduit dans Redis 1.2 et est devenu Redis dans Redis 2.0 > Protocole standard de communication. Ce protocole présente les avantages suivants :
Analyse rapide	Directement lisible
		Type
Remarques		Chaîne simple
Chaîne simple commence par +		Données d'erreur

Les données d'erreur commencent par - 🎜🎜🎜🎜 Entiers🎜 🎜: 🎜🎜Integers Commencez par: 🎜🎜🎜🎜Complex Strings🎜🎜 $ 🎜🎜 🎜🎜Complex Strings commencez par $ 🎜🎜🎜🎜arrays🎜🎜 * 🎜🎜arrays commencez par * 🎜🎜🎜🎜

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

若我们想执行

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	无	从库

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!