Jelajahi Sumber

cache.Redis增加SetConn方法,修改redis包地址

Xian Zhao 7 tahun lalu
induk
melakukan
a241ec4c14
1 mengubah file dengan 6 tambahan dan 1 penghapusan
  1. 6 1
      cache/redis.go

+ 6 - 1
cache/redis.go

@@ -4,7 +4,7 @@ import (
 	"encoding/json"
 	"time"
 
-	"github.com/garyburd/redigo/redis"
+	"github.com/gomodule/redigo/redis"
 )
 
 //Redis redis cache
@@ -45,6 +45,11 @@ func NewRedis(opts *RedisOpts) *Redis {
 	return &Redis{pool}
 }
 
+//SetConn 设置conn
+func (r *Redis) SetConn(conn *redis.Pool) {
+	r.conn = conn	
+}
+
 //Get 获取一个值
 func (r *Redis) Get(key string) interface{} {
 	conn := r.conn.Get()