Versions Compared
Key
- This line was added.
- This line was removed.
- Formatting was changed.
Set/Get
操作
Do/DoVar
方法
我们最常用的是Do/DoVar
方法,执行同步指令,通过向Redis Server
发送对应的Redis API
命令,来使用Redis Server
的服务。Do/Var
方法最大的特点是内部自行从连接池中获取连接对象,使用完毕后自动丢回连接池中,开发者无需手动调用Close
方法,方便使用。
Do
和DoVar
的区别在于返回的结果类型不一样,DoVar
返回的是gvar.Var
类型,该类型对象可以执行非常方便的类型转换。
基本使用
Code Block | ||
---|---|---|
| ||
package main import ( "fmt" _ "github.com/gogf/gf/contrib/nosql/frameredis/gv2" ) func main() { g.Redis().Do("SET", "k", "v") v, _ := g.Redis().DoVar("GET", "k") fmt.Println(v.String()) } |
HSET/HGETALL
操作
Code Block | ||
---|---|---|
| ||
package main import ( "fmt" "github.com/gogf/gf/v2/containerframe/gvarg" "github.com/gogf/gf/v2/frameos/ggctx" ) func main() { var ( errctx error result *gvar.Var key = "user" = gctx.New() _, err := g.Redis().DoSet("HSET"ctx, "key", "idvalue", 10000) if err != nil { panic(g.Log().Fatal(ctx, err) } _value, err := g.Redis().DoGet("HSET"ctx, key, "name", "john"key") if err != nil { panic(err) } result, err = g.RedisLog().DoVarFatal("HGETALL"ctx, key) if err != nil { panic(err) } fmt.Println(resultvalue.MapString()) // May Output: // map[id:10000 name:john] } |
HMSET/HMGET
操作
我们可以通过map
参数执行HMSET
操作。
} |
执行后,终端输出:
Code Block | ||
---|---|---|
| ||
value |
SetEx
操作
Code Block | ||
---|---|---|
| ||
package main import ( "fmt" "time" _ "github.com/gogf/gf/contrib/nosql/redis/v2" "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/utilos/gutilgctx" ) func main() { var ( key ctx = "user_100"gctx.New() dataerr := g.Map{ "name": "gf", "sex": 0, "score": 100, } ) _Redis().SetEX(ctx, "key", "value", 1) if err != nil { g.Log().Fatal(ctx, err) } value, err := g.Redis().DoGet("HMSET"ctx, append(g.Slice{key}, gutil.MapToSlice(data)...)..."key") if err != nil { g.Log().Fatal(ctx, err) } v fmt.Println(value.IsNil()) fmt.Println(value.String()) time.Sleep(time.Second) value, err := g.Redis().DoVarGet("HMGET"ctx, "key, "name") if err != nil { g.Log().Fatal(ctx, err) } fmt.Println(v.Slice(value.IsNil()) fmt.Println(value.Val()) // May Output: // [gf] } |
struct
参数执行HMSET
操作。} |
执行后,终端输出:
Code Block | ||
---|---|---|
| ||
false
value
true
<nil> |
HSet/HGetAll
操作
Code Block | ||
---|---|---|
| ||
package main import ( "fmt" _ "github.com/gogf/gf/contrib/nosql/redis/v2" "github.com/gogf/gf/v2/frame/g" "github.com/gogf/gf/v2/utilos/gutilgctx" ) func main() { type User struct {var ( Namectx string `json:"name"`= gctx.New() Sexkey int `json:"sex"` Score int `json:"score"` } var ( key = "user_100" data = &User{ Name: "gf", Sex: 0, Score: 100, } ) _, err := g.Redis().Do("HMSET", append(g.Slice{key}, gutil.StructToSlice(data)...)...)= "key" ) _, err := g.Redis().HSet(ctx, key, g.Map{ "id": 1, "name": "john", "score": 100, }) if err != nil { g.Log().Fatal(ctx, err) } // retrieve hash map vvalue, err := g.Redis().DoVarHGetAll("HMGET"ctx, key, "name") if err != nil { g.Log().Fatal(ctx, err) } fmt.Println(vvalue.SliceMap()) // scan Mayto Output:struct // [gf] } |
Conn
连接对象
使用Do/DoVar
方法已经能够满足绝大部分的场景需要,如果需要更复杂的Redis操作,那么我们可以使用Conn
方法从连接池中获取一个连接对象,随后使用该连接对象进行操作。但需要注意的是,该连接对象不再使用时,应当显式调用Close
方法进行关闭(丢回连接池)。
Note |
---|
由于该 |
基本使用
package main import (type User struct { Id |
uint64
Name string
Score float64
}
var user *User
if err = value.Scan(&user); err != nil {
g.Log().Fatal(ctx, err)
}
g.Dump(user)
} |
执行后,终端输出:
Code Block | ||
---|---|---|
| ||
map[id:1 name:john score:100]
{
Id: 1,
Name: "john",
Score: 100,
} |
HMSet/HMGet
操作
Code Block | ||
---|---|---|
|
执行后,输出结果为:
v
Send
方法
Send
可以执行批量指令,并通过Receive
方法一一获取返回结果。
package main
import (
"fmt"
"github.com/gogf/gf/frame/g"
"github.com/gogf/gf/util/gconv"
)
func main() {
conn := g.Redis().Conn()
defer conn.Close()
conn.Send("SET", "foo", "bar")
conn.Send("GET", "foo")
conn.Flush()
// reply from SET
conn.Receive()
// reply from GET
v, _ := conn.Receive()
fmt.Println(gconv.String(v))
}
执行后,输出结果为:
bar
订阅/发布package main
import (
|
_ "github.com/gogf/gf/ |
执行后,程序将阻塞等待获取数据。
另外打开一个终端通过redis-cli
命令进入Redis Server,发布一条消息:
$ redis-cli
127.0.0.1:6379> publish channel test
(integer) 1
127.0.0.1:6379>
随后程序终端立即打印出从Redis Server获取的数据:
[message channel test]
自动序列化/反序列化
当给定的参数为map
, slice
, struct
时,gredis
内部支持自动对其使用json
序列化,并且读取数据时可使用gvar.Var
的转换功能实现反序列化。
map
存取
package main
import (
"fmt"
contrib/nosql/redis/v2" "github.com/gogf/gf/v2/ |
frame/ |
g" "github.com/gogf/gf/v2/ |
os/ |
gctx" ) func main() { var ( |
ctx |
= gctx.New() key |
= " |
key" ) |
err := |
g.Redis().HMSet(ctx, key, g.Map{ |
"id": |
1, |
"name": "john", |
|
|
"score": 100, }) if err != nil { |
g. |
Log(). |
Fatal( |
struct
存取
package main
import (
"fmt"
"github.com/gogf/gf/container/gvar"
"github.com/gogf/gf/frame/g"
)
func main() {
type User struct {
Id int
Name string
}
var (
err error
result *gvar.Var
key = "user"
user = &User{
Id: 10000,
Name: "john",
}
)
_, err ctx, err) } // retrieve hash map values, err := g.Redis(). |
HMGet( |
ctx, key, "id", |
"name") if err != nil { |
g.Log().Fatal(ctx, err) } |
g. |
Dump( |
values. |
Strings())
} |
执行后,终端输出:
Code Block | ||
---|---|---|
| ||
[
"1",
"john",
] |
As per Redis 4.0.0, HMSET is considered deprecated. Please use HSET in new code.
根据Redis 4.0.0
,HMSET
被视为已弃用。请在新代码中使用HSET
。
Panel | ||
---|---|---|
| ||
|