Godis is a golang implementation of Redis Server, which intents to provide an example of writing a high concurrent middleware using golang.
- Support string, list, hash, set, sorted set
- AOF and AOF Rewrite
- MULTI Commands Transaction is Atomic and Isolated. If any errors are encountered during execution, godis will rollback the executed commands
- Server-side Cluster which is transparent to client. You can connect to any node in the cluster to access all data in the cluster.
DELcommand is supported and atomically executed in cluster mode
RenameNXcommand is supported within slot in cluster mode
- MULTI Commands Transaction is supported within slot in cluster mode
- Concurrent Core, so you don't have to worry about your commands blocking the server too much.
If you could read Chinese, you can find more details in My Blog.
You can get runnable program in the releases of this repository, which supports Linux and Darwin system.
You could use redis-cli or other redis client to connect godis server, which listens on 0.0.0.0:6399 on default mode.
The program will try to read config file path from environment variable
If environment variable is not set, then the program try to read
redis.conf in the working directory.
If there is no such file, then the program will run with default config.
Godis can work in cluster mode, please append following lines to redis.conf file
peers localhost:7379,localhost:7389 // other node in cluster self localhost:6399 // self address
We provide node1.conf and node2.conf for demonstration. use following command line to start a two-node-cluster:
CONFIG=node1.conf ./godis-darwin & CONFIG=node2.conf ./godis-darwin &
Connect to a node in the cluster to access all data in the cluster:
redis-cli -p 6399
System: macOS Catalina 10.15.7
CPU: 2.6GHz 6-Core Intel Core i7
Memory: 16 GB 2667 MHz DDR4
Performance report by redis-benchmark:
PING_INLINE: 87260.03 requests per second PING_BULK: 89206.06 requests per second SET: 85034.02 requests per second GET: 87565.68 requests per second INCR: 91157.70 requests per second LPUSH: 90334.23 requests per second RPUSH: 90334.23 requests per second LPOP: 90334.23 requests per second RPOP: 90415.91 requests per second SADD: 90909.09 requests per second HSET: 84104.29 requests per second SPOP: 82918.74 requests per second LPUSH (needed to benchmark LRANGE): 78247.26 requests per second LRANGE_100 (first 100 elements): 26406.13 requests per second LRANGE_300 (first 300 elements): 11307.10 requests per second LRANGE_500 (first 450 elements): 7968.13 requests per second LRANGE_600 (first 600 elements): 6092.73 requests per second MSET (10 keys): 65487.89 requests per second
WatchCommand and CAS support
- Stream support
- RDB file loader
- Master-Slave mode
Read My Code
If you want to read my code in this repository, here is a simple guidance.
- github.com/hdt3213/godis/cmd: only the entry point
- github.com/hdt3213/godis/config: config parser
- github.com/hdt3213/godis/interface: some interface definitions
- github.com/hdt3213/godis/lib: some utils, such as logger, sync utils and wildcard
I suggest focusing on the following directories:
- github.com/hdt3213/godis/tcp: the tcp server
- github.com/hdt3213/godis/redis: the redis protocol parser
- github.com/hdt3213/godis/datastruct: the implements of data structures
- dict: a concurrent hash map
- list: a linked list
- lock: it is used to lock keys to ensure thread safety
- set: a hash set based on map
- sortedset: a sorted set implements based on skiplist
- github.com/hdt3213/godis: the core of storage engine
- db.go: the basement of database
- exec.go: the gateway of database
- router.go: the command table
- keys.go: handlers for keys commands
- string.go: handlers for string commands
- list.go: handlers for list commands
- hash.go: handlers for hash commands
- set.go: handlers for set commands
- sortedset.go: handlers for sorted set commands
- pubsub.go: implements of publish / subscribe
- aof.go: implements of AOF persistence and rewrite
- geo.go: implements of geography features
This project is licensed under the GPL license.