redis scan命令_redis 查询命令

大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

我们可能会遇到需要运行的某些命令在godis中不存在的情况，这个时候我们可以使用其原生的方式运行命令，为了方便使用，封装了一个方法，用于简化这个过程。需要注意的是，执行命令的返回结果返回的是interface{}，需要对其进行解析成可读的实体结构。

传递的参数logger是用来打印日志的：

// RunRedisCmd 运行redis命令
func RunRedisCmd(redis *godis.Redis, logger *log.Logger, cmd string, args ...string) (interface{ 
   }, error) { 
   
	byteArr := make([][]byte, len(args))
	cmdStr := cmd
	for i, str := range args { 
   
		byteArr[i] = []byte(str)
		cmdStr += fmt.Sprint(" ", str)
	}
	if logger != nil { 
   
		logger.Println(cmdStr)
	}
	err := redis.SendByStr(cmd, byteArr...)
	if err != nil { 
   
		if logger != nil { 
   
			logger.Println(err)
		}
		return nil, err
	}
	// 一定要receive
	r, err := redis.Receive()
	if err != nil { 
   
		if logger != nil { 
   
			logger.Println(err)
		}
		return r, err
	}
	if logger != nil { 
   
		if r != nil { 
   
			switch r.(type) { 
   
			case []byte:
				logger.Println(string(r.([]byte)))
			case int64:
				logger.Println(r.(int64))
			case []interface{ 
   }:
				logger.Println("\n", SprintArrAsRedis(0, r.([]interface{ 
   })))
			default:
				logger.Println(r)
			}
		} else { 
   
			logger.Println(r)
		}
	}
	return r, nil
}

// SprintArrAsRedis 打印redis返回的数组格式的数据，以redis的方式
//
// 127.0.0.1:16379> xrange testStream - +
//
// 1) 1) "1650986325904-0"
// 2) 1) "msg"
// 2) "hello"
func SprintArrAsRedis(spaceSize int, result []interface{ 
   }) string { 
   
	str := ""
	for i, data := range result { 
   
		if i != 0 { 
   
			for j := 0; j < spaceSize; j++ { 
   
				str += " "
			}
		}
		str += fmt.Sprintf("%d) ", i+1)
		markArr := false
		switch data.(type) { 
   
		case []byte:
			str += string(data.([]byte))
		case []interface{ 
   }:
			str += SprintArrAsRedis(spaceSize+3, data.([]interface{ 
   }))
			markArr = true
		default:
			str += fmt.Sprint(data)
		}
		if !markArr { 
   
			str += "\n"
		}
	}

	return str
}

单元测试：

package test

import (
	"github.com/piaohao/godis"
	"log"
	"momo/utils"
	"os"
	"testing"
	"time"
)

func Test_RunRedisCmd(t *testing.T) { 
   
	option := &godis.Option{ 
   
		Host:              "localhost",
		Port:              16379,
		Db:                0,
		ConnectionTimeout: 10 * time.Second,
		SoTimeout:         10 * time.Second,
	}
	pool := godis.NewPool(&godis.PoolConfig{ 
   }, option)
	redis, _ := pool.GetResource()

	logger := log.New(os.Stdout, "redis log ", log.Ldate|log.Lmicroseconds|log.Lshortfile)

	rsl, err := utils.RunRedisCmd(redis, logger, "set", "userage", "1")
	if err != nil || rsl == nil || string(rsl.([]byte)) != "OK" { 
   
		t.Error("fail set", err)
	}

	rsl, err = utils.RunRedisCmd(redis, logger, "incr", "userage")
	if err != nil || rsl == nil || rsl.(int64) != 2 { 
   
		t.Error("fail incr", err)
	}

	rsl, err = utils.RunRedisCmd(redis, logger, "del", "userage")
	if err != nil || rsl == nil || rsl.(int64) != 1 { 
   
		t.Error("fail del", err)
	}
}