我应该怎么用我的Redis（三）？

博主： EpicMo
发布时间：2023 年 08 月 08 日
200 次浏览
暂无评论
3472字数
分类：学习小记

## 前言回顾

<div class="inner-content" >
<p class="inser-title">我应该怎么用我的Redis（二）？</p>
<div class="inster-summary text-muted">
前言回顾实际应用计数应用场景对于我们业务中的计数场景，我们可能会对某个用户有多个关联的数据，例如对于一个 B站 用...
</div>
</div>
</a>

</div>

</div>

## 使用场景

### 限流

#### 业务需求

我们需要对业务进行限流，比如我们要求1秒内只能让某个服务访问 N 次，如果超过 N 那么就紧张访问，或者让他们等待。

#### 业务代码

基本的思路是使用一个 Key + Incr 操作来完成：

例如：

- Key： comment_freq_limit_xxx (timestamp)

对这个Key调用Incr，超过限制N则禁止访问。

#### 数据结构

是我们（一）中所讲到的 String 结构

### 分布式锁

#### 业务需求

并发场景，要求一次只能由一个协程执行，执行完成后其他在等待的协程才能够执行。

#### 业务代码

可以使用 Redis 的 SetNX 实现，利用的特性有：

- Redis 单线程执行操作
- SetNX 只有没有设置过才能够执行成功

```go
package example

// setnx 分布式锁
import (
	"context"
	"fmt"
	"strconv"
	"time"

"gitee.com/wedone/redis_course/example/common"
)

const resourceKey = "syncKey"      // 分布式锁的key
const exp = 800 * time.Millisecond // 锁的过期时间，避免死锁

// EventLog 搜集日志的结构
type EventLog struct {
	eventTime time.Time
	log       string
}

// Ex02Params Ex02的自定义函数
type Ex02Params struct {
}

// Ex02 只是体验SetNX的特性，不是高可用的分布式锁实现
// 该实现存在的问题:
// (1) 业务超时解锁，导致并发问题。业务执行时间超过锁超时时间
// (2) redis主备切换临界点问题。主备切换后，A持有的锁还未同步到新的主节点时，B可在新主节点获取锁，导致并发问题。
// (3) redis集群脑裂，导致出现多个主节点
func Ex02(ctx context.Context) {
	eventLogger := &common.ConcurrentEventLogger{}
	// new一个并发执行器
	cInst := common.NewConcurrentRoutine(10, eventLogger)
	// 并发执行用户自定义函数work
	cInst.Run(ctx, Ex02Params{}, ex02Work)
	// 按日志时间正序打印日志
	eventLogger.PrintLogs()
}

func ex02Work(ctx context.Context, cInstParam common.CInstParams) {
	routine := cInstParam.Routine
	eventLogger := cInstParam.ConcurrentEventLogger
	defer ex02ReleaseLock(ctx, routine, eventLogger)
	for {
		// 1. 尝试获取锁
		// exp - 锁过期设置,避免异常死锁
		acquired, err := RedisClient.SetNX(ctx, resourceKey, routine, exp).Result() // 尝试获取锁
		if err != nil {
			eventLogger.Append(common.EventLog{
				EventTime: time.Now(), Log: fmt.Sprintf("[%s] error routine[%d], %v", time.Now().Format(time.RFC3339Nano), routine, err),
			})
			panic(err)
		}
		if acquired {
			// 2. 成功获取锁
			eventLogger.Append(common.EventLog{
				EventTime: time.Now(), Log: fmt.Sprintf("[%s] routine[%d] 获取锁", time.Now().Format(time.RFC3339Nano), routine),
			})
			// 3. sleep 模拟业务逻辑耗时
			time.Sleep(10 * time.Millisecond)
			eventLogger.Append(common.EventLog{
				EventTime: time.Now(), Log: fmt.Sprintf("[%s] routine[%d] 完成业务逻辑", time.Now().Format(time.RFC3339Nano), routine),
			})
			return
		} else {
			// 没有获得锁，等待后重试
			time.Sleep(100 * time.Millisecond)
		}
	}
}

func ex02ReleaseLock(ctx context.Context, routine int, eventLogger *common.ConcurrentEventLogger) {
	routineMark, _ := RedisClient.Get(ctx, resourceKey).Result()
	if strconv.FormatInt(int64(routine), 10) != routineMark {
		// 其它协程误删lock
		panic(fmt.Sprintf("del err lock[%s] can not del by [%d]", routineMark, routine))
	}
	set, err := RedisClient.Del(ctx, resourceKey).Result()
	if set == 1 {
		eventLogger.Append(common.EventLog{
			EventTime: time.Now(), Log: fmt.Sprintf("[%s] routine[%d] 释放锁", time.Now().Format(time.RFC3339Nano), routine),
		})
	} else {
		eventLogger.Append(common.EventLog{
			EventTime: time.Now(), Log: fmt.Sprintf("[%s] routine[%d] no lock to del", time.Now().Format(time.RFC3339Nano), routine),
		})
	}
	if err != nil {
		fmt.Errorf("[%s] error routine=%d, %v", time.Now().Format(time.RFC3339Nano), routine, err)
		panic(err)
	}
}
```

