Fast Redis server implementation for Go
Redcon is a Redis server implementation for Go that is fast and simple to use. The reason for this library it to give an efficient server front-end for the [BuntDB](https://github.com/tidwall/buntdb) and [Tile38](https://github.com/tidwall/tile38) projects. Features -------- - Create a [Fast](#benchmarks) custom Redis compatible server in Go - Simple interface. One function `ListenAndServe` and one type `Conn` - Support for pipelining and telnet commands - Works with Redis clients such as [redigo](https://github.com/garyburd/redigo), [redis-py](https://github.com/andymccurdy/redis-py), [node_redis](https://github.com/NodeRedis/node_redis), and [jedis](https://github.com/xetorthio/jedis) Installing ---------- ``` go get -u github.com/tidwall/redcon ``` Example ------- Here's a full example of a Redis clone that accepts: - SET key value - GET key - DEL key - PING - QUIT You can run this example from a terminal: ```sh go run example/clone.go ``` ```go package main import ( "log" "strings" "sync" "github.com/tidwall/redcon" ) var addr = ":6380" func main() { var mu sync.RWMutex var items = make(map[string]string) go log.Printf("started server at %s", addr) err := redcon.ListenAndServe(addr, func(conn redcon.Conn, commands [][]string) { for _, args := range commands { switch strings.ToLower(args[0]) { default: conn.WriteError("ERR unknown command '" + args[0] + "'") case "ping": conn.WriteString("PONG") case "quit": conn.WriteString("OK") conn.Close() case "set": if len(args) != 3 { conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command") continue } mu.Lock() items[args[1]] = args[2] mu.Unlock() conn.WriteString("OK") case "get": if len(args) != 2 { conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command") continue } mu.RLock() val, ok := items[args[1]] mu.RUnlock() if !ok { conn.WriteNull() } else { conn.WriteBulk(val) } case "del": if len(args) != 2 { conn.WriteError("ERR wrong number of arguments for '" + args[0] + "' command") continue } mu.Lock() _, ok := items[args[1]] delete(items, args[1]) mu.Unlock() if !ok { conn.WriteInt(0) } else { conn.WriteInt(1) } } } }, 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) } } ``` Benchmarks ---------- **Redis**: Single-threaded, no disk persistence. `redis-server --port 6379 --appendonly no` ``` redis-benchmark -p 6379 -t set,get -n 10000000 -q -P 512 -c 512 SET: 941265.12 requests per second GET: 1189909.50 requests per second ``` **Redcon**: Single-threaded, no disk persistence. `GOMAXPROCS=1 go run example/clone.go` ``` redis-benchmark -p 6380 -t set,get -n 10000000 -q -P 512 -c 512 SET: 1320655.00 requests per second GET: 1552354.25 ``` **Redcon**: Multi-threaded, no disk persistence. `GOMAXPROCS=0 go run example/clone.go` ``` redis-benchmark -p 6380 -t set,get -n 10000000 -q -P 512 -c 512 SET: 2740477.00 requests per second GET: 3210272.75 requests per second ``` *Running on a MacBook Pro 15" 2.8 GHz Intel Core i7 using Go 1.7* Contact ------- Josh Baker [@tidwall](http://twitter.com/tidwall) License ------- Redcon source code is available under the MIT [License](/LICENSE).