首页 / REDIS / 用Redis实现分布式锁以及redission使用

用Redis实现分布式锁以及redission使用

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了用Redis实现分布式锁以及redission使用，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6973字，纯文字阅读大概需要10分钟。

内容图文

前言：分布式环境有很多问题，比如你前一个请求访问的是服务器A，第二个请求访问到了服务器B，就会发生并发重复插入问题，这个时候需要依赖单点来实现分布锁，而redis就是。

先导入maven依赖 redission

<dependency>
????<groupId>org.redisson</groupId>
????<artifactId>redisson</artifactId>
????<version>2.2.13</version>
</dependency>

创建redission工具类

package?redis;
import?org.redisson.Config;
import?org.redisson.Redisson;
import?org.redisson.RedissonClient;
import?org.redisson.core.RAtomicLong;
import?org.redisson.core.RBucket;
import?org.redisson.core.RCountDownLatch;
import?org.redisson.core.RDeque;
import?org.redisson.core.RList;
import?org.redisson.core.RLock;
import?org.redisson.core.RMap;
import?org.redisson.core.RQueue;
import?org.redisson.core.RSet;
import?org.redisson.core.RSortedSet;
import?org.redisson.core.RTopic;
import?org.slf4j.Logger;
import?org.slf4j.LoggerFactory;

/***
?*?Redis?client的辅助工具类
?*?用于连接Redis服务器?创建不同的Redis?Server对应的客户端对象
?*?@author?wangnian
?*?博客地址：http://my.oschina.net/wangnian
?*/
public?class?RedisUtils?{

???private?static???Logger?logger=?LoggerFactory.getLogger(RedisUtils.class);
???
???private?static?RedisUtils?redisUtils;
???
???private?RedisUtils(){}
???
???/**
????*?提供单例模式
????*?@return
????*/
???public?static?RedisUtils?getInstance(){
??????if(redisUtils==null)?
?????????synchronized?(RedisUtils.class)?{
????????????if(redisUtils==null)?redisUtils=new?RedisUtils();
?????????}
??????return?redisUtils;
???}
???
???
???/**
????*?使用config创建Redisson
????*?Redisson是用于连接Redis?Server的基础类
????*?@param?config
????*?@return
????*/
???public?RedissonClient?getRedisson(Config?config){
??????RedissonClient?redisson=Redisson.create(config);
??????logger.info("成功连接Redis?Server");
??????return?redisson;
???}?
???
???/**
????*?使用ip地址和端口创建Redisson
????*?@param?ip
????*?@param?port
????*?@return
????*/
???public?RedissonClient?getRedisson(String?ip,String?port){
??????Config?config=new?Config();
??????config.useSingleServer().setAddress(ip+":"+port);
??????RedissonClient?redisson=Redisson.create(config);
??????logger.info("成功连接Redis?Server"+"\t"+"连接"+ip+":"+port+"服务器");
??????return?redisson;
???}
???
???/**
????*?关闭Redisson客户端连接
????*?@param?redisson
????*/
???public?void?closeRedisson(RedissonClient?redisson){
??????redisson.shutdown();
??????logger.info("成功关闭Redis?Client连接");
???}
???
???/**
????*?获取字符串对象
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<T>?RBucket<T>?getRBucket(RedissonClient?redisson,String?objectName){
??????RBucket<T>?bucket=redisson.getBucket(objectName);
??????return?bucket;
???}
???
???/**
????*?获取Map对象
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<K,V>?RMap<K,?V>?getRMap(RedissonClient?redisson,String?objectName){
??????RMap<K,?V>?map=redisson.getMap(objectName);
??????return?map;
???}
???
???/**
????*?获取有序集合
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<V>?RSortedSet<V>?getRSortedSet(RedissonClient?redisson,String?objectName){
??????RSortedSet<V>?sortedSet=redisson.getSortedSet(objectName);
??????return?sortedSet;
???}
???
???/**
????*?获取集合
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<V>?RSet<V>?getRSet(RedissonClient?redisson,String?objectName){
??????RSet<V>?rSet=redisson.getSet(objectName);
??????return?rSet;
???}
???
???/**
????*?获取列表
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<V>?RList<V>?getRList(RedissonClient?redisson,String?objectName){
??????RList<V>?rList=redisson.getList(objectName);
??????return?rList;
???}
???
???/**
????*?获取队列
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<V>?RQueue<V>?getRQueue(RedissonClient?redisson,String?objectName){
??????RQueue<V>?rQueue=redisson.getQueue(objectName);
??????return?rQueue;
???}
???
???/**
????*?获取双端队列
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<V>?RDeque<V>?getRDeque(RedissonClient?redisson,String?objectName){
??????RDeque<V>?rDeque=redisson.getDeque(objectName);
??????return?rDeque;
???}
???
???/**
????*?此方法不可用在Redisson?1.2?中?
????*?在1.2.2版本中?可用
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???/**
???public?<V>?RBlockingQueue<V>?getRBlockingQueue(RedissonClient?redisson,String?objectName){
??????RBlockingQueue?rb=redisson.getBlockingQueue(objectName);
??????return?rb;
???}*/
???
???/**
????*?获取锁
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?RLock?getRLock(RedissonClient?redisson,String?objectName){
??????RLock?rLock=redisson.getLock(objectName);
??????return?rLock;
???}
???
???/**
????*?获取原子数
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?RAtomicLong?getRAtomicLong(RedissonClient?redisson,String?objectName){
??????RAtomicLong?rAtomicLong=redisson.getAtomicLong(objectName);
??????return?rAtomicLong;
???}
???
???/**
????*?获取记数锁
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?RCountDownLatch?getRCountDownLatch(RedissonClient?redisson,String?objectName){
??????RCountDownLatch?rCountDownLatch=redisson.getCountDownLatch(objectName);
??????return?rCountDownLatch;
???}
???
???/**
????*?获取消息的Topic
????*?@param?redisson
????*?@param?objectName
????*?@return
????*/
???public?<M>?RTopic<M>?getRTopic(RedissonClient?redisson,String?objectName){
???????RTopic<M>?rTopic=redisson.getTopic(objectName);
???????return?rTopic;
???}
???
???
}

