Java操作Redis2种方法代码详解
作者:晒太阳的兔子很忙 发布时间:2022-09-10 22:58:56
Java操作Redis的方式有下面两种:
一、jedis
(1)maven配置
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
(2)相关类
单节点:redis.clients.jedis.Jedis
集群:redis.clients.jedis.JedisCluster
(3)说明
使用的类和api不一样,导致对redis单节点和集群要特地区别对待。
无法集成springCache。
JedisCluster没有对象序列化/反序列化 api,需要自己实现。
jedis2.7版本才正式支持JedisCluster。
二、spring-data-redis
(1)maven配置
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.8.4.RELEASE</version>
</dependency>
(2)相关类
单节点:org.springframework.data.redis.core.RedisTemplate
集群:org.springframework.data.redis.core.RedisTemplate
(3)说明
使用方式统一,如:
redisTemplate.opsForValue().set(key, object);
redisTemplate.opsForHash().put(key, hashKey, object);
可以集成SpringCache。
自带序列化功能,4种:
stringRedisSerializer
JdkSerializationRedisSerializer
Jackson2JsonRedisSerializer
OxmSerializer
(4)SpringCache功能
Spring 3.1 引入了基于注解(annotation)的缓存(cache)技术,通过在既有代码中添加少量它定义的各种annotation,即能够达到缓存方法的返回对象的效果,支持和主流的专业缓存例如 EHCache,Memcache,Redis等集成,也支持以自行扩展。注解可以标记在一个类上,也可以标记在方法上。
开启SpringCache功能:@EnableCaching
SpringCache注解:
@Cacheable --执行方法前,判断有无缓存,如果有直接从缓存中获取结果进行返回,否则放入缓存
@CacheEvict --触发缓存的清除操作
@CachePut --每次都会执行该方法,并将执行结果以键值对的形式存入指定的缓存中
优点:
减少手写缓存代码量,通过少量的注释标签和配置文件,即可达到使代码具备缓存的能力。
底层Cache类型更换代码无需改动,如由EHCache换成Redis。
缺点:
注解无过期时间expire属性,需自行扩展。
使用限制:基于proxy 的spring aop带来的内部调用问题,如this内部调用,非public方法调用等。
放入缓存方法只使用connection.set,即缓存存入Redis都是String字符串类型。
(5)Tomcat插件RedisSessionManager
分布式系统要将HttpSession放入Redis共享,代码又不想改动的话,那么可以通过RedisSessionManager来集成,可以引入第三方插件RedisSessionManager和相关jar,在tomcat下配置即可。
配置
引入插件:
\Tomcat7\conf\context.xml下配置
<Valve className="com.r.tomcat.session.management.RequestSessionHandlerValve"/>
<Manager className="com.r.tomcat.session.management.RequestSessionManager"/>\Tomcat7\conf\RedisDataCache.properties配置
redis.hosts=127.0.0.1:6379, 127.0.0.2:6379, 127.0.0.2:6380, ....
redis.password=
redis.cluster.enabled=true
优点
session的代码写法不用动,依然使用传统写法session.setAttribute(key,value);引入插件后session由本地tomcat存储改为了Redis,重启tomcat也不用担心session消失。
缺点
只能用于tomcat。
(6)SpringSession
这个技术重写了HttpSession,以SpringSession来做,Spring Session提供了集群Session(Clustered Sessions)功能, 默认采用外置的Redis来存储Session数据,以此来解决Session共享的问题。
配置
maven:
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
开启Reids键空间通知功能:
notify-keyspace-events AKE
开启Redis存储springSession:
@EnableRedisHttpSession(maxInactiveIntervalInSeconds=1800)
优点
和web服务器无关,甚至可以不用web服务器,也能支持session,是一种独立于应用服务器的方案。
配合spring-data-redis.jar使用,能够支持Redis单节点、Sentinel、Redis3.x集群等。
HttpSession代码无需做任何改动,依然使用传统写法session.setAttribute(key,value)。
SpringSession最新版本支持HttpSessionListener。
缺点
依赖Spring。
Spring版本要是4.1.6以上,servlet要是3.0.1以上,这样对JDK(1.6+)和web服务器(tomcat7+)版本有限制。
(7)SpringSession使用session *
SpringSession最新版本支持HttpSessionListener,该 * 可以捕捉到session创建和销毁,内部采用Redis的Sub/Pub+键空间通知功能实现。
* 类
@EnableRedisHttpSession(maxInactiveIntervalInSeconds=1800)
public class RedisHttpSessionConfig {
/**
* 注入 *
*/
@Bean
public SessionEventHttpSessionListenerAdapter listenerAdapter() {
List<HttpSessionListener> listenerList = new ArrayList<>();
listenerList.add(new SessionListener()); // 注入自己的SessionListener类
return new SessionEventHttpSessionListenerAdapter(listenerList);
}
}
说明
HttpSessionListener不推荐在RedisCluster下使用:因sessionDestoryed采取的是Redis键空间通知功能,键空间通知功能是在Redis2.8开始新推出的,但在RedisCluster下键空间通知功能有bug,event触发时不会publish通知到所有节点,只对本节点的master/slave通知,故使用redisCluster的环境下,有可能会订阅收不到sessionDestroyed消息,故不推荐在RedisCluster下使用HttpSessionListener。需要自己去实现SUBSCRIBE各个Redis节点捕捉sessionDestoryed功能。
重复监听:当一个session销毁时,那么我们的listener的sessionDestroyed方法、所有微服务实例都会收到事件通知。会导致重复,故需要注意这点,需要应用自行控制重复问题。
来源:https://www.cnblogs.com/bien94/p/12603270.html
猜你喜欢
- java文件打包jar运行有效步骤:1.cmd 到当前目录(默认包主类所在目录为例) set classpath = 默认包主类所在目录2.
- 程序的结构分类:顺序结构:按照写代码的顺序 一次执行选择结构:根据条件的不同有选择的执行不同的代码循环结构:在一定条件下 反复执行某一片代码
- 官方文档:https://developers.weixin.qq.com/miniprogram/dev/framework/open-a
- 文章来源:csdn 作者:wangfengsdu经常听到回调函数(callback function)这个概念, 所谓回调函数,就是指这个函
- 一、XSSFpackage com.yy.demo01;import java.io.FileInputStream;import java
- 一、 WillPopScope用法WillPopScope本质是一个widget用于拦截物理按键返回事件(Android的物理返回键和iOS
- Java设计模式的模板方法模式定义一个操作中算法的框架,而将一些步骤延迟到子类中,使得子类可以不改变算法的结构即可重定义该算法中的某些特定步
- 本文实例讲述了java实现单词搜索迷宫游戏。分享给大家供大家参考。具体分析如下:我们在杂志上,经常能够看到找单词的小游戏,在一个二维表格中,
- 责任链模式责任链模式的定义:使多个对象都有机会处理请求,从而避免请求的发送者和接受者之间的耦合关系, 将这个对象连成一条链,并沿着这条链传递
- JPA设置表名和实体名,表字段与实体字段的对应首先 你的jpaProperties配置项中要有<prop key="hibe
- Map 中ConcurrentHashMap是线程安全的,但不是所有操作都是,例如get()之后再put()就不是了,这时使用merge()
- 配置文件<!-- 文件上传 --> <bean id="multipartResolver" clas
- 我们知道 Spring Boot 已经提供了一套默认的异常处理机制,但是 Spring Boot 提供的默认异常处理机制却并不一定适合我们实
- 当两个线程竞争同一资源时,如果对资源的访问顺序敏感,就称存在竞态条件。导致竞态条件发生的代码区称作临界区。在临界区中使用适当的同步就可以避免
- 以前就遇到过这个问题,今天重新拾起来。跑马灯效果其实就是当文字超过TextView控件宽度的时候,使用滚动的方式显示出来:方法1:(直接xm
- 资源服务器就是业务服务 如用户服务,订单服务等 第三方需要到资源服务器调用接口获取资源ResourceServerConfigResourc
- Android 微信摇一摇功能实现,最近学习传感器,就想实现摇一摇的功能,上网查了些资料,就整理下。如有错误,还请指正。开发环境Androi
- 提示:java.util.zipoutputstream
- 本篇博客我们继续的来聊SpringMVC的东西,下方我们将会聊到js、css这些静态文件的加载配置,以及服务器推送的两种实现方式。当然我们在
- 懒加载---就是我们在spring容器启动的是先不把所有的bean都加载到spring的容器中去,而是在当需要用的时候,才把这个对象实例化到