|
@@ -368,20 +368,27 @@ func DelByPattern(key string) {
|
|
**/
|
|
**/
|
|
//自增计数器
|
|
//自增计数器
|
|
func Incr(code, key string) int64 {
|
|
func Incr(code, key string) int64 {
|
|
|
|
+ ret, err := IncrByErr(code, key)
|
|
|
|
+ if nil != err {
|
|
|
|
+ log.Println("redisutil-INCR-Error", err)
|
|
|
|
+ }
|
|
|
|
+ return ret
|
|
|
|
+}
|
|
|
|
+
|
|
|
|
+//自增计数器
|
|
|
|
+func IncrByErr(code, key string) (int64, error) {
|
|
defer catch()
|
|
defer catch()
|
|
conn := RedisPool[code].Get()
|
|
conn := RedisPool[code].Get()
|
|
defer conn.Close()
|
|
defer conn.Close()
|
|
ret, err := conn.Do("INCR", key)
|
|
ret, err := conn.Do("INCR", key)
|
|
if nil != err {
|
|
if nil != err {
|
|
- log.Println("redisutil-INCR-Error", err)
|
|
|
|
|
|
+ return 0, err
|
|
|
|
+ }
|
|
|
|
+ if res, ok := ret.(int64); ok {
|
|
|
|
+ return res, nil
|
|
} else {
|
|
} else {
|
|
- if res, ok := ret.(int64); ok {
|
|
|
|
- return res
|
|
|
|
- } else {
|
|
|
|
- return 0
|
|
|
|
- }
|
|
|
|
|
|
+ return 0, nil
|
|
}
|
|
}
|
|
- return 0
|
|
|
|
}
|
|
}
|
|
|
|
|
|
//自减
|
|
//自减
|