例子

package?redis;

import?org.junit.Test;
import?org.redisson.Config;
import?org.redisson.RedissonClient;
import?org.redisson.SingleServerConfig;
import?org.redisson.core.RBucket;
import?org.redisson.core.RLock;

import?java.util.concurrent.TimeUnit;

/**
?*?Created?by?wangnian?on?2016/5/2.
?*博客地址：http://my.oschina.net/wangnian
?*/
public?class?RedissonTest?{

????@Test
????public?void?test()?throws?InterruptedException?{
????????//redisson配置
????????Config?config?=?new?Config();
????????SingleServerConfig?singleSerververConfig?=?config.useSingleServer();
????????singleSerververConfig.setAddress("127.0.0.1:6379");
????????singleSerververConfig.setPassword("redis");
????????//redisson客户端
????????RedissonClient?redissonClient?=?RedisUtils.getInstance().getRedisson(config);
????????RBucket<Object>?rBucket?=?RedisUtils.getInstance().getRBucket(redissonClient,?"key");
????????//rBucket.set("wangnian");
????????System.out.println(rBucket.get());

????????while?(true)?{
????????????RLock?lock?=?redissonClient.getLock("lock");
????????????lock.tryLock(0,?1,?TimeUnit.SECONDS);//第一个参数代表等待时间，第二是代表超过时间释放锁，第三个代表设置的时间制
????????????try?{
????????????????System.out.println("执行");
????????????}?finally?{
????????????????lock.unlock();
????????????}
????????}
????}

}

如果生产上，我建议用注解aop的方式写个 lock的注解比如 @lock("name")

内容总结

以上是互联网集市为您收集整理的用Redis实现分布式锁以及redission使用全部内容，希望文章能够帮你解决用Redis实现分布式锁以及redission使用所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/874234.html

来源：【匿名】

【上一篇】Redis 简介【下一篇】redis可以做什么？

更多 ►

【用Redis实现分布式锁以及redission使用】教程文章相关的互联网学习教程文章

分布式系统--封装Redis分布式锁解决跨进程并发秒杀引起的超卖问题【代码】【图】

一、单进程多线程的锁--线程锁锁住线程的锁叫线程锁，像C#中的lock，Monitor，让线程排队，同一时刻只能有一个线程进来，让线程同步排队。二、多进程的锁--分布式锁锁住进程的锁就叫分布式锁，是锁住进程的一种机制，让进程排队。三、电商秒杀场景1、单体架构并发量不够，秒杀服务只能并发1000，而客户端同时发送3000个请求。2、集群架构这时候就需要多两个角色，一个角色是网关，一个角色是秒杀集群，网关把用户请求转发到3个秒...

redis分布式锁-lua脚本【代码】

