ljydlv
/
videoplayer
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

修改redis日志输出

This commit is contained in:
junleea 2025-06-02 14:47:38 +08:00
parent abd00e9ec0
commit 892e080d6a
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
worker/redis.go
View File

@ -50,7 +50,7 @@ func IsContainKey(key string) bool {
ctx := context.Background()
val, err := RedisClient.Exists(ctx, key).Result() // 检查键是否存在, 如果存在则返回 1, 否则返回 0
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return false
}
if val == 0 {
@ -170,7 +170,7 @@ func GetRedis(key string) string {
ctx := context.Background()
val, err := RedisClient.Get(ctx, key).Result() // 从 Redis 读取键值, 如果键不存在则返回空字符串, 如果出现错误则返回错误
if err != nil {
fmt.Println(key, " Error getting key: %v", err)
//fmt.Println(key, " Error getting key: %v", err)
return ""
}
return val
@ -220,7 +220,7 @@ func GetRedisListLen(key string) int64 {
ctx := context.Background()
val, err := RedisClient.LLen(ctx, key).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return 0
}
return val
@ -281,7 +281,7 @@ func hGetRedis(key string, field string) string {
ctx := context.Background()
val, err := RedisClient.HGet(ctx, key, field).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
}
return val
}
@ -362,7 +362,7 @@ func GetRedisSetIntersect(key1 string, key2 string) []string {
ctx := context.Background()
val, err := RedisClient.SInter(ctx, key1, key2).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return nil
}
return val
@ -373,7 +373,7 @@ func IsContainSet(key string, value string) bool {
ctx := context.Background()
val, err := RedisClient.SIsMember(ctx, key, value).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return false
}
return val
@ -384,7 +384,7 @@ func GetRedisSetMembers(key string) []string {
ctx := context.Background()
val, err := RedisClient.SMembers(ctx, key).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return nil
}
return val
@ -395,7 +395,7 @@ func SetRedisBitmap(key string, offset int64, value int) bool {
ctx := context.Background()
err := RedisClient.SetBit(ctx, key, offset, value).Err()
if err != nil {
fmt.Println("Error setting key: %v", err)
//fmt.Println("Error setting key: %v", err)
return false
}
return true
@ -406,7 +406,7 @@ func GetRedisBitmap(key string, offset int64) int {
ctx := context.Background()
val, err := RedisClient.GetBit(ctx, key, offset).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return 0
}
return int(val)
@ -476,7 +476,7 @@ func GetRedisSetUnion(key1 string, key2 string) []string {
ctx := context.Background()
val, err := RedisClient.SUnion(ctx, key1, key2).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return nil
}
return val
@ -494,7 +494,7 @@ func GetAllRedisInfo() ([]RedisInfo, error) {
ctx := context.Background()
keys, err := RedisClient.Keys(ctx, "*").Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return nil, err
}
var redisInfos []RedisInfo
@ -502,12 +502,12 @@ func GetAllRedisInfo() ([]RedisInfo, error) {
//先查看key类型，再根据类型获取value
key_type, val, err := getKeyTypeAndData(key)
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return nil, err
}
expire, err := RedisClient.TTL(ctx, key).Result()
if err != nil {
fmt.Println("Error getting key: %v", err)
//fmt.Println("Error getting key: %v", err)
return nil, err
}
redisInfo := RedisInfo{