在使用redis分布式锁时，为了保证加锁解锁具备原子性 加锁时使用带过期时间的set指令，而不是通过setnx+expire； 解锁时为了防止误删，给锁添加了唯一标识，判断唯一标识与解锁之间也要具备原子性，使用lua脚本解决 redis中使用lua脚本的方式;EVAL script numkeys key [key...] arg [arg...] script:脚本语言 numkeys :key的数量。必须要指定 key :key的值 arg :value的值。因为redis存储的key:value的方式 通过EV...
使用redis setnx命令结合lua脚本实现分布式锁功能 public Map<String, List<catalog2Vo>> getCatalogJsonFromDBWithRedisLock() {//抢占分布式锁String uuid = UUID.randomUUID().toString();//设置锁的唯一idBoolean lockBoolean = redisTemplate.opsForValue().setIfAbsent("redisLock",uuid,60,TimeUnit.SECONDS);//设置过期时间，这里的setIfAbsent相当于setnx命令if (lockBoolean){System.out.println("success to obtain red...
Nginx Lua Redis防止CC攻击实现原理：同一个外网IP、同一个网址(ngx.var.request_uri)、同一个客户端(http_user_agent)在某一段时间(CCseconds)内访问某个网址(ngx.var.request_uri)超过指定次数(CCcount)，则禁止这个外网IP+同一个客户端(md5(IP+ngx.var.http_user_agent)访问这个网址(ngx.var.request_uri)一段时间(blackseconds)。 该脚本使用lua编写(依赖nginx+lua)，将信息写到redis(依赖redis.lua)。 Nginx lua模块安装 重新...
前言 公司有一个发券的接口有并发安全问题，下面列出这个问题和解决这个问题的方式。 业务描述 这个接口的作用是给会员发多张券码。涉及到4张主体，分别是：用户，券，券码，用户领取记录。 下面是改造前的伪代码。 主要是因为查出券码那行存在并发安全问题，多个线程拿到同几个券码。以下都是基于如何让取券码变成原子的去展开。 public boolean sendCoupons(Long userId, Long couponId) {// 一堆校验// ...// 查出券码List<Coup...
github地址 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>redisIncrTest</groupId><artifactId>redisIncr</artifactId><version>0.0.1-SNAPSHOT</version><packaging>jar</packaging><name>redisIncrTest</name><...
分布式限流方案 概述 分布式锁 为什么要使用分布式锁 分布式锁应该具备的条件 分布式锁的实现方案 基于数据库实现 基于缓存redis实现 无论是分布式锁还是常规的锁，其目的都是在于：让多个线/进程在竞争某一个资源的时候，获取访问的权限。分布式锁无非是将线程竞争的层面拔高到进程竞争。 使用redis实现分布式锁的思想： 获取锁的时候，使用set命令加锁， Redis有个事务锁，就是如下的命令，这个命令的含义是将一个value设置到一个...
效果如下：做法如下：redis_sk.lua 脚本如下： local redis = require "resty.redis" --打开redis连接 local function open_redis() local red = redis:new() red:set_timeout(1000) -- 超时时间1 second local res = red:connect(192.168.42.101,6379) if not res then return nil end res = red:auth(123456) --密码校验 if not res then return nil end ...
import org.junit.Test; import org.junit.runner.RunWith; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.script.DefaultRedisScript; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import java.util.Col...
ngx_redis2https://github.com/openresty/redis2-nginx-module redis2-nginx-module是一个openresty（1.9.15.1）自带的模块。它能够把请求转发给upstream（redis2_pass）。注意它和lua-resty-redis不同，lua-resty-redis是一个lua语言版的redis API，使用socket（lua sock）和redis通信。而redis2-nginx-module是把请求转发给别的upstream。 实现Nginx中同步非阻塞的方式访问Redis ngx_drizzle 介绍：https://github.com/openrest...
目录1、场景2、编写脚本3、加载脚本4、执行脚本5、参考资料 1、场景 使用 redis 作为延迟队列时，在 zrangebyscore 与 zrem 之间会存在 context switch 的情况，造成其他的消费者空转 在其他场景下可能会发生更严重的情况 在掘金小册《Redis 深度历险：核心原理与应用实践》第四章讲的比较清楚，最后作者留了一个思考题 使用 Lua Scripting 来优化延时队列的逻辑。 于是，我就用 redis 试了一下 2、编写脚本 local value = redis.c...
Lua基本语法 表类型 函数 Redis执行脚本 KEYS与ARGV 沙盒与随机数 脚本相关命令 原子性和执行时间Lua是一种高效的轻量级脚本语言，能够方便地嵌入到其他语言中使用。在Redis中，借助Lua脚本可以自定义扩展命令。 Lua基本语法 数据类型空(nil)，没有赋值的变量或表的字段值都是nil 布尔(boolean) 数字(number)，整数或浮点数 字符串(string),字符串可以用单引号或双引号表示，可以包含转义字符如\n \r等 表(table),表类型是Lua语言中...
Openresty+Lua+Redis灰度发布灰度发布，简单来说，就是根据各种条件，让一部分用户使用旧版本，另一部分用户使用新版本。百度百科中解释：灰度发布是指在黑与白之间，能够平滑过渡的一种发布方式。AB test就是一种灰度发布方式，让一部分用户继续用A，一部分用户开始用B，如果用户对B没有什么反对意见，那么逐步扩大范围，把所有用户都迁移到B上面 来。灰度发布可以保证整体系统的稳定，在初始灰度的时候就可以发现、调整问题，以保...
package com.ppdai.merchant.service.configuration;import lombok.extern.slf4j.Slf4j;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.dao.DataAccessException;import org.springframework.data.redis.connection.RedisConnection;import org.springframework.data.redis.core.RedisCallback;import org.springframework.data.redis.core.RedisTemplate;import org.springframework...
加载到redisredis-cli script load "$(cat test.lua)" 得到sha1值 执行redis-cli evalsha "7a2054836e94e19da22c13f160bd987fbc9ef146" 0 点赞 收藏分享文章举报学亮编程手记发布了910 篇原创文章 · 获赞 390 · 访问量 79万+他的留言板 关注
lua限流脚本：local key_local = redis.call(setnx,KEYS[1],0)if tonumber(key_local) == 0 thenif tonumber(redis.call(get,KEYS[1]))>=tonumber(ARGV[2]) thenreturn falseelseredis.call(incr,KEYS[1])return trueend elseredis.call(incr,KEYS[1])redis.call(pexpire,KEYS[1],ARGV[1])return true endjava调用代码：import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.io.Class...