使用redis的increment()方法实现计数器功能案例

一直知道redis可以用来实现计数器功能,但是之前没有实际使用过,昨天碰到一个需求:用户扫码当天达到20次即提示:当日扫码次数达到上限!

当时就想到使用redis的递增方法increment()来实现计数器功能,一定要注意redisTemplate和stringRedisTemplate的使用

首先设置key:

该key我使用了用户id和当天日期作为key的一部分,date:xxxx-xx-xx格式,这样一来该用户在第二天扫码的时候又是一个新key,因为日期不同了

设置key的过期时间:

实现计数器功能:

通过使用上面的方法,redis的计数器功能就可以实现了。

在使用过程过遇到的问题:

在使用的过程中,老是会抛错:ERR value is not an integer or out of range

后来发现当时我使用的方法底层用的redisTemplate和stringRedisTemplate串了,当时setKey的时候用的方法底层是

stringRedisTemplate,后面我想get(key)的时候方法底层的模板使用的是redisTemplate,后面统一了一下模板的使用,然后计数

器功能正常运行不再抛错。

看过很多文章说是序列化器的锅,increment方法必须是stringRedisTemplate模板才能使用,但是我在实际使用的时候也确实是

用了redisTemplate,这个具体原因我还在看,此次使用中最主要的问题是setKey的时候使用的模板和取key的时候使用的模板不

一致导致的。写个笔记记录一下,一个坑不踩第二遍。大家如果遇到一样的问题可以一起讨论学习一下。

补充知识:认识redis:redis计数器与数量控制

这篇文章是我个人对redis的一些理解,可以帮助大家系统的认识redis。本文的目标读者是使用过redis,但对redis了解不深的朋友。文章内容以redis为主,也会少量提到memcached。文章从redis的设计目的、工作模式、应用场景等方面阐述,最后会讲解一些具体的应用场景,还会夹带一些代码作为“干货”。

鉴于本人水平有限,文中如有不准确的内容,敬请斧正。

redis是什么

redis是一种内存型的数据存储器,使用场景

数据库

缓存

消息代理(message broker)

同memcached对比

memcached是分布式的内存对象缓存系统,设计意图为通过缓解数据库压力来加快web应用的响应速度。

上面的描述分别被放在了redis和memcached的官网首页最显眼的位置,这也回答了redis和memcached的本质区别。

redis的工作模式

redis的工作模式为单进程,这意味着redis只能利用到一个cpu内核。 redis对请求的处理是串行的,对于同时涌进来的多个请求,redis首先把请求存入队列,按请求到达的先后顺序串行处理。

了解单进程和串行这两个特点,有助于我们使用redis时“扬长避短”。

之前有同事提到过,为何redis不适合存储大块的数据?从redis的工作模式我们可以窥知一二:大块的数据意味着需要较长的io时间,包括内存io和网络的io,cpu资源在io过程中是一直被占用的,这会阻塞其它请求,从而影响redis的整体性能。

数据类型

大家对redis的数据类型已经比较熟悉了,主要有以下5种。

string

list

hash

set

sorted set

各种数据类型的常用操作

string

set,get,setnx,setex,psetex

拼接

增加、减少(整数型字符串)

位操作

list

入列,出列(这两个命令都有阻塞模式)

按排位获取部分元素

hash

设置某个索引

获取某个索引

增加/减少某个索引的值(整数型字符串)

获取所有索引的值

set

集合是一个数学概念,啰嗦提一下:集合中的元素都是唯一的

加入元素

删除元素

检查元素是否在集合

获取集合中的元素数量

取差集/并集/交集

元素转移(从集合a移至集合b)

zset

有序集合,每个元素都有一个分值,用于对元素进行排序

取交集/并集

获取一个元素的rank

获取分值在某个范围内的元素数量

获取分值在某个范围内的元素

按rank范围获取元素

redis事务

redis事务和我们熟悉的mysql事务有所区别,它们的相同在于都是对一个或一组命令的打包执行,不同的地方在于redis事务不可回滚。

redis的事务具有原子性,一个事务的执行有两种结果

完全执行

完全不执行

一些不可抗力因素除外,如服务挂掉,服务器断电。redis事务是一个独立的请求,执行过程中会阻塞其它请求。

实现redis事务有以下两种方式

multi-exec

lua脚本

multi-exec

127.0.0.1:6380[1]> set counter1 1
OK
127.0.0.1:6380[1]> set counter2 2
OK
127.0.0.1:6380[1]> set counter3 3
OK
127.0.0.1:6380[1]>
127.0.0.1:6380[1]>
127.0.0.1:6380[1]> multi
OK
127.0.0.1:6380[1]> incr counter1
QUEUED
127.0.0.1:6380[1]> sadd counter2 1
QUEUED
127.0.0.1:6380[1]> incr counter3
QUEUED
127.0.0.1:6380[1]> exec
1) (integer) 2
2) (error) WRONGTYPE Operation against a key holding the wrong kind of value
3) (integer) 4

