用Go实现Redis之二客户端/服务端交互

qieangel2013 发布于2019-07-24 15:32 / 2979人阅读

摘要：写在前面在前一篇梳理了版本的基本功能，这一篇要做的是实现客户端服务端的交互。进入正题事件处理器既要实现交互，网络编程必不可少。

写在前面

在前一篇梳理了Godis v1.0版本的基本功能，这一篇要做的是实现客户端/服务端的交互。先让代码跑起来，才算有了生命力。
本篇Godis版本号：v0.0.1

在这个系列文章里，尽量减少介绍Golang语法、C语言语法和redis原理，聚焦在“用Golang实现Redis”的主题上。其中如有疏漏、不足，还请指正。

进入正题 Redis事件处理器

既要实现C/S交互，网络编程必不可少。在Redis中，有实现方式：

*Redis基于 Reactor 模式开发了自己的网络事件处理器：这个处理器被称为文件事件处理器（file event handler）：

文件事件处理器使用 I/O 多路复用（multiplexing）程序来同时监听多个套接字，并根据套接字目前执行的任务来为套接字关联不同的事件处理器。

当被监听的套接字准备好执行连接应答（accept）、读取（read）、写入（write）、关闭（close）等操作时，与操作相对应的文件事件就会产生，这时文件事件处理器就会调用套接字之前关联好的事件处理器来处理这些事件。*

Redis事件处理器的架构图：

Redis兼顾了简单性和高性能，但出于对其代码复杂性的考虑，Godis v0.0.1会采用更简单的弱智方案。Godis的编码使用最简单的同步技术，争取在网络处理方面简单化，因为复杂的也不会:)。暂时舍弃高性能，只求可用。在未来的版本中，会结合Golang自身的特性，优化网络层。

Godis的方案

客户端/服务端的交互，只需使用Golang的net包进行socket编程，编写一个流程为监听-读取-处理-回复的服务端和一个流程为建立-发送-接收-显示的客户端即可。

图中英文均为Golang中net包的主要函数，这里简要说明一下在这一篇中使用的net包函数：
ResolveTCPAddr ：
用例：tcpAddr, err := net.ResolveTCPAddr("tcp4", “127.0.0.1:9736”);
功能：创建TCPAddr类型的数据结构，其中包含IP和Port，留作连接之用；

ListenTCP：
用例：netListen, err := net.Listen("tcp", "127.0.0.1:9763");
功能：监听

Accept：
用例：conn, err := netListen.Accept()
功能：接收请求

Read：
用例：n, err := conn.Read(buff)
功能：读取数据

Write：
用例：conn.Write([]byte(buff))
功能：响应数据

net.DialTCP：
用例：conn, err := net.DialTCP("tcp", nil, tcpAddr)
功能：建立连接

代码实现

按照前图的流程，服务端的部分代码如下所示：

func main() {
        netListen, err := net.Listen("tcp", "127.0.0.1:9736")
        if err != nil {
            log.Print("listen err ")
        }
        //checkError(err)
        defer netListen.Close()
    
        for {
            conn, err := netListen.Accept()
            if err != nil {
                continue
            }
            go handle(conn)
        }
    }

真实完整代码实现请见这里。
在建立客户端之前，我们通过telnet测试下服务端是否可用（Redis也支持Telnet方式连接、请求，后面的协议部分会介绍）。
编译godis-server.go
go build godis-server.go 并启动 ./godis-server

执行 telnet localhost 9736

可以看到回复如下：

接下来，按照简单流程图的步骤，客户端的实现如下：

