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

写在前面

在前一篇梳理了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('\n')
        //清除掉回车换行符
        text = strings.Replace(text, "\n", "", -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]