锐客网

  1. 首页 > 睿知 > it技术 > >

Spring Boot + Redis 实现各种操作 #yyds干货盘点#

IT知识spring操作

春衣少年当酒歌，起舞四顾以笑和。这篇文章主要讲述Spring Boot + Redis 实现各种操作 #yyds干货盘点#相关的知识，希望能为你提供帮助。
一、Jedis,Redisson,Lettuce 三者的区别共同点：都提供了基于 Redis 操作的 java API，只是封装程度，具体实现稍有不同。
不同点：

  • 1.1、Jedis
是 Redis 的 Java 实现的客户端。支持基本的数据类型如：String、Hash、List、Set、Sorted Set。
特点：使用阻塞的 I/O，方法调用同步，程序流需要等到 socket 处理完 I/O 才能执行，不支持异步操作。Jedis 客户端实例不是线程安全的，需要通过连接池来使用 Jedis。
  • 1.1、Redisson
优点点：分布式锁，分布式集合，可通过 Redis 支持延迟队列。
  • 1.3、 Lettuce
用于线程安全同步，异步和响应使用，支持集群，Sentinel，管道和编码器。
基于 Netty 框架的事件驱动的通信层，其方法调用是异步的  ，Lettuce 的 API 是线程安全的，所以可以操作单个 Lettuce 连接来完成各种操作。
二、Jedis三、RedisTemplate3.1、使用配置
maven 配置引入，（要加上版本号，我这里是因为 Parent 已声明）
< dependency>
< groupId> org.springframework.boot< /groupId>
< artifactId> spring-boot-starter-data-redis< /artifactId>
< /dependency>


application-dev.yml
spring:
redis:
host: 192.168.1.140
port: 6379
password:
database: 15 # 指定redis的分库（共16个0到15）


3.2、使用示例
@Resource
private StringRedisTemplate stringRedisTemplate;

@Override
public CustomersEntity findById(Integer id)
// 需要缓存
// 所有涉及的缓存都需要删除，或者更新
try
String toString = stringRedisTemplate.opsForHash().get(REDIS_CUSTOMERS_ONE, id + "").toString();
if (toString != null)
return JSONUtil.toBean(toString, CustomersEntity.class);

catch (Exception e)
e.printStackTrace();

// 缓存为空的时候，先查,然后缓存redis
Optional< CustomersEntity> byId = customerRepo.findById(id);
if (byId.isPresent())
CustomersEntity customersEntity = byId.get();
try
stringRedisTemplate.opsForHash().put(REDIS_CUSTOMERS_ONE, id + "", JSONUtil.toJsonStr(customersEntity));
catch (Exception e)
e.printStackTrace();

return customersEntity;

return null;



3.3、扩展
3.3.1、spring-boot-starter-data-redis 的依赖包
3.3.2、stringRedisTemplate API（部分展示）opsForHash --> hash 操作
opsForList --> list 操作
opsForSet --> set 操作
opsForValue --> string 操作
opsForZSet --> Zset 操作

3.3.3 StringRedisTemplate 默认序列化机制
public class StringRedisTemplate extends RedisTemplate< String, String>

public StringRedisTemplate()
RedisSerializer< String> stringSerializer = new StringRedisSerializer();
setKeySerializer(stringSerializer);
setValueSerializer(stringSerializer);
setHashKeySerializer(stringSerializer);
setHashValueSerializer(stringSerializer);




四、RedissonClient 操作示例4.1 基本配置
4.1.1、Maven pom 引入
< dependency>
< groupId> org.springframework.boot< /groupId>
< artifactId> spring-boot-starter-data-redis< /artifactId>
< /dependency>

< dependency>
< groupId> org.redisson< /groupId>
< artifactId> redisson< /artifactId>
< version> 3.8.2< /version>
< optional> true< /optional>
< /dependency>

< dependency>
< groupId> org.redisson< /groupId>
< artifactId> redisson-spring-boot-starter< /artifactId>
< version> LATEST< /version>
< /dependency>


4.1.2、添加配置文件 Yaml 或者 json 格式redisson-config.yml
# Redisson 配置
singleServerConfig:
address: "redis://192.168.1.140:6379"
password: null
clientName: null
database: 15
#选择使用哪个数据库0~15
idleConnectionTimeout: 10000
pingTimeout: 1000
connectTimeout: 10000
timeout: 3000
retryAttempts: 3
retryInterval: 1500
reconnectionTimeout: 3000
failedAttempts: 3
subscriptionsPerConnection: 5
subscriptionConnectionMinimumIdleSize: 1
subscriptionConnectionPoolSize: 50
connectionMinimumIdleSize: 32
connectionPoolSize: 64
dnsMonitoringInterval: 5000
#dnsMonitoring:
falsethreads: 0
nettyThreads: 0
codec:
class: "org.redisson.codec.JsonJacksonCodec"
transportMode: "NIO"


或者，配置 redisson-config.json

"singleServerConfig":

"idleConnectionTimeout": 10000,
"pingTimeout": 1000,
"connectTimeout": 10000,
"timeout": 3000,
"retryAttempts": 3,
"retryInterval": 1500,
"reconnectionTimeout": 3000,
"failedAttempts": 3,
"password": null,
"subscriptionsPerConnection": 5,
"clientName": null,
"address": "redis://192.168.1.140:6379",
"subscriptionConnectionMinimumIdleSize": 1,
"subscriptionConnectionPoolSize": 50,
"connectionMinimumIdleSize": 10,
"connectionPoolSize": 64,
"database": 0,
"dnsMonitoring": false,
"dnsMonitoringInterval": 5000
,
"threads": 0,
"nettyThreads": 0,
"codec": null,
"useLinuxNativeEpoll": false



4.1.3、读取配置【Spring Boot + Redis 实现各种操作 #yyds干货盘点#】新建读取配置类
@Configuration
public

    推荐阅读


    上一篇：java版gRPC实战之二（服务发布和调用）

    下一篇：测试服务器带宽的几种常用方法