python - Redis 流水线发送 200 条指令，只有 189 个答案

Question

我正在学习 Redis，但我被流水线概念所阻碍，我正在尝试向我的 Redis 服务器发送指令

这样我就可以使用套接字连接到我正在使用的 Redis 服务器。

这是我的代码(我是法国人所以有些词会用法语)

def send(MESSAGE):
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.connect((TCP_IP, TCP_PORT))
    s.send(MESSAGE)
    data = s.recv(BUFFER_SIZE)
    s.close()
    print "Envoi requete PC:", MESSAGE
    return data

这是我使用流水线的方式:

instruction ='SET compteur 0'
donnee = instruction.encode('utf-8') + '\x0D\x0A'
print envoie(donnee)
instruction=''
for i in range(200):
    instruction = instruction + 'INCR compteur\r\n'
donnee = instruction.encode('utf-8') + '\x0D\x0A'
print send(donnee)

当我这样做时，shell 给了我 200 INCR compteur 但它后面跟着:

:1
:2
:3
:4
....
:185
:186
:187
:188
:189

有人有解释吗？另外，如果我使用另一条指令，例如 GET compteur，我只有 147 +PONG

Answer 1

您可以在指令周围添加两个命令:指令前的 MULTI 和指令后的 EXEC。这将保证原子性并获得执行命令的所有结果。看看transaction文档。

请阅读 pipelining还。这里有很多有用的信息。

事实上，我猜你的问题是你可以在 Redis 返回之前开始阅读答案。

虽然流程 submitRequest -> receiveResults 的逻辑看起来不错，但是您的代码不能以这种方式工作，因为 Redis 执行异步操作。

实际上，您的代码以下一种方式读取:将数据(指令)发送到服务器-> 从套接字读取一些数据(结果 | 结果的一部分 | 什么都没有？)。问题是我们不等待 Redis 完成计算。

我不擅长 Python，但我猜 data = s.recv(BUFFER_SIZE) 将从 s 中读取最多“BUFFER_SIZE”字节(如果存在)。但是如果套接字中只有部分结果存在，则此命令仅返回这部分数据。正如其他人所建议的那样，处理从套接字读取并不是那么简单的操作 - 使用已经存在的库 - https://redis.io/clients#python