`Set/Get`操作

`Do`方法

我们最常用的是Do方法，执行同步指令，通过向Redis Server发送对应的Redis API命令，来使用Redis Server的服务。Do方法最大的特点是内部自行从连接池中获取连接对象，使用完毕后自动丢回连接池中，开发者无需手动调用Close方法，方便使用。

基本使用

Code Block

language	go

package main

import (
	"fmt"

	_ "github.com/gogf/gf/v2contrib/frame/g"
	"github.com/gogf/gf/v2/os/gctx"
)

func main() {
	var (
		ctx = gctx.New()
	)
	v, _ := g.Redis().Do(ctx, "SET", "k", "v")
	fmt.Println(v.String())
}

`HSET/HGETALL`操作

Code Block

language	go

package main

import (
	"fmt"
	"github.com/gogf/gf/v2/container/gvar"nosql/redis/v2"

	"github.com/gogf/gf/v2/frame/g"
	"github.com/gogf/gf/v2/os/gctx"
)

func main() {
	var (
		err    error
		result *gvar.Var
		key    = "user"
		ctx = gctx.New()
	)
	_, err := g.Redis().DoSet(ctx, "HSETkey", key, "idvalue", 10000)
	if err != nil {
		panic(g.Log().Fatal(ctx, err)
	}
	_value, err := g.Redis().DoGet(ctx,"HSET ", key, "name", "john")
	if err != nil {
		panic(err)
	}
	result, err = g.RedisLog().DoFatal(ctx,"HGETALL", key)
	if err != nil {
		panic(err)
	}
	fmt.Println(resultvalue.MapString())

	// May Output:
	// map[id:10000 name:john]
}

`HMSET/HMGET`操作

我们可以通过map参数执行HMSET操作。

执行后，终端输出：

Code Block

language	xml

value

`SetEx`操作

Code Block

language	go

package main

import (
	"fmt"
	"time"

	_ "github.com/gogf/gf/contrib/v2nosql/frameredis/gv2"

	"github.com/gogf/gf/v2/osframe/gctxg"
	"github.com/gogf/gf/v2/utilos/gutilgctx"
)

func main() {
	var (
		ctx = gctx.New()
		key  = "user_100"
		data err := 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(ctx, "HMSET", 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().DoGet(ctx, "HMGET", key, "name")
	if err != nil {
		g.Log().Fatal(ctx, err)
	}
	fmt.Println(vvalue.SliceIsNil())

	// May Output:
	// [gf]
}

我们可以通过struct参数执行HMSET操作。

	fmt.Println(value.Val())
}

执行后，终端输出：

Code Block

language	xml

false
value
true
<nil>

`HSet/HGetAll`操作

Code Block

language	go

package main

import (
	"fmt"

	_ "github.com/gogf/gf/contrib/v2nosql/frameredis/gv2"

	"github.com/gogf/gf/v2/osframe/gctxg"
	"github.com/gogf/gf/v2/utilos/gutilgctx"
)

func main() {
	type User struct {
		Name  string `json:"name"`
		Sex   int    `json:"sex"`
		Score int    `json:"score"`
	}
	var (
		ctx = gctx.New()
		key  = "user_100key"
		data = &User)
	_, err := g.Redis().HSet(ctx, key, g.Map{
			Name:"id":    "gf"1,
			Sex"name":   0"john",
			Score"score": 100,
		}
	)
	_, err := g.Redis().Do(ctx,"HMSET", append(g.Slice{key}, gutil.StructToSlice(data)...)...)
	if err != nil {
		g.Log().Fatal(ctx, err)
	}
	v
	// retrieve hash map
	value, err := g.Redis().DoHGetAll(ctx,"HMGET", 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
由于该`Conn`是个连接对象，注意该对象存在连接超时的限制，超时和服务端配置有关。

基本使用

package main import (

type User struct {
		Id

"fmt" "github.com/gogf/gf/frame/g" "github.com/gogf/gf/util/gconv" ) func main() { conn := g.Redis().Conn() defer conn.Close() conn.Do("SET", "k", "v") v, _ := conn.Do("GET", "k") fmt.Println(gconv.String(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

订阅/发布

我们可以通过Redis的SUBSCRIBE/PUBLISH命令实现订阅/发布模式。

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

language	xml

map[id:1 name:john score:100]
{
    Id:    1,
    Name:  "john",
    Score: 100,
}

`HMSet/HMGet`操作

Code Block

language	go

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() _, err := conn.Do("SUBSCRIBE", "channel") if err != nil { panic(err) } for { reply, err := conn.Receive() if err != nil { panic(err) } fmt.Println(gconv.Strings(reply)) } }

执行后，程序将阻塞等待获取数据。

另外打开一个终端通过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/

container

frame/

gvar

g"
	"github.com/gogf/gf/v2/

frame

os/

g

gctx"
)

func main() {
	var (

err

ctx

error result *gvar.Var

= gctx.New()
		key

= "

user

key"
	)

data

err :=

=

g.Redis().HMSet(ctx, key, g.Map{

		"id":

10000

1,

		"name":  "john",

}

)

_, err = g.Redis().Do("SET", key, data

"score": 100,
	})
	if err != nil {

panic(err) } result, err =

g.

Redis

Log().

DoVar

Fatal(

"GET", key) if err != nil { panic(

ctx, err)
	}

fmt.Println(result.Map())

}

`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

 retrieve hash map
	values, err := g.Redis().

Do

HMGet(

"SET"

ctx, key, "id",

user

"name")
	if err != nil {

panic(

g.Log().Fatal(ctx, err)
	}

result, err =

g.

Redis

Dump(

)

values.

DoVar("GET", key) if err != nil { panic(err) } var user2 *User if err = result.Struct(&user2); err != nil { panic(err) } fmt.Println(user2.Id, user2.Name) }

Strings())
}

执行后，终端输出：

Code Block

language	xml

[
    "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

title	Content Menu

Table of Contents

Space shortcuts

Page tree

Versions Compared

Old Version 13

New Version Current

Key

`Set/Get`操作

`Do`方法

基本使用

`HSET/HGETALL`操作

`HMSET/HMGET`操作

`SetEx`操作

`HSet/HGetAll`操作

`Conn`连接对象

基本使用

`Send`批量指令

订阅/发布

`HMSet/HMGet`操作

自动序列化/反序列化

`map`存取

`struct`存取

Space shortcuts

Page tree

Page History

Versions Compared

Old Version 13

New Version Current

Key

Set/Get操作

Do方法

基本使用

HSET/HGETALL操作

HMSET/HMGET操作

SetEx操作

HSet/HGetAll操作

Conn连接对象

基本使用

Send批量指令

订阅/发布

HMSet/HMGet操作

自动序列化/反序列化

map存取

struct存取

`Set/Get`操作

`Do`方法

`HSET/HGETALL`操作

`HMSET/HMGET`操作

`SetEx`操作

`HSet/HGetAll`操作

`Conn`连接对象

`Send`批量指令

`HMSet/HMGet`操作

`map`存取

`struct`存取