Redis API——List 功能实践与性能测试【Go 版】
作者：FunTester
- 2022 年 8 月 15 日 北京
本文字数：3767 字
阅读完需：约 12 分钟
前文提到Go语言Redis API基本功能实践，以及后续的学习实践计划，由于总总原因耽搁了许久。终究是计划赶不上变化，学完 Go 语言操作 Redis 的常用功能之后，我打算把 API 实践、封装、简单性能测试场景放在一起写。
今天分享一下 Redis list 常用操作 API 的实践和性能测试，API 的封装会放在文末。
常用 API 实践
LPush、LPush、LPush、LPush
关于 API 的功能，看名字就能够明白八九不离十。两组变量：左和右，推送和获取。
下面是我写了一个测试用例，均测试通过。
func TestPushPop(t *testing.T) { var pool = redis.NewRdisPool("127.0.0.1:6379", base.Empty, 1) var key = "fun" var value = "abc" pool.LPush(key, value) pop := pool.LPop(key) assert.Equal(t, pop, value)}
func TestPushPop2(t *testing.T) { var pool = redis.NewRdisPool("127.0.0.1:6379", base.Empty, 1) var key = "fun" var value = "abc" pool.RPush(key, value) pop := pool.RPop(key) assert.Equal(t, pop, value)}
复制代码
XLen
这是一个获取 list 长度的 API。测试用例如下：
func TestLen(t *testing.T) { var pool = redis.NewRdisPool("127.0.0.1:6379", base.Empty, 1) var key = "fun" var value = "FunTester" len1 := pool.LLen(key) pool.LPush(key, value) len2 := pool.LLen(key) pool.LPop(key) len3 := pool.LLen(key) assert.Equal(t, len1, len3) assert.Equal(t, len1, len2-1)}
复制代码
LRange
获取某个范围的 list 数据，获取不会删除原始数据。用例如下：
func TestLRange(t *testing.T) { var pool = redis.NewRdisPool("127.0.0.1:6379", base.Empty, 1) var key = "fun" var value = "FunTester" pool.Del(key) for i := 0; i < 10; i++ { pool.RPush(key, value+strconv.Itoa(i)) } lRange := pool.LRange(key, 1, 3) for _, s := range lRange { log.Println(s) }}
复制代码
日志输出如下：
=== RUN TestLRange2022/08/13 17:13:31 Redis 连接成功2022/08/13 17:13:31 确认连接成功!2022/08/13 17:13:31 FunTester12022/08/13 17:13:31 FunTester22022/08/13 17:13:31 FunTester3--- PASS: TestLRange (0.00s)
复制代码
后来还有一些不常用的 API（对于我来讲）这里就不过多展示了，下面进入性能测试环节。
性能测试
这里我只设计了一个性能测试用例，添加和删除。这次使用的时间作为限制条件的压测模型。
func TestPushPopPerf(t *testing.T) { var pool = redis.NewRdisPool("127.0.0.1:6379", base.Empty, 1) var key = "fun" var value = "FunTester" execute.ExecuteRoutineTime(func() { pool.LPush(key, value) pool.RPop(key) }, 20, 2)}
复制代码
控制台输出：
=== RUN TestPushPopPerf2022/08/13 17:22:40 Redis 连接成功2022/08/13 17:22:40 确认连接成功!2022/08/13 17:23:00 总耗时: 20.0010002022/08/13 17:23:00 请求总数: 5320292022/08/13 17:23:00 QPS: 26600.119994--- PASS: TestPushPopPerf (20.00s)PASS
复制代码
API 封装
下面是我针对 Redis API 的封装源码，大家有兴趣的可以阅读原文去我的仓库。
package redis
import ( "funtester/base" "log")
// LPush// @Description: 从列表左边插入数据// @receiver r// @param key// @param value// @return int64//func (r RedisBase) LPush(key string, value interface{}) int64 { result, err := r.pool.LPush(key, value).Result() if err != nil { log.Printf("LPush:%s value: %s 失败\n", key, value) log.Println(err) return base.TestError } return result}
// RPush// @Description:从列表右边插入数据// @receiver r// @param key// @param value// @return int64//func (r RedisBase) RPush(key string, value interface{}) int64 { result, err := r.pool.RPush(key, value).Result() if err != nil { log.Printf("RPush:%s value: %s 失败\n", key, value) log.Println(err) return base.TestError } return result}
// LPop// @Description: 从列表左边删除第一个数据，并返回删除的数据// @receiver r// @param key// @param second// @return string//func (r RedisBase) LPop(key string) string { result, err := r.pool.LPop(key).Result() if err != nil { log.Printf("LPop:%s 失败\n", key) log.Println(err) return base.Empty } return result}
// RPop// @Description: 从列表的右边删除第一个数据，并返回删除的数据// @receiver r// @param key// @param second// @return string//func (r RedisBase) RPop(key string) string { result, err := r.pool.RPop(key).Result() if err != nil { log.Printf("RPop:%s 失败\n", key) log.Println(err) return base.Empty } return result}
// LLen// @Description: 返回列表的大小// @receiver r// @param key// @return int64//func (r RedisBase) LLen(key string) int64 { result, err := r.pool.LLen(key).Result() if err != nil { log.Printf("LLen :%s 失败\n", key) log.Println(err) return base.TestError } return result}
// LRange// @Description:返回列表的一个范围内的数据，也可以返回全部数据// @receiver r// @param key// @param start// @param end// @return []string//func (r RedisBase) LRange(key string, start, end int64) []string { result, err := r.pool.LRange(key, start, end).Result() if err != nil { log.Printf("LRange :%s 失败\n", key) log.Println(err) return nil } return result}
// LRem// @Description:删除列表中的数据//从列表左边开始删除， 如果出现重复元素，仅删除1次，也就是删除第一个(key,1,"FunTester")// 如果存在多个，则从列表左边开始删除2个100(key,2,"FunTester")// 如果存在多个，则从列表右边开始删除2个100(key,-2,"FunTester")// 删除所有(key,0,value)// @receiver r// @param key// @param count// @param value// @return int64//func (r RedisBase) LRem(key string, count int64, value interface{}) int64 { result, err := r.pool.LRem(key, count, value).Result() if err != nil { log.Printf("LRem :%s count: %d value: %s 失败\n", key, count, value) log.Println(err) return base.TestError } return result}
// LIndex// @Description:根据索引坐标，查询列表中的数据// @receiver r// @param key// @param index 索引,从0开始算// @return string//func (r RedisBase) LIndex(key string, index int64) string { result, err := r.pool.LIndex(key, index).Result() if err != nil { log.Printf("LIndex :%s index: %d 失败\n", key, index) log.Println(err) return base.Empty } return result}
// LInsertBefore// @Description:在指定位置插入数据// @receiver r// @param key// @param pivot// @param value// @return int64//func (r RedisBase) LInsertBefore(key string, pivot, value interface{}) int64 { result, err := r.pool.LInsertBefore(key, pivot, value).Result() if err != nil { log.Printf("LInsertBefore :%s pivot: %s value:%s 失败\n", key, pivot, value) log.Println(err) return base.TestError } return result}
// LInsertAfter// @Description:在指定位置插入数据// @receiver r// @param key// @param pivot// @param value// @return int64//func (r RedisBase) LInsertAfter(key string, pivot, value interface{}) int64 { result, err := r.pool.LInsertAfter(key, pivot, value).Result() if err != nil { log.Printf("LInsertAfter :%s pivot: %s value:%s 失败\n", key, pivot, value) log.Println(err) return base.TestError } return result}
复制代码
❝
FunTester原创专题集锦
-- By FunTester
阅读原文，跳转我的仓库地址
划线
评论
复制
发布于: 刚刚阅读数: 2
版权声明: 本文为 InfoQ 作者【FunTester】的原创文章。
原文链接:【http://xie.infoq.cn/article/afdb6d88e725fb785079bf21b】。文章转载请联系作者。
FunTester
关注
公众号：FunTester，800篇原创，欢迎关注 2020.10.20 加入
Fun·BUG挖掘机·性能征服者·头顶锅盖·Tester
评论