Redis之并发写入
时间:2022-05-06
本文章向大家介绍Redis之并发写入，主要内容包括其使用实例、应用技巧、基本知识点总结和需要注意事项，具有一定的参考价值，需要的朋友可以参考一下。
那么开始总结下方案吧：
- 1. SETNX key value //key存在就不做任何操作，返回0；不存在操作成功返回1
复制代码
这种方式通过对需要操作的key加锁来保证并发操作的串行化。这里我们以Golang代码为例来举例说明该操作。先看多个协程写同一个key的情况。代码如下：
package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
"runtime"
"sync"
"time"
)
var w sync.WaitGroup
func newRdsPool(server, auth string) *redis.Pool {
return &redis.Pool{
MaxIdle: 100,
MaxActive: 30,
IdleTimeout: 60 * time.Second,
Dial: func() (redis.Conn, error) {
c, err := redis.Dial("tcp", server)
if err != nil {
return nil, err
}
if auth == "" {
return c, err
}
if _, err := c.Do("AUTH", auth); err != nil {
c.Close()
return nil, err
}
return c, err
},
TestOnBorrow: func(c redis.Conn, t time.Time) error {
_, err := c.Do("PING")
return err
},
}
}
func g1(r redis.Conn) {
for i := 0; i < 2; i++ {
if _, err := redis.String(r.Do("set", "hello", "1")); err != nil {
fmt.Println(err)
}
time.Sleep(10 * time.Millisecond)
}
w.Done()
}
func g2(r redis.Conn) {
for i := 0; i < 2; i++ {
if _, err := redis.String(r.Do("set", "hello", "2")); err != nil {
fmt.Println(err)
}
time.Sleep(10 * time.Millisecond)
}
w.Done()
}
func main() {
w.Add(2)
runtime.GOMAXPROCS(runtime.NumCPU())
var rc1 redis.Conn = newRdsPool(`127.0.0.1:6379`, ``).Get()
var rc2 redis.Conn = newRdsPool(`127.0.0.1:6379`, ``).Get()
defer rc1.Close()
defer rc2.Close()
go g1(rc1)
go g2(rc2)
w.Wait()
}执行上面的代码之后，hello的值在1和2之间徘徊。希望出现的是如果协程1在操作时候，协程2就放弃操作，也即让操作串行化。这样就需要有一个锁来保证不能同时让两个协程进去临界区。setnx = set if not exists 不存在返回1，存在返回0。通过这个机制可以判断当前的lock是否已经被设置了。lock必须给一个过期时间，因为很有可能goroutine1在do work的时候出现panic，这样就导致goroutine2一直在尝试获取锁。
package main
import (
"fmt"
"github.com/garyburd/redigo/redis"
"runtime"
"sync"
"time"
)
var w sync.WaitGroup
func newRdsPool(server, auth string) *redis.Pool {
return &redis.Pool{
MaxIdle: 100,
MaxActive: 30,
IdleTimeout: 60 * time.Second,
Dial: func() (redis.Conn, error) {
c, err := redis.Dial("tcp", server)
if err != nil {
return nil, err
}
if auth == "" {
return c, err
}
if _, err := c.Do("AUTH", auth); err != nil {
c.Close()
return nil, err
}
return c, err
},
TestOnBorrow: func(c redis.Conn, t time.Time) error {
_, err := c.Do("PING")
return err
},
}
}
func g1(r redis.Conn) {
var lock int64
var lock_timeout int64 = 2
var lock_time int64
var now int64
for lock != 1 {
now = time.Now().Unix()
lock_time = now + lock_timeout
lock, err1 := redis.Int64(r.Do("setnx", "foo", lock_time))
lockValue1, err2 := redis.Int64(r.Do("get", "foo"))
if lock == 1 && err1 == nil {
break
} else {
if now > lockValue1 && err2 == nil {
lockValue2, err3 := redis.Int64(r.Do("getset", "foo", lock_time))
if err3 == nil && now > lockValue2 {
break
} else {
fmt.Println(`g1 not get lock`)
time.Sleep(1000 * time.Millisecond)
}
} else {
fmt.Println(`g1 not get lock`)
time.Sleep(1000 * time.Millisecond)
}
}
}
for i := 0; i < 5; i++ {
if _, err := redis.String(r.Do("set", "hello", "1")); err != nil {
fmt.Println(err)
}
fmt.Println(`g1 now work... `)
time.Sleep(1 * time.Second)
}
if time.Now().Unix() < lock_time {
if _, err4 := redis.Int64(r.Do("del", "foo")); err4 != nil {
fmt.Println(err4)
}
}
w.Done()
}
func g2(r redis.Conn) {
var lock int64
var lock_timeout int64 = 2
var lock_time int64
var now int64
for lock != 1 {
now = time.Now().Unix()
lock_time = now + lock_timeout
lock, err1 := redis.Int64(r.Do("setnx", "foo", lock_time))
lockValue1, err2 := redis.Int64(r.Do("get", "foo"))
if lock == 1 && err1 == nil {
break
} else {
if now > lockValue1 && err2 == nil {
lockValue2, err3 := redis.Int64(r.Do("getset", "foo", lock_time))
if err3 == nil && now > lockValue2 {
break
} else {
fmt.Println(`g2 not get lock`)
time.Sleep(1000 * time.Millisecond)
}
} else {
fmt.Println(`g2 not get lock`)
time.Sleep(1000 * time.Millisecond)
}
}
}
for i := 0; i < 5; i++ {
if _, err := redis.String(r.Do("set", "hello", "2")); err != nil {
fmt.Println(err)
}
fmt.Println(`g2 now work... `)
time.Sleep(1 * time.Second)
}
if time.Now().Unix() < lock_time {
if _, err4 := redis.Int64(r.Do("del", "foo")); err4 != nil {
fmt.Println(err4)
}
}
w.Done()
}
func main() {
w.Add(2)
runtime.GOMAXPROCS(runtime.NumCPU())
var rc1 redis.Conn = newRdsPool(`127.0.0.1:6379`, ``).Get()
var rc2 redis.Conn = newRdsPool(`127.0.0.1:6379`, ``).Get()
defer rc1.Close()
defer rc2.Close()
go g1(rc1)
go g2(rc2)
w.Wait()
}上面的代码给出了两个goroutine通过锁达到串行化操作同一个key的效果。 2. MULTI、DISCARD、 EXEC、WATCH // redis事务 3. 将对key的操作的值都放到一个list里面
- 分布式监控系统Zabbix3.2对数据库的连接数预警
- 分布式监控系统Zabbix3.2监控数据库的连接数
- 分布式监控系统Zabbix3.2给异常添加邮件报警
- 分布式监控系统Zabbix3.2跳坑指南
- 一图看懂java内存模型
- 零代码如何打造自己的实时监控预警系统
- 一步一步在Windows中使用MyCat负载均衡 上篇
- 你真的会玩SQL吗？之逻辑查询处理阶段
- javascript中如何正确将日期(Date)字符串转换为日期(Date)对象?
- 全面迎接.Net3.0时代的到来（WCF/WF/WPF/LINQ）
- SQL Server 2005 正则表达式使模式匹配和数据提取变得更容易
- [基础]datagridview绑定数据源的几种常见方式
- c#:winform鼠标拖动窗口大小时，设定窗口最小尺寸
- 在非SqlServer数据库上实现MemberShip和Role功能(自定义MemberShipProvider和RoleProvider)
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 虚拟机中CentOS7设置固定IP地址的方法
- CentOs下手动升级node版本的办法
- php设计模式之抽象工厂模式分析【星际争霸游戏案例】
- PHP使用PDO、mysqli扩展实现与数据库交互操作详解
- Linux中的who命令实例介绍
- php获取本年、本月、本周时间戳和日期格式的实例代码
- Smarty缓存机制实例详解【三种缓存方式】
- 详解在Ubuntu上的Apache配置SSL(https证书)的正确姿势
- php设计模式之建造器模式分析【星际争霸游戏案例】
- Yii框架使用PHPExcel导出Excel文件的方法分析【改进版】
- PHP容器类的两种实现方式示例
- Linux下Mysql定时任务备份数据的实现办法
- PHP抽象类和接口用法实例详解
- php+lottery.js实现九宫格抽奖功能
- PHP实现一个按钮点击上传多个图片操作示例