更新redis,支持byte更新
This commit is contained in:
parent
830b635af7
commit
f998db645e
|
|
@ -80,19 +80,21 @@ func Get(key string) interface{} {
|
|||
return reply
|
||||
}
|
||||
|
||||
//Set 设置一个值
|
||||
func Set(key string, val interface{}, timeout time.Duration) (err error) {
|
||||
//设置一个值
|
||||
func Set(key string, val interface{}, timeout time.Duration) error {
|
||||
data, err := json.Marshal(val)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return SetBytes(&key, &data, timeout)
|
||||
}
|
||||
|
||||
func SetBytes(key *string, data *[]byte, timeout time.Duration) error {
|
||||
conn := pool.Get()
|
||||
defer conn.Close()
|
||||
|
||||
var data []byte
|
||||
if data, err = json.Marshal(val); err != nil {
|
||||
return
|
||||
}
|
||||
|
||||
_, err = conn.Do("SETEX", key, int64(timeout/time.Second), data)
|
||||
|
||||
return
|
||||
_, err := conn.Do("SETEX", key, int64(timeout/time.Second), *data)
|
||||
return err
|
||||
}
|
||||
|
||||
//IsExist 判断key是否存在
|
||||
|
|
|
|||
Loading…
Reference in New Issue