Golang 实现 Redis系列(六)如何实现 pipeline 模式的 redis 客户端

本文的完整代码在github.com/hdt3213/godis/redis/client

通常 tcp 客户端的通信模式都是阻塞式的: 客户端发送请求 -> 等待服务端响应 -> 发送下一个请求。因为需要等待网络传输数据，完成一次请求循环需要等待较多时间。

我们能否不等待服务端响应直接发送下一条请求呢？答案是肯定的。

tcp 作为全双工协议可以同时进行上行和下行通信，不必担心客户端和服务端同时发包会导致冲突。

p.s. 打电话的时候两个人同时讲话就会冲突听不清，只能轮流讲。这种通信方式称为半双工。广播只能由电台发送到收音机不能反向传输，这种方式称为单工。

我们为每一个 tcp 连接分配了一个 goroutine 可以保证先收到的请求先先回复。另一个方面，tcp 协议会保证数据流的有序性，同一个 tcp 连接上先发送的请求服务端先接收，先回复的响应客户端先收到。因此我们不必担心混淆响应所对应的请求。

这种在服务端未响应时客户端继续向服务端发送请求的模式称为 pipeline 模式。因为减少等待网络传输的时间，pipeline 模式可以极大的提高吞吐量，减少所需使用的 tcp 链接数。

pipeline 模式的 redis 客户端需要有两个后台协程程负责 tcp 通信，调用方通过 channel 向后台协程发送指令，并阻塞等待直到收到响应，这是一个典型的异步编程模式。

我们先来定义 client 的结构:

调用者将请求发送给后台协程，并通过 wait group 等待异步处理完成:

client 的核心部分是后台的读写协程。先从写协程开始:

读协程是我们熟悉的协议解析器模板, 不熟悉的朋友可以到解析redis cluster原理了解更多。

最后编写 client 的构造器和启动异步协程的代码:

关闭 client 的时候记得等待请求完成:

测试一下:

keep working, we will find a way out.this is finley, welcome to join us.

到此这篇关于golang 实现 redis系列(六)如何实现 pipeline 模式的 redis 客户端的文章就介绍到这了,更多相关golang实现pipeline模式的redis客户端内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！