从上面的事务执行输出可以看到,我们的sadd执行出错了,原因是操作的数据类型不正确,但redis没有中止整个事务,而是继续往下执行。redis这么做是有道理的,见参考文献1。

multi-exec和watch的组合可以实现类似于mysql事务的功能,如果被watch的key在事务执行前被修改了,redis会放弃执行事务。

lua脚本

和multi-exec相比,lua脚本的优势在于灵活性,也可以减少一定的网络时间消耗(为什么?)。

鉴于redis的工作模式,不建议用lua脚本实现耗时较长的事务。

下面模拟了lua脚本的执行阻塞其它请求的场景,大家可以亲自试一下。

client 1

eval "local i=0; while(i<1000000) do redis.call('keys', '*'); i=i+1; end" 0

client 2

incr counter

redis的实际应用

类型:string

命令:setnx name alice |set name alice NX

返回true则锁定成功,否则锁定失败

了解了redis的工作模式,就知道为什么用redis实现锁是如此容易了。用memcache也可以实现锁,但代码层面要复杂一些,参见memcached.cas。

事件队列

类型:zset

命令:zadd,zrangebyscore,zrem

适合存储一些需要顺序处理的事件,将事件的score值设为时间戳或自增id即可。为什么用list不可以?

计数器

类型:string

命令:incr

抽奖限额

类型:string

命令:incrby

某活动的现金红包每天最多只能发送10000元。下面是这段逻辑的伪代码,如果能够举一反三,这段代码将大有用武之地。大家可以用并发测试工具测试这段代码,如果发现了bug,或者能有更好的实现方式,请不要告诉我 -_-

$key = 'max_amount';
$amountLimit = 10000;

if (!$currAmount = Redis::get($key)) {
  $currAmount = 9990;     // 从持久化数据库获取当前已发放金额
  // 初始化
  Redis::setnx($key, $currAmount);
}

if ($currAmount >= $amountLimit) {
  // 超出限额退出
}

// 抽奖金额
$rewardAmount = 10;
if ($rewardAmount > $amountLimit - $currAmount) {
  $rewardAmount = $amountLimit - $currAmount;
}
if (Redis::incrby($key, $rewardAmount) > $amountLimit) {
  // 超出限额退出
} else {
  // 成功抽奖
}

初始化为何用setnx,用set可以吗?

最后为何使用incrby,不用可以吗?

总结

文章内容不多,所谓的干货更少,这和作者的水平有关,也和文章的定位有关。细心的朋友可能发现了,文中有一些内容是带有问号的,有兴趣的朋友可以加以思考。希望能给大家一个参考,也希望大家多多支持我们

(0)

