参考链接
-
RDM 一款 redis 数据管理工具！
Redis应用场景
- 缓存系统，减轻主数据库（MySQL）的压力。
- 计数场景，比如微博、抖音中的关注数和粉丝数。
- 热门排行榜，需要排序的场景特别适合使用ZSET。
- 利用 LIST 可以实现队列的功能。
- 利用 HyperLogLog 统计UV、PV等数据。
- 使用 geospatial index 进行地理位置相关查询。
Redis 有 6 种基础数据结构，
它们分别是：string(字符串)、list(列表)、hash(字典)、set(集合) 、 **zset(有序集合)**和 Stream(流)。
这 6 种是 Redis 相关知识中最基础、最重要的部分。
环境准备
同样使用 docker 启动一个 redis 的服务,比较方便，下面是 docker-compose 文件！
# Use root/example as user/password credentials
version: '3.1'
services:
redisDb:
container_name: redisDB
image: redis
restart: always
ports:
- 6379:6379
volumes:
- /Users/hope/sdy/temp_go_test/redis:/data
启动测试
❯ docker-compose up -d
Recreating go-dirver-mysql-test ... done
Creating redisDB ... done
❯ docker container ls -a
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES
d2d8acf11d79 mysql "docker-entrypoint.s…" 16 seconds ago Up 15 seconds 0.0.0.0:3306->3306/tcp, 33060/tcp go-dirver-mysql-test
e54abf029737 redis "docker-entrypoint.s…" 20 seconds ago Up 18 seconds 0.0.0.0:6379->6379/tcp redisDB
那么环境就准备好了！
安装&连接
使用以下命令下安装 go-redis 库。
go get -u github.com/go-redis/redis
引入使用！
封装到初始化模块！ initialization
package initialization
import (
"fmt"
"github.com/go-redis/redis"
)
func InitRedisDB() (rdb *redis.Client, err error) {
rdb = redis.NewClient(&redis.Options{
Addr: "localhost:6379",
Password: "", // 没有密码设置 no password set
DB: 0, // 默认 db use default DB
})
sc := rdb.Ping()
if sc.Err() != nil {
return nil, sc.Err()
}
fmt.Println("redis connect successfully！")
return //tips:这里的返回值中有有变量名，所以直接return就行了！
}
main 中执行初始化！
package main
import (
"gotest/initialization"
"github.com/go-redis/redis"
"github.com/jmoiron/sqlx"
)
var sqlxDB *sqlx.DB
var err error
var rdb *redis.Client
func main() {
sqlxDB, err = initialization.InitSqlxDB()
if err != nil {
panic("数据库连接失败" + err.Error())
}
defer sqlxDB.Close()
rdb, err = initialization.InitRedisDB()
if err != nil {
panic("redis 连接失败" + err.Error())
}
defer rdb.Close()
}
执行 go 程序! Ok 的！
❯ go run main.go
data base connect successfully!
redis connect successfully！
redis set/get 存string(字符串)
func TestGetSet() {
s, err := rdb.Set("test", "1", time.Hour).Result()
if err != nil {
panic(err)
}
fmt.Println(s)
s, err = rdb.Get("test").Result()
// rdb.Get("test").Val() 也可以直接返回值！
if err != nil {
panic(err)
}
fmt.Println(s)
}
执行
❯ go run main.go
data base connect successfully!
redis connect successfully！
OK
1
RDM 中查看数据！
redis hashSet/hashGet 存 hash(字典)
HSet(target,key,value).Result()HGet(key,value).Result()|| （HGet(key,value).Val()直接返回值！）HGetAll(target).Result()->map返回完整的 target 字典map类型！HMGetAll(target,...fields)-> 返回字段在 target hash字典中对应的值，这些值是放在一个slice切片中！
func TestHashGetSet() {
_, err = rdb.HSet("family", "dad", "jack").Result()
_, err = rdb.HSet("family", "mom", "marry").Result()
_, err = rdb.HSet("family", "son", "tom").Result()
if err != nil {
panic(err)
}
r1, err := rdb.HGet("family", "dad").Result()
if err != nil {
panic(err)
}
r2, err := rdb.HGet("family", "mom").Result()
if err != nil {
panic(err)
}
r3 := rdb.HGet("family", "son").Val()
if err != nil {
panic(err)
}
r4, err := rdb.HGetAll("family").Result()
if err != nil {
panic(err)
}
r5, err := rdb.HMGet("family", "mom", "son").Result()
fmt.Println(r1)
fmt.Println(r2)
fmt.Println(r3)
fmt.Println(r4)
fmt.Println(r5)
}
执行
❯ go run main.go
data base connect successfully!
redis connect successfully！
jack
marry
tom
map[dad:jack mom:marry son:tom]
[marry tom]
RDM 中查看数据！
redis 操作 zset 有序集合
常用 redis zset 操作命令
redis.Z 结构体
redis.Z 是 go-redis 提供的一个结构体！用来初始化一个根据 Score 排序 (sorted) 的集合！
// Z represents sorted set member.
type Z struct {
Score float64
Member interface{}
}
ZAdd 添加 zset 集合 到 redis
// Redis `ZADD key score member [score member ...]` command.
func (c *cmdable) ZAdd(key string, members ...Z) *IntCmd
添加 zset 集合 到 redis
// key
zsetKey := "language_rank"
languages := []redis.Z{
{Score: 90.0, Member: "Golang"},
{Score: 98.0, Member: "Java"},
{Score: 95.0, Member: "Python"},
{Score: 97.0, Member: "JavaScript"},
{Score: 99.0, Member: "C/C++"},
}
i, err := rdb.ZAdd(zsetKey, languages...).Result()
if err != nil {
panic(err.Error())
}
fmt.Print(i) // 5
RDM 查看一下！
ZIncrBy 修改redis.Z成员的Score
func (c *cmdable) ZIncrBy(key string, increment float64, member string) *FloatCmd
increment 传入正数代表+传入负数代表-
func TestZset() {
// key
zsetKey := "language_rank"
languages := []redis.Z{
{Score: 90.0, Member: "Golang"},
{Score: 98.0, Member: "Java"},
{Score: 95.0, Member: "Python"},
{Score: 97.0, Member: "JavaScript"},
{Score: 99.0, Member: "C/C++"},
}
i, err := rdb.ZAdd(zsetKey, languages...).Result()
if err != nil {
panic(err.Error())
}
fmt.Println(i) // 5
f := rdb.ZIncrBy(zsetKey, 10, "Golang").Val() // Val 返回加后的值！
if err != nil {
panic(err.Error())
}
fmt.Println(f) // 100
}
注意这个操作只能对已经添加到redis 的 set 值生效！
zsetKey := "language_rank"
languages := []redis.Z{
{Score: 90.0, Member: "Golang"},
{Score: 98.0, Member: "Java"},
{Score: 95.0, Member: "Python"},
{Score: 97.0, Member: "JavaScript"},
{Score: 99.0, Member: "C/C++"},
}
// 先修改
f := rdb.ZIncrBy(zsetKey, 10, "Golang").Val()
if err != nil {
panic(err.Error())
}
fmt.Println(f)
// 然后 add
i, err := rdb.ZAdd(zsetKey, languages...).Result()
if err != nil {
panic(err.Error())
}
fmt.Println(i)
可以看到这种情况没有修改成功！
ZRevRangeWithScores 从大到小取指定个数元素
func (c *cmdable) ZRevRangeWithScores(key string, start, stop int64)
有序集成员按分数值递减**(从大到小)**的次序排列,取 [start-stop]的元素！注意元素索引从 0 开始！
z, err := rdb.ZRevRangeWithScores(zsetKey, 0, 3).Result() // [0,1,2,3]
if err != nil {
panic(err.Error())
}
fmt.Print(z) // [ {100 Golang} {99 C/C++} {98 Java} {97 JavaScript} ]
ZRangeByScore 取指定区间的元素
对应 Redis Zrangebyscore 命令
使用方式:
// 找到 95-98分之间！
r, err := rdb.ZRangeByScore(zsetKey, redis.ZRangeBy{
Min: "95",
Max: "98",
}).Result()
if err != nil {
panic(err.Error())
}
fmt.Print(r) // [Python JavaScript Java]
更多的，以后再业务场景参考redis命令！
评论区