README.md

medis

mysql cluster work as a redis node

架构图

• group层是虚拟的，是一组读写分离的mysql数据源
• key会hash到某一个gourp在这个group上做读写
• 扩容期间，会自动在多个group上做双写
• 按照目前的架构，写瓶颈通过扩容group解决，读瓶颈通过扩容group中用于读的mysql从库解决

启动

• go run medis.go

启动代码中的group的配置需要说明一下

// 创建主从关系
group0 := datasource.NewGroup("group0")
// 0 1 0 1 代表的是 读权重是0，写权重是1，不可读，写优先级是1
group0.AddClient(datasource.NewClientWeightWrapper("group0_master_0", master0, 0, 1, 0, 1))
group0.AddClient(datasource.NewClientWeightWrapper("group0_slave_0", master0, 1, 0, 1, 0))
group0.Init()
group1 := datasource.NewGroup("group1")
group1.AddClient(datasource.NewClientWeightWrapper("group1_master_0", master1, 0, 1, 0, 1))
group1.AddClient(datasource.NewClientWeightWrapper("group1_slave_0", master1, 1, 0, 1, 0))
group1.Init()

• 首先一个group中是按照优先级优先选择mysql，高优先级还可用时才用低优先级
• 所以低优先级的mysql可以理解为备机
• 其次读写权重的意义是，按照权重的来选择用哪个mysql，一般写只有一个，所以写权重意义目前不大

动态扩容

• 扩容通过medis的admin对外提供的HTTP端口来操作

1. 对medis添加新的group

• 创建一个group http://localhost:13801/group/new?group_name=group2

• 向这个group添加mysql主库 http://localhost:13801/group/add?group_name=group2&name=root&pwd=root&host=localhost&port=8889&db=test2&charset=utf8&w=1&p=0&r=1&q=0&ds_name=group2_master&group_name=group2

• 向这个group添加mysql从库 http://localhost:13801/group/add?group_name=group2&name=root&pwd=root&host=localhost&port=8889&db=test2&charset=utf8&w=0&p=1&r=0&q=1&ds_name=group2_slave&group_name=group2

• 对group2进行balance http://localhost:13801/group/balance?group_name=group2

已经兼容的redis操作列表

• Del
• FlushAll
• Get
• Hget
• Hgetall
• Hset
• Lrange
• Mget 并行查询
• Ping
• Rpush
• Set
• Slaveof
• Type
• Zadd
• Zcard
• Zrange
• Zrangebyscore
• Zrem
• Zscore