Redisson学习

简介

Redisson 是一个在 Redis 的基础上实现的 Java 驻留内存数据网格（In-Memory Data Grid）。它提供了许多分布式 Java 对象和服务，包括分布式锁、分布式集合、分布式执行服务、分布式调度任务等。

使用

依赖

相关依赖，注意版本

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/org.redisson/redisson -->
<dependency><groupId>org.redisson</groupId><artifactId>redisson</artifactId><version>3.21.3</version>
</dependency>
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope>
</dependency>
<dependencyManagement><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.5.6}</version><type>pom</type><scope>import</scope></dependency></dependencies>
</dependencyManagement>

配置

spring.redis.host=192.168.0.120
spring.redis.port=6379
spring.redis.password=123456
spring.redis.timeout=3000
spring.redis.lettuce.pool.max-wait=-1
spring.redis.lettuce.pool.max-active=300
spring.redis.lettuce.pool.max-idle=100
spring.redis.lettuce.pool.min-idle=20

RedisConfig

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
public class RedisConfig {@Beanpublic RedisTemplate<String, Object> redisTemplate(LettuceConnectionFactory redisConnectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());redisTemplate.setConnectionFactory(redisConnectionFactory);return redisTemplate;}}

RBloomFilterConfiguration

import org.redisson.Redisson;
import org.redisson.api.RBloomFilter;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;/*** 布隆过滤器配置*/
@Configuration
public class RBloomFilterConfiguration {@Beanpublic RedissonClient redissonClient(){Config config = new Config();config.useSingleServer().setAddress("redis://192.168.0.120:6379");config.useSingleServer().setPassword("123456");RedissonClient redisson = Redisson.create(config);return redisson;}/*** 防⽌检查⽤户是否重复时查询数据库的布隆过滤器*/@Beanpublic RBloomFilter<String> userRegisterCachePenetrationBloomFilter(RedissonClient redissonClient) {RBloomFilter<String> cachePenetrationBloomFilter = redissonClient.getBloomFilter("userRegisterCachePenetrationBloomFilter");cachePenetrationBloomFilter.tryInit(100000000L, 0.001);return cachePenetrationBloomFilter;}
}

业务逻辑

public interface IRedissonService {//测试布隆过滤器void testBloomFilter();//分布式锁void testLock();//写锁void testWriteLock();//读锁void testReadLock();
}

@Service
@Transactional
public class RedissonServiceImpl implements IRedissonService {@Autowiredprivate RedisTemplate<String, Object> redisTemplate;@Autowiredprivate RedissonClient redissonClient;@Autowiredprivate RBloomFilter<String> userRegisterCachePenetrationBloomFilter;public void testBloomFilter() {// 新增数据到布隆过滤器中userRegisterCachePenetrationBloomFilter.add("IRedissonService");// 判断元素是否存在布隆过滤器boolean hasUsername = userRegisterCachePenetrationBloomFilter.contains("IRedissonService");System.out.println("testBloomFilter:" + hasUsername);}//TODO 注意 key 内容中不要包含一些关键词 比如 java,lock等等，否则会报错@Overridepublic void testLock() {RLock testLock = redissonClient.getLock("testL");testLock.lock();//加锁try {//业务......redisTemplate.opsForValue().set("testLK", "testLValue", 5, TimeUnit.SECONDS);System.out.println("加锁成功");} catch (Exception ex) {ex.printStackTrace();} finally {Object testLockValue = redisTemplate.opsForValue().get("testLK");System.out.println("解锁成功" + testLockValue);testLock.unlock();//解锁}}@Overridepublic void testWriteLock() {RReadWriteLock testWriteLock = redissonClient.getReadWriteLock("testWL");try {testWriteLock.writeLock().lock();//业务......redisTemplate.opsForValue().set("testWLK", "testWLV", 10, TimeUnit.SECONDS);Thread.sleep(3000);System.out.println("testWriteLock 加锁成功");} catch (Exception ex) {ex.printStackTrace();} finally {Object testWriteLockValue = redisTemplate.opsForValue().get("testWLK");System.out.println("testWriteLock 解锁成功" + testWriteLockValue);testWriteLock.writeLock().unlock();}}@Overridepublic void testReadLock() {RReadWriteLock testReadLock = redissonClient.getReadWriteLock("testRL");try {testReadLock.readLock().lock(2000, TimeUnit.MILLISECONDS);//业务......Object testWriteLockValue = redisTemplate.opsForValue().get("testWLK");System.out.println("testReadLock 加锁成功" + testWriteLockValue);} catch (Exception ex) {ex.printStackTrace();} finally {System.out.println("testReadLock 解锁成功");testReadLock.readLock().unlock();}}
}

单元测试

import com.xysd.commodity.application.impl.MyAspectServiceImpl;
import com.xysd.commodity.domain.PaymentProcess;
import com.xysd.common.domain.Holiday;
import com.xysd.test.application.IDataCacheService;
import com.xysd.test.application.IDomeService;
import com.xysd.test.application.IRedissonService;
import com.xysd.test.infrastructure.DomeRepositoryHibernate;
import com.xysd.utils.calendar.CalendarUtils;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.mockito.Mockito;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.mock.mockito.MockBean;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowCallbackHandler;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.UUID;@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = CDAApplication.class)
public class CDAApplicationTest {@Autowiredprivate IRedissonService redissonService;@Testpublic void testBloomFilter() {redissonService.testBloomFilter();}@Testpublic void testLock() throws Exception {redissonService.testLock();redissonService.testWriteLock();Thread.sleep(5000);redissonService.testReadLock();}}

