文档建议反馈控制台
首页
学习
活动
专区
圈层
工具
MCP广场
文章/答案/技术大牛
发布
社区首页 >专栏 >怎么用redigo操作redis？

怎么用redigo操作redis？

作者头像
闻说社
发布于 2024-08-26 16:00:05
发布于 2024-08-26 16:00:05
3570
举报

前言

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.png
image.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自身不支持集群，这点需要注意，要支持集群，需要引入其他包

本文系转载，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

数据库
redis

本文系转载，前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

数据库
redis
评论
登录后参与评论
0 条评论
热度
最新
登录 后参与评论
推荐阅读
目录
  • 前言
  • redigo使用
    • redigo依赖安装
  • redigo使用
    • redigo连接redis
    • redigo操作字符串
    • 设置键值过期时间示例
    • redigo判断键值是否存在
    • redigo操作List
    • redigo操作Set
    • redigo操作hash
    • redigo操作zset
    • redigo使用连接池
  • 总结
领券

腾讯云开发者

扫码关注腾讯云开发者

扫码关注腾讯云开发者

领取腾讯云代金券

热门产品

热门推荐

更多推荐

Copyright © 2013 - 2025 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有 

深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 粤公网安备44030502008569号

腾讯云计算（北京）有限责任公司 京ICP证150476号 |  京ICP备11018762号

问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档

Copyright © 2013 - 2025 Tencent Cloud.

All Rights Reserved. 腾讯云 版权所有

登录 后参与评论