go语言公共库 goredis

golang redis client, bufferd connection, connection pool, support all redis commands， 欢迎大家批评指正，更欢迎大家加入进来。 #### Create a new conn? c, e := Dial("127.0.0.1:6379", pwd, CTimeout, RTimeout, WTimeout, alive, *pool) if e != nil { println(e.Error()) return } 如果redis不需要AUTH认证, password ="" #### A Redis Command. c.GET("mykey") c.SADD("mySets", []string{"a","b","c"}) // You can also use this c.Call(CommandName, arg...) #### Pipeline c.PipeSend("SET", "a", "zyh") c.PipeSend("SET", "b", "zyh") c.PipeSend("SET", "c", "zyh") c.PipeExec() #### Transaction c.MULTI() c.TransSend("SET", "a", "zyh2") c.TransSend("SET", "b", "zyh3") c.TransExec() #### Create a new pool? p := NewPool("127.0.0.1:6379", "", maxConnNum, maxIdleSeconds) // get a new conn c := p.Pop() if c == nil{ fmt.Println("get a nil conn") } defer p.Push(c) #### Create a new multiPool? addresses := []string{"127.0.0.1:6379", "127.0.0.1:9991@1"} mp := NewMultiPool(addresses, maxConnNum, maxIdleSeconds) addr := "127.0.0.1:6379" c := mp.PopByAddr(addr) mp.PushByAddr(addr, c) key := "myhashes" c = mp.PopByKey(key) mp.PushByKey(key, c) // mp.Push(c) PopByKey和PushByKey是对参数key进行hash，然后选出固定的redis。你可以使用自己的hash算法，具体实现在Sum函数中。 AddPool函数，会在multiPool中新加入一个Pool，maxConnNum和maxIdleSeconds可以和初始化multiPool的时候不同，或者直接 mp.Push(c) 会自动去找到应该放入的Pool中 注意：必须在init的时候按顺序添加不同参数的Pool，因为multiPool里面没有对pool slice加锁 #### Add a new pool into multiPool? mp.AddPool("127.0.0.1:9988", maxConnNum+10, maxIdleSeconds+10) 当有新的pool需要加入到pool中时，可以用该方法，但是如果你是通过对key进行hash，然后选择redis pool的话，会影响数据的一致性 #### Delete a pool from multiPool? mp.DelPool("127.0.0.1:9988") 删除一个pool，可以用该方法，但是如果你是通过对key进行hash，然后选择redis pool的话，会影响数据的一致性 #### Replace a exists pool in multiPool? mp.ReplacePool("127.0.0.1:9901", "127.0.0.1:9801", 20, 8) 如果需要替换一个redis pool可以用该方法 #### Use Lua script? ###### Lua 脚本是针对pool结构的，每个pool有一个script map，使用者可以预先编写好需要用到的脚本，通过script load函数生成sha1 ###### 然后，放入map中，下次方便调用，且不用每次都编译，而且可能节省带宽，变相的增加了访问的速度 ###### 需要注意的一点是，如果返回lua的table，所以只能是整数，且从1开始顺序的。 ###### 具体关于redis lua的说明请参考[http://redis.io/commands/eval](http://redis.io/commands/eval) p := NewPool("10.16.15.121:9731", "", 10, 10) c := p.Pop() if c == nil { return } scriptA := ` local ttl = redis.call("ttl",KEYS[1]) local key = redis.call("get",KEYS[1]) local rTable = {} rTable[1] = ttl rTable[2] = key return rTable ` sha1, e := c.SCRIPTLOAD(scriptA) if e != nil { fmt.Println("script load error = ", e.Error()) return } #### Todo List - Consistent Hash - Etc...