测试效果图

测试结果

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/734171.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【兔子机器人】修改GO电机id（软件方法、硬件方法）

【兔子机器人】修改GO电机id（软件方法、硬件方法）

一、硬件方法 利用上位机直接修改GO电机的id号&#xff1a; 打开调试助手&#xff0c;点击“调试”&#xff0c;查询电机&#xff0c;修改id号&#xff0c;即可。 但先将四个GO电机连接线拔掉&#xff0c;不然会将连接的电机一并修改。 利用24V电源给GO电机供电。 二、软件方…
阅读更多...
回溯算法12-全排列II(Java/排列数去重操作)

回溯算法12-全排列II(Java/排列数去重操作)

12.全排列II 题目描述 给定一个可包含重复数字的序列 nums &#xff0c;按任意顺序 返回所有不重复的全排列。 示例 1&#xff1a; 输入&#xff1a;nums [1,1,2] 输出&#xff1a; [[1,1,2],[1,2,1],[2,1,1]]示例 2&#xff1a; 输入&#xff1a;nums [1,2,3] 输出&…
阅读更多...
Spring Boot整合zxing实现二维码登录

Spring Boot整合zxing实现二维码登录

zxing是google的一个二维码生成库&#xff0c;使用时需配置依赖&#xff1a; implementation("com.google.zxing:core:3.4.1") implementation("com.google.zxing:javase:3.4.1") zxing的基本使用 我们可以通过MultiFormatWriter().encode()方法获取一个…
阅读更多...
AI预测福彩3D第3弹【2024年3月6日预测】

AI预测福彩3D第3弹【2024年3月6日预测】

书接上回&#xff0c;经过连续两期使用人工神经网络对福彩3D进行预测&#xff0c;经过不断的调参优化&#xff0c;并及时总结规律&#xff0c;感觉还是有一定的信心提高七码的命中概率。 今天&#xff0c;咱们继续来验证&#xff0c;直接上今天的统计结果&#xff0c;首先&…
阅读更多...
手写分布式配置中心（五）整合springboot（不自动刷新的）

手写分布式配置中心（五）整合springboot（不自动刷新的）

springboot中使用配置方式有四种&#xff0c;分别是environment、BeanDefinition、Value、ConfigurationProperties。具体的原理可以看我之前的一篇文章https://blog.csdn.net/cjc000/article/details/132800290。代码在https://gitee.com/summer-cat001/config-center 原理 …
阅读更多...
移动端uni-app小程序搜索高亮前端处理，同时可设置相关样式，兼顾性能

移动端uni-app小程序搜索高亮前端处理，同时可设置相关样式，兼顾性能

在uni-app中我们会遇到搜索高亮显示的需求 如下图&#xff1a; 起初用的是富文本实现 使用replaceAll方法取代搜索字段为一个 标签并设置相应的样式&#xff0c;但是小程序的并没有把 标签渲染出来&#xff0c;所以放弃了&#xff0c;下面原代码&#xff1a; /* 搜索字体变色…
阅读更多...
C++进阶：详细讲解继承

C++进阶：详细讲解继承

现在也是结束了初阶部分的内容&#xff0c;今天开始就进入进阶部分了。一刻也没有为初阶的结束而哀悼&#xff0c;立刻赶来“战场”的是进阶部分里的继承 文章目录 1.继承的概念和定义1.1继承的概念1.2继承的定义1.2.1继承的格式1.2.2再讲访问限定符(详讲protected)1.2.3**继承…
阅读更多...
NFT交易市场开发（一）

NFT交易市场开发（一）

实现的基本功能 &#xff08;一&#xff09; 发行一个符合ERC20标准的测试Token&#xff0c;要求如下&#xff1a; 总量&#xff1a;&#xff1a;1亿精度&#xff1a;18名称&#xff1a;Fake USDT in CBI简称&#xff1a;cUSDT &#xff08;二&#xff09; 发行一个符合ERC72…
阅读更多...
数据结构——算法的空间复杂度

数据结构——算法的空间复杂度

【本节内容】 1.空间复杂度 2.常见空间复杂度 1.空间复杂度 空间复杂度也是一个数学表达式&#xff0c;是对一个算法在运行过程中临时占用额外存储空间大小的量度。 空间复杂度不是程序占用了多少bytes的空间&#xff0c;因为这个也没太大意义&#xff0c;所以空间复杂度算…
阅读更多...
random标准模块

random标准模块

