|
|
@@ -132,10 +132,17 @@ func (r *GoRedis) Init(opt interface{}) {
|
|
|
} else { //多节点模式
|
|
|
r.Code = code
|
|
|
r.DB = dbs[0]
|
|
|
- r.DBS = dbs
|
|
|
+ r.HashDb = 1 + len(dbs)
|
|
|
+ if len(dbs) > 1 {
|
|
|
+ r.DBS = []int{}
|
|
|
+ for i := dbs[0]; i <= dbs[1]; i++ {
|
|
|
+ r.DBS = append(r.DBS, i)
|
|
|
+ }
|
|
|
+ } else {
|
|
|
+ r.DBS = dbs
|
|
|
+ }
|
|
|
r.Ctx = context.Background()
|
|
|
r.CMap = map[int]map[int]*redis.Client{}
|
|
|
- r.HashDb = 1 + len(dbs)
|
|
|
r.Nodes = []int{}
|
|
|
for i := 0; i < len(addr1); i++ {
|
|
|
r.Nodes = append(r.Nodes, i)
|
