乌海做网站的公司,最流行的做网站语言,免费收录链接网,企业网页制作哪家公司好使用redis的setnx命令放入数据并用此数据当锁完成业务#xff08;但是如果用户操作途中出现异常导致超出指定时间会出现问题#xff09;
Service
public class StockService {Autowiredprivate StockDao stockDao; //mapper注入Autowiredprivate StringRedisTemplate redisT…使用redis的setnx命令放入数据并用此数据当锁完成业务但是如果用户操作途中出现异常导致超出指定时间会出现问题
Service
public class StockService {Autowiredprivate StockDao stockDao; //mapper注入Autowiredprivate StringRedisTemplate redisTemplate; //使用redis方法//public String decrement(Integer productid) {ValueOperationsString, String opsForValue redisTemplate.opsForValue();//1.获取共享锁资源通过进行redis放入数据的方式如果放入成功说明redis没有该数据Boolean flag opsForValue.setIfAbsent(product:: productid, 1111, 30, TimeUnit.SECONDS);//表示获取锁成功if(flag) {try {//根据id查询商品的库存int num stockDao.findById(productid);if (num 0) {//修改库存stockDao.update(productid);System.out.println(商品编号为: productid 的商品库存剩余: (num - 1) 个);return 商品编号为: productid 的商品库存剩余: (num - 1) 个;} else {System.out.println(商品编号为: productid 的商品库存不足。);return 商品编号为: productid 的商品库存不足。;}}finally {//释放锁资源删除放入的该数据然后准备开始下一次抢锁redisTemplate.delete(product::productid);}}else{//休眠100毫秒 在继续抢锁try {Thread.sleep(100);} catch (InterruptedException e) {throw new RuntimeException(e);}return decrement(productid);}}
}
看门狗改善版解决了超时的bug 引入依赖 dependencygroupIdorg.redisson/groupIdartifactIdredisson/artifactIdversion3.24.3/version
/dependency 编写配置类 Configuration
public class RedissonConfig {Beanpublic RedissonClient redisson(){Config config new Config();//连接redis集群config.useClusterServers()use rediss:// for SSL connection.addNodeAddress(redis://127.0.0.1:7181,,,);//连接单机config.useSingleServer().setAddress(redis://192.168.111.188:6379);RedissonClient redisson Redisson.create(config);return redisson;}
} 业务代码 Service
public class StockService {Autowiredprivate StockDao stockDao; //注入mapperAutowiredprivate RedissonClient redisson; //注入看门狗//public String decrement(Integer productid) {RLock lock redisson.getLock(product:: productid); //获取锁资源lock.lock(); //上锁try {//根据id查询商品的库存: 提前预热到redis缓存中int num stockDao.findById(productid);if (num 0) {//修改库存---incr---定时器[redis 数据库同步]stockDao.update(productid);System.out.println(商品编号为: productid 的商品库存剩余: (num - 1) 个);return 商品编号为: productid 的商品库存剩余: (num - 1) 个;} else {System.out.println(商品编号为: productid 的商品库存不足。);return 商品编号为: productid 的商品库存不足。;}}finally {lock.unlock(); //释放锁资源}}
}