func main() {
    IPPort := "127.0.0.1:9736"

    reader := bufio.NewReader(os.Stdin)
    fmt.Println("Hi Godis")
    tcpAddr, err := net.ResolveTCPAddr("tcp4", IPPort)
    checkError(err)

    conn, err := net.DialTCP("tcp", nil, tcpAddr)
    checkError(err)
    defer conn.Close()

    for {
        fmt.Print(IPPort + "> ")
        text, _ := reader.ReadString("
")
        //清除掉回车换行符
        text = strings.Replace(text, "
", "", -1)
        send2Server(text, conn)

        buff := make([]byte, 1024)
        n, err := conn.Read(buff)
        checkError(err)
        if n == 0 {
            fmt.Println(IPPort+"> ", "nil")
        } else {
            fmt.Println(IPPort+">", string(buff))
        }
    }
}

编译cli.go 并启动./cli
与服务端交互，如下图所示：

到这里只是实现了基本的客户端/服务端通信。接下来为它添加少许交互选项，也就是在执行Redis命令行时的选项，让它看起来更像是Redis。

服务端添加平滑退出。

未来增加持久化后，会在平滑退出时持久化数据到磁盘，防止丢失。
平滑退出这里使用的方式是让客户端监听信号，有“退出”信号触达，做完收尾工作再退出。
简化代码如下：

func sigHandler(c chan os.Signal) {
    for s := range c {
        switch s {
        case syscall.SIGHUP, syscall.SIGINT, syscall.SIGTERM, syscall.SIGQUIT:
            exitHandler()
        default:
            fmt.Println("signal ", s)
        }
    }
}

func exitHandler() {
    fmt.Println("exiting smoothly ...")
    fmt.Println("bye ")
    os.Exit(0)
}

编译之后，执行Ctrl+c退出，可以看到：

本篇遇到过的问题：

1.服务端读取客户端信息时，发生err时没有return，导致服务端会一直读取数据失败。
解决方案：return或者其他可以退出goroutine的方案。
本篇就是这样了。简陋是简陋了点，又不是不能用，李姐万岁。完整代码请看本篇对应的release，（只有release才是当前本篇文章对应的完整代码，当前repo状态不是）。

下集预告

1.[实现get/set命令。][8]

超融合服务器云服务器 webrtc 服务端交互网站客户端服务器交互客户端服务器交互过程客户端服务器信息交互

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/36668.html

用Go实现Redis之二客户端/服务端交互

摘要：写在前面在前一篇梳理了版本的基本功能，这一篇要做的是实现客户端服务端的交互。进入正题事件处理器既要实现交互，网络编程必不可少。写在前面在前一篇梳理了Godis v1.0版本的基本功能，这一篇要做的是实现客户端/服务端的交互。先让代码跑起来，才算有了生命力。本篇Godis版本号：v0.0.1 在这个系列文章里，尽量减少介绍Golang语法、C语言语法和redis原理，聚焦在用Gol...

Scliang 2019-07-01 10:05 评论0 收藏0
用Go实现Redis之一准备工作

摘要：命令实现命令是最常用的命令之一，也是最能反映缓存发展历史的操作。命令在客户端接收之后，经由协议转换传递给服务端执行。服务端执行命令前先查询是否支持该命令，以决定是否执行。，是的简称，代表的是只存增量的持久化方式。缘起最近公司的第一个PHP转GO项目已经在生产环境稳定运行数周，又逢需求小年儿，最近可以得空分享下去年学GO过程中的练手项目Godis——用Golang实现的Redis. ...

yacheng 2019-07-24 15:30 评论0 收藏0
用Go实现Redis之一准备工作

摘要：命令实现命令是最常用的命令之一，也是最能反映缓存发展历史的操作。命令在客户端接收之后，经由协议转换传递给服务端执行。服务端执行命令前先查询是否支持该命令，以决定是否执行。，是的简称，代表的是只存增量的持久化方式。缘起最近公司的第一个PHP转GO项目已经在生产环境稳定运行数周，又逢需求小年儿，最近可以得空分享下去年学GO过程中的练手项目Godis——用Golang实现的Redis. ...

zhangke3016 2019-07-01 10:04 评论0 收藏0
用Go实现Redis之三get/set命令实现

摘要：在读者阅读实现代码时，也可以看到最新版本，与有一处是在文件清除掉回车换行符该行被暂时注释掉，也就是在版本，使用作为文本协议分隔符，确定命令的结尾。写在前面本篇Godis版本号：v0.0.2 前一篇文章实现了客户端/服务端的交互。这一篇，主要介绍get/set命令的实现。命令本身比较简单，支撑命令的整个系统基础比较麻烦。本文会介绍get/set操作涉及的组件和模块，并适当简化，最后实...

flyer_dev 2019-07-24 15:31 评论0 收藏0
用Go实现Redis之三get/set命令实现

摘要：在读者阅读实现代码时，也可以看到最新版本，与有一处是在文件清除掉回车换行符该行被暂时注释掉，也就是在版本，使用作为文本协议分隔符，确定命令的结尾。写在前面本篇Godis版本号：v0.0.2 前一篇文章实现了客户端/服务端的交互。这一篇，主要介绍get/set命令的实现。命令本身比较简单，支撑命令的整个系统基础比较麻烦。本文会介绍get/set操作涉及的组件和模块，并适当简化，最后实...

Ethan815 2019-07-01 10:06 评论0 收藏0