相关推荐

  • 使用Redis incr解决并发问题的操作

    项目背景: 1.新增问题件工单,工单中有工单编码字段,工单编码字段的规则为 "WT"+yyyyMMdd+0000001. 2.每天的工单生成量是30W,所以会存在并发问题 解决思路: 1.首先乐观的认为redis不会宕机,对应的缓存不会被清除(除非人为操作,人为操作会有独立的补救办法) 2.将工单编码存到缓存中(redis),其值只存"WT"+yyyyMMdd后面的数字部分: 对应的key为:key标识+yyyyMMdd,即每天一个key 3.每次生成工单编码时,先

  • Redis密码设置与访问限制实现方法

    现在用redis缓存热数据越来越常见了,甚至一些配置,开关等等的东西也写到redis里.原因就是redis简单高效.redis里的数据也越来越重要了,例如一些业务的中间数据会暂时存放在redis里,所以限制redis的访问还是很有必要. 本文通过几个手段说一下生产环境中redis的访问权限控制. 1.绑定网卡bind redis的配置文件redis.conf中对于网络安全部分有这样一段话 ################################## NETWORK ###########

  • Redis中的String类型及使用Redis解决订单秒杀超卖问题

    本系列将和大家分享Redis分布式缓存,本章主要简单介绍下Redis中的String类型,以及如何使用Redis解决订单秒杀超卖问题. Redis中5种数据结构之String类型:key-value的缓存,支持过期,value不超过512M. Redis是单线程的,比如SetAll & AppendToValue & GetValues & GetAndSetValue & IncrementValue & IncrementValueBy等等,这些看上去像是组合命

  • 解决spring中redistemplate不能用通配符keys查出相应Key的问题

    有个业务中需要删除某个前缀的所有Redis缓存,于是用RedisTemplate的keys方法先查出所有合适的key,再遍历删除. 但是在keys(patten+"*")时每次取出的都为空. 解决问题: spring中redis配置中,引入StringRedisTemplate而不是RedisTemplate,StringRedisTemplate本身继承自RedisTemplate, 即 <bean id="redisTemplate" class=&quo

  • 使用redis的increment()方法实现计数器功能案例

    一直知道redis可以用来实现计数器功能,但是之前没有实际使用过,昨天碰到一个需求:用户扫码当天达到20次即提示:当日扫码次数达到上限! 当时就想到使用redis的递增方法increment()来实现计数器功能,一定要注意redisTemplate和stringRedisTemplate的使用 首先设置key: 该key我使用了用户id和当天日期作为key的一部分,date:xxxx-xx-xx格式,这样一来该用户在第二天扫码的时候又是一个新key,因为日期不同了 设置key的过期时间: 实现计

  • 将音频文件转二进制分包存储到Redis的实现方法(奇淫技巧操作)

    功能需求: 一.获取本地音频文件,进行解析成二进制数据音频流 二.将音频流转化成byte[]数组,按指定大小字节数进行分包 三.将音频流分成若干个包,以List列表形式缓存到redis数据库中 四.从redis数据库中获取数据,转换成音频流输出到浏览器播放.实现音频下载功能 程序如下: 1.在SpringBootpom.xml文件中添加Redis依赖 <!--Redis依赖--> <dependency> <groupId>org.springframework.boo

  • 为Java项目添加Redis缓存的方法

    Redis的安装 Redis一般有Linux和Windows两种安装方式,Windows的最高版本为3.2,Linux的最高版本为5.0,大家可以根据自己的需要添加 Linux 首先在linux下安装docker,在docker环境下安装redis5.0的镜像 docker pull redis:5.0 然后使用Docker命令启动Redis容器 docker run -p 6379:6379 --name redis \ -v /mydata/redis/data:/data \ -d red

  • 大白话讲解调用Redis的increment失败原因及推荐使用详解

    大家在项目中基本都会接触到redis,在spring-data-redis-2.*.*.RELEASE.jar中提供了两个Helper class,可以让我们更方便的操作redis中存储的数据.这两个Helper class分别是RedisTemplate和StringRedisTemplate,其中StringRedisTemplate是RedisTemplate在存储String类型的时候的一个扩展子类.所以大家在使用redis的时候: 1.如果操作的是String类型,优先考虑用Strin

  • 利用Redis实现防止接口重复提交功能

    目录 前言 1.自定义注解 2.自定义拦截器 3.Redis工具类 4.其他想说的 前言 在划水摸鱼之际,突然听到有的用户反映增加了多条一样的数据,这用户立马就不干了,让我们要马上修复,不然就要投诉我们. 这下鱼也摸不了了,只能去看看发生了什么事情.据用户反映,当时网络有点卡,所以多点了几次提交,最后发现出现了十几条一样的数据. 只能说现在的人都太心急了,连这几秒的时间都等不了,惯的.心里吐槽归吐槽,这问题还是要解决的,不然老板可不惯我. 其实想想就知道为啥会这样,在网络延迟的时候,用户多次点击

  • 菜鸟蔡之Ajax复习第一篇(后台asp.net)(传统的JavaScript方法实现Ajax功能)

    其实最简单的可以理解为:JavaScript + XMLHttpRequest + CSS +服务器端的集合,其本质上是一种浏览器端的技术.好了, 简单的描述了一下,现在直接上代码吧! (1).功能描述: 新建两个html页面分别为1.html和2.html,在不刷新的情况下点击1.html页面上的"获取数据"按钮后,将2.html页中的内容显示在1.html页面的<div>标记中. (2).实现代码: 1.html实现代码: 复制代码 代码如下: <head>

  • redis查看连接数及php模拟并发创建redis连接的方法

    max_redis.php <?php set_time_limit (0); for($i=1;$i<=1050;$i++){ exec("nohup php /var/www/html/big/link_redis.php > /dev/null &"); } link_redis.php <?php set_time_limit (0); $redis = new redis(); $redis->pconnect('localhost',

  • Linux下php安装Redis扩展的方法

    本文实例讲述了Linux下php安装Redis扩展的方法.分享给大家供大家参考,具体如下: 注意:目录的权限   chomd 777 -R 1.安装redis 下载:https://github.com/nicolasff/phpredis/archive/2.2.4.tar.gz 上传phpredis-2.2.4.tar.gz到/usr/local/src目录 cd /usr/local/src #进入软件包存放目录 tar zxvf phpredis-2.2.4.tar.gz #解压 cd

  • SpringBoot项目中使用redis缓存的方法步骤

    本文介绍了SpringBoot项目中使用redis缓存的方法步骤,分享给大家,具体如下: Spring Data Redis为我们封装了Redis客户端的各种操作,简化使用. - 当Redis当做数据库或者消息队列来操作时,我们一般使用RedisTemplate来操作 - 当Redis作为缓存使用时,我们可以将它作为Spring Cache的实现,直接通过注解使用 1.概述 在应用中有效的利用redis缓存可以很好的提升系统性能,特别是对于查询操作,可以有效的减少数据库压力. 具体的代码参照该

  • Django中redis的使用方法(包括安装、配置、启动)

    一.安装redis: 1.下载: wget http://download.redis.io/releases/redis-3.2.8.tar.gz 2.解压 tar -zxvf redis-3.2.8.tar.gz 3.复制,放到/usr/local目录下 sudo mv ./redis-3.2.8 /usr/local/redis 4.进入到redis目录下 cd /usr/local/redis/ 5.生成 sudo make 6.测试,时间会比较长 sudo make test 7.安装

随机推荐