但是上面使用的 SetNX 也不能够做成真正的高可用的锁，有以下实现上的问题：

- 业务超时解锁，导致并发问题。业务执行时间超过锁超时时间
- redis主备切换临界点问题。主备切换后，A持有的锁还未同步到新的主节点时，B可在新主节点获取锁，导致并发问题。
- redis集群脑裂，导致出现多个主节点

最后修改：2023 年 08 月 08 日

如果你觉得文章帮到你了，请以沫喝杯奶茶吧~

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

评论 *

私密评论

名称 *

🎲

邮箱 *

地址

clash节点
友链申请网站名称：clash节点网站链接：https://cl...
小趴菜
现在都很难破解了，换了Charles抓包...
xiwen_youmu
大佬加个友链ヾ(≧∇≦*)ゝURL: https://www....

我应该怎么用我的Redis（三）？

EpicMo • 2023 年 08 月 08 日

## 前言回顾

## 使用场景

### 限流

#### 业务需求

我们需要对业务进行限流，比如我们要求1秒内只能让某个服务访问 N 次，如果超过 N 那么就紧张访问，或者让他们等待。

#### 业务代码

基本的思路是使用一个 Key + Incr 操作来完成：

例如：

- Key： comment_freq_limit_xxx (timestamp)

对这个Key调用Incr，超过限制N则禁止访问。

#### 数据结构

是我们（一）中所讲到的 String 结构

### 分布式锁

#### 业务需求

并发场景，要求一次只能由一个协程执行，执行完成后其他在等待的协程才能够执行。

#### 业务代码

可以使用 Redis 的 SetNX 实现，利用的特性有：

- Redis 单线程执行操作
- SetNX 只有没有设置过才能够执行成功

```go
package example

// setnx 分布式锁
import (
	"context"
	"fmt"
	"strconv"
	"time"

"gitee.com/wedone/redis_course/example/common"
)

const resourceKey = "syncKey"      // 分布式锁的key
const exp = 800 * time.Millisecond // 锁的过期时间，避免死锁

// EventLog 搜集日志的结构
type EventLog struct {
	eventTime time.Time
	log       string
}

// Ex02Params Ex02的自定义函数
type Ex02Params struct {
}

但是上面使用的 SetNX 也不能够做成真正的高可用的锁，有以下实现上的问题：

我应该怎么用我的Redis（三）？

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

Ubuntu安装网易云音乐

Fiddler EveryWhere 365 Crack 办法

记一次Bat编写

Ubuntu下Dash to dock在锁屏后会出现重叠的解决方案

Nginx 配置 Stable Diffusion 反向代理

记一次比较有意思的俱乐部招新

K6 使用录 | 一次压力测试的小记

Fluentd 以 Sidecar 模式作为 pod 的日志收集单元

我应该怎么用我的Redis（三）？

Fiddler EveryWhere 365 Crack 办法

我应该怎么用我的Redis（三）？

发表评论 取消回复 使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

我应该怎么用我的Redis（三）？

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款