java操作redis并发_使用Redis incr解决并发问题的操作
项目背景:
1、新增问题件工单,工单中有工单编码字段,工单编码字段的规则为 “WT”+yyyyMMdd+0000001。
2、每天的工单生成量是30W,所以会存在并发问题
解决思路:
1、首先乐观的认为redis不会宕机,对应的缓存不会被清除(除非人为操作,人为操作会有独立的补救办法)
2、将工单编码存到缓存中(redis),其值只存“WT”+yyyyMMdd后面的数字部分;
对应的key为:key标识+yyyyMMdd,即每天一个key
3、每次生成工单编码时,先调用redis的incr方法,使其在原来编码的基础上加1,并返回结果
4、判断返回的结果,如果返回的是1,说明当前key之前不存在,为生成的新的一天的key,
需要设置此key的生命周期为24小时
5、每个key只会存活24小时
6、如果redis宕机,或者key被删除,调用指定的接口,接口会去数据库查询今天最大的工单编码,
解析后,将其存在redis中,后面的工单编码再在此基础上自增
7、请自行配置redisClient客户端并实例化
代码:
1、编码获取核心方法
/**
* 通过自定义的方法查询问题件缓存
* @param redisKey
* @param codePre
* @return
*/
public static String getCodeBySelfRedis(String redisKey,String codePre){
String nowDateStr = DateTimeUtil.getDateTimeStr(new Date(),DateTimeUtil.DATE_PATTERN_YYYYMMDD);
Long value = 1L;
RedisClient uceClient = null;
Jedis jedis=null;
try {
uceClient = SpringContextUtil.getBean("uceClient");
jedis = uceClient.getResource();
value = jedis.incr(redisKey+nowDateStr);
if(value != null){
//如果值为1说明是第一次设置,那么设置key的存活时间为24小时
if (value == 1){
jedis.expire(redisKey+nowDateStr,(24*60*60+1000));
}
}else{
//如指为空,重置缓存
value = resetCodeRedis(redisKey);
}
}catch (Exception e){
logger.error("获取问题件编码的自定义缓存异常:",e);
value = resetCodeRedis(redisKey);
}finally {
if (uceClient != null){
uceClient.returnResource(jedis);
}
}
String problemCode = String.valueOf(value);
for(int i = 0;i < 7;i++){
if (problemCode.length() < 7){
problemCode = "0"+problemCode;
}else{
break;
}
}
return codePre + nowDateStr + problemCode;
}
2、宕机时,调用的核心接口方法
/**
* 重置编码缓存
* @param redisKey
* @return
*/
public static Long resetCodeRedis(String redisKey){
String oldDateStr = null;
String nowDateStr = DateTimeUtil.getDateTimeStr(new Date(),DateTimeUtil.DATE_PATTERN_YYYYMMDD);
//编码的最大字符串
String databaseMaxCode = null;
//问题件
if(StringUtil.isNotEmpty(redisKey) && redisKey.equals(WO_PROBLEM_CODE_KEY)){
CsWoProblemService csWoProblemService = SpringContextUtil.getBean("csWoProblemService");
//获取数据库中的问题件的最大编码
databaseMaxCode = csWoProblemService.getMaxCode(WO_PROBLEM_CODE_PRE);
//获取编码的日期部分
if(StringUtil.isNotEmpty(databaseMaxCode)){
oldDateStr = databaseMaxCode.substring(2,10);
databaseMaxCode = databaseMaxCode.substring(10);
}
}else if(StringUtil.isNotEmpty(redisKey) && redisKey.equals(WO_CUST_SER_CODE_KEY)){
CsWoCustSerService csWoCustSerService = SpringContextUtil.getBean("csWoCustSerService");
//获取数据库中的客户服务类工单的最大编码
databaseMaxCode = csWoCustSerService.getMaxCode("");
//获取编码的日期部分
if(StringUtil.isNotEmpty(databaseMaxCode)){
oldDateStr = databaseMaxCode.substring(0,8);
databaseMaxCode = databaseMaxCode.substring(8);
}
}
Long value = getRedisValue(oldDateStr,nowDateStr,databaseMaxCode);
RedisClient uceClient = null;
Jedis jedisCluster = null;
try {
uceClient = SpringContextUtil.getBean("uceClient");
jedisCluster = uceClient.getResource();
boolean keyExist = jedisCluster.exists(redisKey + nowDateStr);
// NX是不存在时才set, XX是存在时才set, EX是秒,PX是毫秒
if (keyExist) {
jedisCluster.del(redisKey + nowDateStr);
}
//设置缓存值,并设置为24小时后自动失效
jedisCluster.set(redisKey + nowDateStr, String.valueOf((value + 1)), "NX","EX", (24*60*60+1000));
}catch (Exception e){
logger.error((redisKey + "编码重置异常:"),e);
}finally {
if(uceClient != null){
uceClient.returnResource(jedisCluster);
}
}
return value + 1;
}
/**
* 解析redis的值
* @param oldDateStr
* @param nowDateStr
* @param databaseMaxCode
* @return
*/
public static Long getRedisValue(String oldDateStr,String nowDateStr,String databaseMaxCode){
Long value = 0L;
String firstCodeZero = "0";
//如果日期相同,解析编码数据存到缓存中
if(StringUtil.isNotEmpty(oldDateStr) && StringUtil.isNotEmpty(nowDateStr) && oldDateStr.equals(nowDateStr) && StringUtil.isNotEmpty(databaseMaxCode)){
for(int i = 0;i < 7;i++){
String firstCode = databaseMaxCode.substring(0,1);
if (StringUtil.isNotEmpty(firstCode) && firstCodeZero.equals(firstCode)){
databaseMaxCode = databaseMaxCode.substring(1);
}else{
break;
}
}
if (StringUtil.isNotEmpty(databaseMaxCode)){
value = Long.parseLong(databaseMaxCode);
}
}
return value;
}
注意:
jedis使用后一定要close,否则jedis连接被占用的会越来越多,可用的连接数会越来越少,最终会导致redis宕机,最终项目宕机。
本项目是在finally中调用的自己封装的returnResource()方法,此方法中会进行关闭操作
补充知识:redis在高并发下导致锁失效问题
解决办法:
可以给线程加唯一标识 关闭线程时判断标识是否相同
问题2:线程超时问题如何解决 同一时间会有俩个或俩个以上线程操作同一方法
使用分布式锁redisson
以上这篇使用Redis incr解决并发问题的操作就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持脚本之家。
java操作redis并发_使用Redis incr解决并发问题的操作相关推荐
- python redis缓存_第二百九十五节,python操作redis缓存-字符串类型
python操作redis缓存-字符串类型 首先要安装redis-py模块 python连接redis方式,有两种连接方式,一种是直接连接,一张是通过连接池连接 注意:以后我们都用的连接池方式连接,直 ...
- redis数据类型_认识Redis与Redis的数据类型
本文作为Redis的入门教程,旨在让大家对Redis有一个概念性和整体性的认识,并且可以快速上手,为深入Redis打下基础. 文章概要: 1. Redis的介绍 2. Redis与其他数据库的对比 3 ...
- php redis 投票_高性能Redis服务架构分析与搭建
基于内存的Redis应该是目前各种web开发业务中最为常用的key-value数据库了,我们经常在业务中用其存储用户登陆态(Session存储),加速一些热数据的查询(相比较mysql而言,速度有数量 ...
- python安装redis模块_安装redis及python redis模块
第一部分:安装redis mkdir /usr/local/redis cd /usr/local/src wget http://download.redis.io/releases/redis-2 ...
- 为什么我的mysql比redis快_为什么redis是单线程的以及为什么这么快?
官网的说法 我们先来认真看一下官网的说法.翻译过来大意如下: CPU并不是您使用Redis的瓶颈,因为通常Redis要么受内存限制,要么受网络限制.例如,使用在一般Linux系统上运行的流水线Redi ...
- mysql每秒支持多少并发_如何设计一个高并发系统?
面试题 如何设计一个高并发系统? 面试官心理分析 说实话,如果面试官问你这个题目,那么你必须要使出全身吃奶劲了.为啥?因为你没看到现在很多公司招聘的 JD 里都是说啥,有高并发就经验者优先. 如果你确 ...
- scanf_s 发送访问冲突_程序员如何解决并发冲突的难题?
作者 | 羽生结弦 责编 | 胡雪蕊 出品 | CSDN(ID: CSDNnews) 在大多数的应用中都会出现客户端同时发送多个请求对同一条数据就行修改,这个时候就会出现并发冲突.我们一般的做法会有如 ...
- java redis计数器_使用Redis原子计数器incr实现限速器功能
点击上方☝ Java编程技术乐园,轻松关注~ 及时获取有趣有料的 技术文章 做一个积极的人编码.改bug.提升自己 我有一个乐园,面向编程,春暖花开! 一.前言 在一些对高并发请求有限制的系统或者功能 ...
- java实现分布式redis锁_使用redis实现分布式锁
# 简介: 当高并发访问某个接口的时候,如果这个接口访问的数据库中的资源,并且你的数据库事务级别是可重复读(Repeatable read)的话,确实是没有线程问题的,因为数据库锁的级别就够了:但是如 ...
最新文章
- redis 分布式锁的实现方式
- SAP UI5 getHeaderFooterOptions
- 我为什么对TypeScript由黑转粉?
- oracle中sql行数的计算,Oracle技术网—如何利用DBMS_SQL包和游标计算当前用户下所有表的行数...
- TokenInsight:反映区块链行业整体表现的TI指数较昨日同期下跌1.54%
- Sudo环境变量继承
- 纪念一下挖到CSDN官网漏洞
- Ubuntu22.04(Linux Mint 21)安装使用绿联USB无线网卡CM448(rtl8821CU)的方法
- php计算ip掩码,php进行ip地址掩码运算处理的方法
- word如何去掉背景色
- 福到了 分数 15作者 陈越单位 浙江大学
- php7.4 ffi,PHP7.4中FFI的介绍(代码示例)
- html 链接excel表格,excel表格超链接设置
- 为什么只看重结果_太过于看重结果会失掉过程
- 南非银行“内鬼”偷走主密钥,后将更换1200万张客户卡,损失惨重
- 机器学习—正则化方法—L1正则化、L2正则化
- js按下回车键调用方法
- CToolBar的使用总结(转1)
- 全局配置遮罩层(VUE Element Ui)
- 网易企业邮箱优势功能
热门文章
- python简单代码需要写多久_python基本语法?初学Python要多久才能入门?
- 爬虫3 requests基础之 乱码编码问题
- #if、#if defined 的使用
- Lintcode 729. 阶乘除法的最后一位数
- 20145308刘昊阳 20145302张薇《信息安全系统设计基础》实验五:网络通信 实验报告...
- __stdcall函数调用约定
- leetcode 1189 python
- PAT乙级(1011 A+B 和 C)
- android+残留软件包名,关于使用pm hide伪卸载系统软件的一些包名
- 免费干货课程!发放官方证书!参与更有礼品相送!戳进绝不后悔~