怎么用redigo操作redis？

2024-08-26 16:00:05 浏览数 (2)

前言

redigo能用于go操作redis，用于实现Redis数据库的基本操作,支持Redis的所有命令

redigo使用

redigo依赖安装

使用以下命令安装redigo依赖，以前使用的是这个命令，但是这个依赖过时了，使用最下面的安装依赖

代码语言：javascript复制
arduino 代码解读复制代码 go get github.com/garyburd/redigo/redis

redigo最新依赖

代码语言：javascript复制
arduino 代码解读复制代码 go get github.com/gomodule/redigo/redis

redigo使用

说明: redigo使用Do()方法操作redis所有的api

redigo连接redis
代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}

	a, err1 := c.Do("ping")
	if err1 != nil {
		fmt.Println("连接失败:", err1)
		return
	}
	fmt.Println(a)

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}

输出结果为:

image.pngimage.png

备注:

如果redis有密码的话，使用以下连接

代码语言：javascript复制
go 代码解读复制代码c, err := redis.Dial("tcp", "localhost:6379", redis.DialPassword("123456"))
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}
redigo操作字符串

redis字符串的命令为: 设置数据为:

代码语言：javascript复制
sql 代码解读复制代码SET a1 a1

获取数据为

代码语言：javascript复制
sql 代码解读复制代码GET a1

redigo操作字符串

代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}

	_, err1 := c.Do("set", "a1", "a1")
	if err1 != nil {
		fmt.Println("设置数据失败:", err1)
		return
	}
	val, err2 := c.Do("get", "a1")
	if err != nil {
		fmt.Println("获取字符串失败:", err2)
		return
	}
	strVal, _ := redis.String(val, nil)
	fmt.Println("数据为: ", strVal)

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
设置键值过期时间示例
代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
	"time"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}

	_, err1 := c.Do("set", "hello1", "test", "EX", "5")
	if err1 != nil {
		fmt.Println("设置过期时间失败:", err1)
		return
	}
	time.Sleep(time.Second * 6)
	valWithEx, _ := redis.String(c.Do("get", "hello1"))
	fmt.Println("获取值为:", valWithEx)

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
redigo判断键值是否存在
代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}

	// 是否存在指定key
	exists, _ := c.Do("exists", "hello10")
	flag, _ := redis.Int(exists, nil)
	fmt.Println("hello10是否存在:", flag == 1)
	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
redigo操作List

将一个或多个值插入到列表头部

代码语言：javascript复制
 代码解读复制代码LPUSH list1 aa

在列表中添加一个或多个值到列表尾部

代码语言：javascript复制
kotlin 代码解读复制代码rpush list val

获取列表指定范围内的元素

代码语言：javascript复制
 代码解读复制代码 LRANGE runoobkey 0 10

redigo操作List

代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}
	c.Do("lpush", "list1", "l1")

	c.Do("rpush", "list1", "l3")
	list, _ := c.Do("lrange", "list1", "0", "100")
	l, _ := redis.Values(list, nil)
	for _, val := range l {
		fmt.Println(string(val.([]byte)))
	}

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
redigo操作Set

往set1添加数据

代码语言：javascript复制
 代码解读复制代码SADD set1 redis  aaa

获取set1数据

代码语言：javascript复制
 代码解读复制代码SMEMBERS set1

redigo操作set

代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}
	c.Do("sadd", "set1", "a1", "a2")

	list, _ := c.Do("smembers", "set1")
	l, _ := redis.Values(list, nil)
	for _, val := range l {
		fmt.Println(string(val.([]byte)))
	}

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
redigo操作hash

redis操作hash,将哈希表 key 中的字段 field 的值设为value

代码语言：javascript复制
markdown 代码解读复制代码	HSET key field value

获取在哈希表中指定 key 的所有字段和值

代码语言：javascript复制
vbnet 代码解读复制代码 HGETALL key

redigo操作hash

代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}
	_, err = c.Do("HSet", "books", "abc", 10)
	if err != nil {
		fmt.Println(err)
		return
	}

	r, err := redis.Int(c.Do("HGet", "books", "abc"))
	if err != nil {
		fmt.Println("get abc failed,", err)
		return
	}

	fmt.Println(r)

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
redigo操作zset

向有序集合添加一个或多个成员，或者更新已存在成员的分数

代码语言：javascript复制
css 代码解读复制代码ZADD key score1 member1 [score2 member2]

通过分数返回有序集合指定区间内的成员

代码语言：javascript复制
arduino 代码解读复制代码ZRANGEBYSCORE key min max [WITHSCORES] [LIMIT]

redigo操作zset

代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

func main() {
	c, err := redis.Dial("tcp", "localhost:6379")
	if err != nil {
		fmt.Println("redis连接失败:", err)
		return
	}
	_, err = c.Do("zadd", "runoobkey", 1, "redis")
	if err != nil {
		fmt.Println(err)
		return
	}

	r, err := c.Do("ZRANGE", "runoobkey", 0, 10, "WITHSCORES")
	if err != nil {
		fmt.Println("get abc failed,", err)
		return
	}

	l, _ := redis.Values(r, nil)
	for _, val := range l {
		fmt.Println(string(val.([]byte)))
	}

	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)
}
redigo使用连接池
代码语言：javascript复制
go 代码解读复制代码package main

import (
	"fmt"
	"github.com/gomodule/redigo/redis"
)

var pool *redis.Pool

func init() {
	pool = &redis.Pool{
		MaxIdle:     8,
		MaxActive:   0,  
		IdleTimeout: 300, 
		Dial: func() (redis.Conn, error) { 
			return redis.Dial("tcp", "localhost:6379")
		},
	}
}

func main() {
	c := pool.Get()
	defer func(c redis.Conn) {
		err := c.Close()
		if err != nil {

		}
	}(c)

	_, err := c.Do("set", "hello5", "aaa")
	if err != nil {
		fmt.Println(err)
		return
	}

	r, err := redis.Strings(c.Do("get", "hello5"))
	if err != nil {
		fmt.Println("获取键值失败:", err)
		return
	}
	fmt.Println(r)
	err1 := pool.Close()
	if err1 != nil {
		return
	}
}

总结

redigo的包操作较为简练，一般为操作redis的命令，至于在开发中的技术选型，看个人习惯以及是否能提高自己开发效率而定,但是redigo自身不支持集群，这点需要注意，要支持集群，需要引入其他包

数据库 redis

0 人点赞