一、概述 在 Python 中&#xff0c;random 是一个内置模块&#xff0c;用于生成随机数。它提供了各种用于生成随机数的函数&#xff0c;包括伪随机数生成器、随机序列操作等。 1、需要导包 不会自动导入&#xff0c;需要显示的将random模块导入 import random2、源码分析&…
阅读更多...
课时59：流程控制_if条件控制_语法解读

课时59：流程控制_if条件控制_语法解读

2.2.1 语法解读 学习目标 这一节&#xff0c;我们从 基础知识、简单实践、小结 三个方面来学习。 基础知识 简介 条件结构能够根据某个特定的条件&#xff0c;结合内置的测试表达式功能&#xff0c;结合测试的结果状态值对于条件进行判断&#xff0c;然后选择执行合适的任务…
阅读更多...
【Greenhills】MULTIIDE集成第三方的编辑器进行源文件编辑工作

【Greenhills】MULTIIDE集成第三方的编辑器进行源文件编辑工作

【更多软件使用问题请点击亿道电子官方网站查询】 1、 文档目标 在使用GHS进行工作的时候&#xff0c;可以集成第三方的编辑器进行源文件编辑工作 2、 问题场景 用于解决在GHS中进行项目开发时&#xff0c;对于GHS的编辑器使用不习惯&#xff0c;想要切换到其他第三方的编辑…
阅读更多...
为什么在镀膜时要测薄膜折射率？

为什么在镀膜时要测薄膜折射率？

在芯片制造中&#xff0c;镀膜工序&#xff08;PVD,CVD&#xff09;是必不可少的关键环节&#xff0c;薄膜的质量直接影响了芯片的性能。对这些薄膜的精细控制又离不开对其折射率的深入理解和精确测量。今天将对芯片制造中薄膜折射率的概念、测量方法&#xff0c;以及它在整个制…
阅读更多...
Arcgis小技巧【19】——更改字段顺序

Arcgis小技巧【19】——更改字段顺序

一、问题分析 一般情况下&#xff0c;一个合格且严谨的要素或表数据&#xff0c;它的字段顺序都是固定的。 比如三调数据&#xff0c;正常的字段数据如下&#xff08;截取部分字段&#xff09;&#xff1a; 数据经过处理&#xff0c;如增删字段&#xff0c;可能会出现字段顺序…
阅读更多...
SAM模型

SAM模型

SAM与过去分割对比 根据以下Demo,我们可以发现&#xff0c;通过在图像中指定要分割的内容提示&#xff0c;SAM可以实现各种分割任务&#xff0c;且无需额外的训练、做到零样本泛化&#xff0c;即SAM学会了辨别物体、具备图像理解力、对不熟悉的图像和物体能进行零样本概括&…
阅读更多...
论文阅读《FENET: FOCUSING ENHANCED NETWORK FOR LANE DETECTION》

论文阅读《FENET: FOCUSING ENHANCED NETWORK FOR LANE DETECTION》

ABSTRACT 受人类驾驶专注力的启发&#xff0c;这项研究开创性地利用聚焦采样&#xff08;Focusing Sampling&#xff09;、部分视野评估&#xff08;Partial Field of View Evaluation&#xff09;、增强型 FPN 架构和定向 IoU 损失&#xff08;Directional IoU Loss&#xff…
阅读更多...
STM32单片机示例：ETH_LAN8742_DHCP_NonOS_Poll_H743

STM32单片机示例：ETH_LAN8742_DHCP_NonOS_Poll_H743

文章目录 目的基础说明关键配置关键代码示例链接总结 目的 以太网是比较常用到的功能&#xff0c;STM32系列单片机使用CubeMX配置使用以太网功能比非常方便。不过对于H7系列来说需要使能 DCache 才能启用LwIP&#xff0c;启用Cache后又会带来一些需要特别注意的事情。这篇文章…
阅读更多...
AI智能应用百科立即落地实操课

AI智能应用百科立即落地实操课

该课程旨在教授学员如何将AI智能应用于实际场景。通过深入的案例研究和实操练习&#xff0c;学员将学会应用机器学习、自然语言处理等技术&#xff0c;快速解决现实问题。课程强调实际操作&#xff0c;帮助学员快速运用AI技术解决工作中的挑战。 课程大小&#xff1a;3.3G 课…
阅读更多...
10 | MySQL为什么有时候会选错索引？

10 | MySQL为什么有时候会选错索引？

前面我们介绍过索引&#xff0c;你已经知道了在 MySQL 中一张表其实是可以支持多个索引的。但是&#xff0c;你写 SQL 语句的时候&#xff0c;并没有主动指定使用哪个索引。也就是说&#xff0c;使用哪个索引是由 MySQL 来确定的。 不知道你有没有碰到过这种情况&#xff0c;一…
阅读更多...
【Selenium】selenium介绍及工作原理

【Selenium】selenium介绍及工作原理

一、Selenium介绍 用于Web应用程序测试的工具&#xff0c;Selenium是开源并且免费的&#xff0c;覆盖IE、Chrome、FireFox、Safari等主流浏览器&#xff0c;通过在不同浏览器中运行自动化测试。支持Java、Python、Net、Perl等编程语言进行自动化测试脚本编写。 官网地址&…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023