2021-10-09 来源:华纳网 责任编辑:韩玉玲 人气:
核心提示:来实现一个简易的Redis服务器

知识点:

用Go实现一台Redis服务器

 


 

本课内容:

 

大家好,欢迎来到谷雨课堂,

Redis是我们常用的缓存服务器,

也可以用于订阅/发布使用

 

大多数,我们使用Redis时,

用独立的进行Redis服务器的安装,

但有时我们仅使用Redis的一部分功能,

我们用可以把Redis的部分功能集成到我们的Go程序里,

这样我们分发程序时就只有一个程序,

这也是Go语言的方便之处。

 

以下是此Redis的全部代码:

  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
  •  
package main

import (  "log"  "strings"  "sync"

  "github.com/tidwall/redcon")

var addr = ":6380"

func main() {  var mu sync.RWMutex  var items = make(map[string][]byte)  var ps redcon.PubSub  go log.Printf("started server at %s", addr)

  err := redcon.ListenAndServe(addr,    func(conn redcon.Conn, cmd redcon.Command) {      switch strings.ToLower(string(cmd.Args[0])) {      default:        conn.WriteError("ERR unknown command '" + string(cmd.Args[0]) + "'")      case "publish":        // Publish to all pub/sub subscribers and return the number of        // messages that were sent.        if len(cmd.Args) != 3 {          conn.WriteError("ERR wrong number of arguments for '" + string(cmd.Args[0]) + "' command")          return        }        count := ps.Publish(string(cmd.Args[1]), string(cmd.Args[2]))        conn.WriteInt(count)      case "subscribe", "psubscribe":        // Subscribe to a pub/sub channel. The `Psubscribe` and        // `Subscribe` operations will detach the connection from the        // event handler and manage all network I/O for this connection        // in the background.        if len(cmd.Args) < 2 {          conn.WriteError("ERR wrong number of arguments for '" + string(cmd.Args[0]) + "' command")          return        }        command := strings.ToLower(string(cmd.Args[0]))        for i := 1; i < len(cmd.Args); i++ {          if command == "psubscribe" {            ps.Psubscribe(conn, string(cmd.Args[i]))          } else {            ps.Subscribe(conn, string(cmd.Args[i]))          }        }      case "detach":        hconn := conn.Detach()        log.Printf("connection has been detached")        go func() {          defer hconn.Close()          hconn.WriteString("OK")          hconn.Flush()        }()      case "ping":        conn.WriteString("PONG")      case "quit":        conn.WriteString("OK")        conn.Close()      case "set":        if len(cmd.Args) != 3 {          conn.WriteError("ERR wrong number of arguments for '" + string(cmd.Args[0]) + "' command")          return        }        log.Println("set", string(cmd.Args[1]), string(cmd.Args[2]))        mu.Lock()        items[string(cmd.Args[1])] = cmd.Args[2]        mu.Unlock()        conn.WriteString("OK")      case "get":        if len(cmd.Args) != 2 {          conn.WriteError("ERR wrong number of arguments for '" + string(cmd.Args[0]) + "' command")          return        }        log.Println("get", string(cmd.Args[1]))        mu.RLock()        val, ok := items[string(cmd.Args[1])]        mu.RUnlock()        if !ok {          conn.WriteNull()        } else {          conn.WriteBulk(val)        }      case "del":        if len(cmd.Args) != 2 {          conn.WriteError("ERR wrong number of arguments for '" + string(cmd.Args[0]) + "' command")          return        }        mu.Lock()        _, ok := items[string(cmd.Args[1])]        delete(items, string(cmd.Args[1]))        mu.Unlock()        if !ok {          conn.WriteInt(0)        } else {          conn.WriteInt(1)        }      case "config":        // This simple (blank) response is only here to allow for the        // redis-benchmark command to work with this example.        conn.WriteArray(2)        conn.WriteBulk(cmd.Args[2])        conn.WriteBulkString("")      }    },    func(conn redcon.Conn) bool {      // Use this function to accept or deny the connection.      // log.Printf("accept: %s", conn.RemoteAddr())      return true    },    func(conn redcon.Conn, err error) {      // This is called when the connection has been closed      // log.Printf("closed: %s, err: %v", conn.RemoteAddr(), err)    },  )  if err != nil {    log.Fatal(err)  }}

扩展阅读:

redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash(哈希类型)。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作,而且这些操作都是原子性的。在此基础上,redis支持各种不同方式的排序。与memcached一样,为了保证效率,数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件,并且在此基础上实现了master-slave(主从)同步。

Redis 是一个高性能的key-value数据库。redis的出现,很大程度补偿了memcached这类key/value存储的不足,在部 分场合可以对关系数据库起到很好的补充作用。它提供了Java,C/C++,C#,PHP,JavaScript,Perl,Object-C,Python,Ruby,Erlang等客户端,使用很方便。[1] 

Redis支持主从同步。数据可以从主服务器向任意数量的从服务器上同步,从服务器可以是关联其他从服务器的主服务器。这使得Redis可执行单层树复制。存盘可以有意无意的对数据进行写操作。由于完全实现了发布/订阅机制,使得从数据库在任何地方同步树时,可订阅一个频道并接收主服务器完整的消息发布记录。同步对读取操作的可扩展性和数据冗余很有帮助。

redis的官网地址,非常好记,是redis.io。(域名后缀io属于国家域名,是british Indian Ocean territory,即英属印度洋领地),Vmware在资助着redis项目的开发和维护。

 

完整的源代码可以登录【华纳网】下载。

https://www.worldwarner.com/




 





免责声明:本文仅代表作者个人观点,与华纳网无关。其原创性以及文中陈述文字和内容未经本站证实,对本文以及其中全部或者部分内容、文字的真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。