package com.tuling.jedis;import redis.clients.jedis.Jedis; import redis.clients.jedis.JedisPool; import redis.clients.jedis.JedisPoolConfig;import java.io.IOException; import java.util.Arrays;/*** 访问redis单机** @author*/publicclass JedisSingleTest {publicstaticvoid main(String[] args) throws IOException {JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();jedisPoolConfig.setMaxTotal(20);jedi...

为什么我们做分布式使用 Redis ？（转）【图】

绝大部分写业务的程序员，在实际开发中使用 Redis 的时候，只会 Set Value 和 Get Value 两个操作，对 Redis 整体缺乏一个认知。这里对 Redis 常见问题做一个总结，解决大家的知识盲点。1、为什么使用 Redis　　在项目中使用 Redis，主要考虑两个角度：性能和并发。如果只是为了分布式锁这些其他功能，还有其他中间件 Zookpeer 等代替，并非一定要使用 Redis。性能：　　如下图所示，我们在碰到需要执行耗时特别久，且结果不频繁变...

借助共享缓存redis实现分布式互斥锁【代码】

新开发的系统需要控制每个时刻回收缓存的GC线程有且只有一个在运行，如果有多个线程同时运行，会造成系统崩溃。如果只有一个JVM进程那么很好办，简单的借助synchronized关键字就行了。可是我的系统要部署在多台服务器，每台服务器上部署多个实例上。而synchronized仅仅在单进程里有用。考虑借助共享数据源redis实现功能。 redis提供一个方法，SETNX key value。将 key 的值设为 value ，当且仅当 key 不存在。若给定的 key ...

Scrapy-redis分布式+Scrapy-redis实战【代码】【图】

【学习目标】Scrapy-redis分布式的运行流程Scheduler与Scrapy自带的Scheduler有什么区别Duplication Filter作用源码自带三种spider的使用6. Scrapy-redis分布式组件Scrapy 和 scrapy-redis的区别Scrapy 是一个通用的爬虫框架，但是不支持分布式，Scrapy-redis是为了更方便地实现Scrapy分布式爬取，而提供了一些以redis为基础的组件(仅有组件)。pip install scrapy-redisScrapy-redis提供了下面四种组件（components）：(四种组件意...

redisLock redis分布式锁【代码】

redis setnx cmmandjava object condition queue 条件队列retrycount 带有重试次数限制object wait time 带有超时时间的waitdelete lock 删除远程锁acquire lock 申请lockrelease lock 释放lockdemo 演示锁的粒度问题，锁分解、锁分段github https://github.com/Plen-wang/redis-lockredis setnx 命令特性当指定key不存在时才设置。也就是说，如果返回1说明你的命令被执行成功了，redis服务器中的key是你之前设置的值。如果返回0，...

spring data redis分布式锁【代码】

问题项目采用spring-boot-starter-data-redis，RedisTemplate中没有同时设置NX和EX的方法，如果使用setIfAbsent()方法也就是NX，再设置过期时间expire()也就是EX,如果在设置EX时失败则会造成死锁。在jedis中提供了同时设置NX和EX的方法，这里通过RedisTemplate的execute()方法获取Jedis。存在问题解决方案可以可以参考Redisson哨兵模式下有问题，Master挂了可能没有复制到Slave导致锁丢失如果是多个系统redis配置的库不同会有问题因...

如何实现redis分布式缓存

摘要: 第一：Redis 是什么？ Redis是基于内存、可持久化的日志型、Key-Value数据库高性能存储系统，并提供多种语言的API. 第二：出现背景数据结构(Data Structure)需求越来越多, 但memcache中没有, 影响开发效率性能需求, 随着读操作的量的上升需要解决，经历的过程有: 数据库读写分离(M/S)–>数据库使用多个Slave–>增加Cache (memcache)–>转到Redis 解决写的问题：水平拆分，对表的拆分，将有的用户放在这个表，有的用户放...

SpringBoot学习示例—整合Redis之StringRedisTemplate及实现redis乐观锁，分布式锁、事务【代码】【图】

1. 前言2. 整合Redis快速入门3. StringRedisTemplate基本操作及测试4. 实现Redis事务5. Redis乐观锁(分布式锁）1. 前言这篇文章你能学到，SpringBoot整合Redis的最简单方式，不需要任何复杂的配置。还有完整的乐观锁，分布式锁，事务等实现样例代码供你选择。2. 整合Redis快速入门SpringBoot项目引入redis依赖 <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-d...

scrapy-redis 分布式爬虫爬取房天下网站所有国内城市的新房和二手房信息【代码】

scrapy-redis 分布式爬虫爬取房天下网站所有国内城市的新房和二手房信息先完成单机版的爬虫，然后将单机版爬虫转为分布式爬虫爬取思路1. 进入 https://www.fang.com/SoufunFamily.htm 页面，解析所有的省份和城市，获取到城市首页链接 2. 通过分析，每个城市的新房都是在首页链接上添加newhouse和house/s/字符串，二手房都死在首页链接上添加esf字段以上海为例：首页：https://sh.fang.com/ 新房：https://sh.newhouse....

一站式学习Redis 从入门到高可用分布式实践（慕课）第五章 Redis持久化的取舍和选择【图】

Redis持久化的取舍和选择持久化的作用 RDB AOF RDB和AOF的决择原文：https://www.cnblogs.com/jiang910/p/10025879.html

使用redis分布式锁解决并发线程资源共享问题【代码】【图】

众所周知, 在多线程中，因为共享全局变量,会导致资源修改结果不一致，所以需要加锁来解决这个问题，保证同一时间只有一个线程对资源进行操作但是在分布式架构中，我们的服务可能会有n个实例，但线程锁只对同一个实例有效，就需要用到分布式锁----redis setnx 原理：　　修改某个资源时, 在redis中设置一个key，value根据实际情况自行决定如何表示　　我们既然要通过检查key是否存在（存在表示有线程在修改资源，资源上锁，其他线程...

Redis 分布式锁【代码】

1 #include <stdio.h>2 #include <stdlib.h>3 #include <string.h>4// -------------------- 5 #include <unistd.h>6 #include <pthread.h>7// -------------------- 8 #include <hiredis.h>9// -------------------- 10 #include "thread_helper.h" 11 12#define ATOMIC_UNLOCK 013#define ATOMIC_LOCK 114 15intlock = 0;16int num = 0;17int total_num = 50;18 ThreadSchema* ts;19 20bool acquire_lock(int sn, redisContext...

redis实现分布式锁--工具类【代码】

1.引入依赖<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId><version>2.0.5.RELEASE</version></dependency><dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.10.7</version></dependency>2.配置文件：application.propertiesspring.redis.host=127.0.0.1 spring.redis.port=6379 spring.redis.password=1234563.配置类：Redis...

分布式缓存技术之Redis_01数据结构分析【图】

目录官网1. 分布式缓存技术的应用2. Redis的安装指引官网?redis.io ?redisDoc1. 分布式缓存技术的应用2. Redis的安装指引官网下载安装包 redis-5.0.4.tar.gz解压 tar -zxvf redis-5.0.4.tar.gz编译 make可能遇到的问题编译测试 make test可能遇到的问题安装 make install原文：https://www.cnblogs.com/Qkxh320/p/distributed_redis_1.html

REDIS - 技术教程分类

Redis 教程 Redis 简介 Redis 安装 Redis 配置 Redis 数据类型 Redis 命令 Redis 键(key) Redis 字符串(String) Redis 哈希(Hash) Redis 列表(List) Redis 集合(Set) Redis 有序集合(sorted set) Redis HyperLogLog Redis 发布订阅 Redis 事务 Redis 脚本 Redis 连接 Redis 服务器 Redis GEO Redis Stream Redis 数据备份与恢复 Redis 安全 Redis 性能测试 Redis 客户端连接 Redis 分区 Redis 全部

REDIS - 最热教程

redis中批量删除key的方法 redis设置密码，取消密码 node.js利用redis数据库缓存数据 PHP swoole和redis异步任务实现方法分析 Laravel使用Redis共享Session步骤详解 mac下卸载干净redis 如何通过命令行修改redis的配置使用Port Forwarding连接k8s集群的pod（...Redis入门（七）——Redis发布订阅 Redis学习笔记2-常用数据类型

首页 / REDIS / 用Redis实现分布式锁以及redission使用

用Redis实现分布式锁以及redission使用

内容导读

内容图文

内容总结

内容备注

内容手机端

【用Redis实现分布式锁以及redission使用】教程文章相关的互联网学习教程文章

分布式系统--封装Redis分布式锁解决跨进程并发秒杀引起的超卖问题【代码】【图】

redis分布式锁-lua脚本【代码】

为什么我们做分布式使用 Redis ？（转）【图】

借助共享缓存redis实现分布式互斥锁【代码】

Scrapy-redis分布式+Scrapy-redis实战【代码】【图】

redisLock redis分布式锁【代码】

spring data redis分布式锁【代码】

如何实现redis分布式缓存

SpringBoot学习示例—整合Redis之StringRedisTemplate及实现redis乐观锁，分布式锁、事务【代码】【图】

scrapy-redis 分布式爬虫爬取房天下网站所有国内城市的新房和二手房信息【代码】

一站式学习Redis 从入门到高可用分布式实践（慕课）第五章 Redis持久化的取舍和选择【图】

使用redis分布式锁解决并发线程资源共享问题【代码】【图】

Redis 分布式锁【代码】

redis实现分布式锁--工具类【代码】

分布式缓存技术之Redis_01数据结构分析【图】

分布式 - 相关标签

REDIS - 技术教程分类

REDIS - 最新教程

REDIS - 最热教程