一、Redis
1. 应用场景
(1) 缓存-热点数据
热点数据:经常会被查询,但是不经常被修改或删除的数据
(2) 计数器
文章点赞数与阅读数等,因为是单线程操作,所以可以保证不会出错
(3) 短信验证码
(4) 分布式锁
秒杀系统,防止数据库“爆破”
(5) 购物车
(6) 限流
限制访问者ip
2. 优点
- 速度快,因为数据存在内存中,类似于HashMap,HashMap的优势就是查找和操作的时间复杂度都是O(1)
- 支持丰富数据类型,支持string,list,set,sorted set,hash
- 支持事务,操作都是原子性,所谓的原子性就是对数据的更改要么全部执行,要么全部不执行
- 丰富的特性:可用于缓存,消息,按key设置过期时间,过期后将会自动删除
3. 缺点
- 缓存和数据库双写一致性问题
- 缓存雪崩问题
- 缓存击穿问题
- 缓存的并发竞争问题
4. 数据类型
- STRING
- LIST
- SET
- HASH
- ZSET
二、使用
1. 配置
在app.conf
内写入
redis.conn=127.0.0.1:6379
redis.dbNum=0
redis.password=""
2. 导包
"gopkg.in/redis.v5"
3. 连接redis
func createClient(redisHost string, password string, dataBase int) *redis.Client {
client := redis.NewClient(&redis.Options{
Addr: redisHost,
Password: password,
DB: dataBase,
})
// 通过 cient.Ping() 来检查是否成功连接到了 redis 服务器
_, err := client.Ping().Result()
if err != nil{
logs.Error("连接失败,",err)
}
return client
}
4. 封装基本使用
package utils
import (
"time"
"github.com/beego/beego/v2/core/logs"
"github.com/beego/beego/v2/server/web"
"gopkg.in/redis.v5"
)
var redisCache *redis.Client
// 创建 redis 客户端
func createClient(redisHost string, password string, dataBase int) *redis.Client {
client := redis.NewClient(&redis.Options{
Addr: redisHost,
Password: password,
DB: dataBase,
})
// 通过 cient.Ping() 来检查是否成功连接到了 redis 服务器
_, err := client.Ping().Result()
if err != nil{
logs.Error("连接失败,",err)
}
return client
}
func init() {
redisHost, _ := web.AppConfig.String("redis.conn")
dataBase, _ := web.AppConfig.Int("redis.dbNum")
password, _ := web.AppConfig.String("redis.password")
redisCache = createClient(redisHost, password, dataBase)
}
func SetStr(key, value string, time time.Duration) (err error) {
err = redisCache.Set(key, value, time).Err()
if err != nil {
logs.Error("set key:", key, ",value:", value, err)
}
return
}
func GetStr(key string) (value string) {
v, _ := redisCache.Get(key).Result()
return v
}
func DelKey(key string) (err error) {
err = redisCache.Del(key).Err()
return
}
5. 其他使用
请看大佬整理的API:gopkg-redis
版权声明:本文为博主原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。