亚洲免费在线视频-亚洲啊v-久久免费精品视频-国产精品va-看片地址-成人在线视频网

您的位置:首頁技術(shù)文章
文章詳情頁

JAVA中 redisTemplate 和 jedis的配合使用操作

瀏覽:41日期:2022-08-16 18:43:08

首先項目A,也就是SpringBOOT項目中使用redisTemplate 來做REDIS的緩存時,你會發(fā)現(xiàn)存到REDIS里邊的KEY和VALUE,redisTemplat使用jdkSerializeable存儲二進制字節(jié)編碼

項目B中使用jedis時,存儲起來的是字符串,導(dǎo)致項目A要調(diào)用項目緩存的鍵值對時,獲取不到

解決方案:

修改項目A的redisTemplate的序列方式

@Configuration@EnableCachingpublic class RedisConfig extends CachingConfigurerSupport { /** * redis模板,存儲關(guān)鍵字是字符串,值是Jdk序列化 * @param factory * @return * @Description: */ @Bean public RedisTemplate<?, ?> redisTemplate(RedisConnectionFactory factory) { RedisTemplate<?, ?> redisTemplate = new RedisTemplate<>(); redisTemplate.setConnectionFactory(factory); //key序列化方式;但是如果方法上有Long等非String類型的話,會報類型轉(zhuǎn)換錯誤; RedisSerializer<String> redisSerializer = new StringRedisSerializer();//Long類型不可以會出現(xiàn)異常信息; redisTemplate.setKeySerializer(redisSerializer); redisTemplate.setHashKeySerializer(redisSerializer); //默認使用JdkSerializationRedisSerializer序列化方式;會出現(xiàn)亂碼,改成StringRedisSerializer StringRedisSerializer stringSerializer = new StringRedisSerializer(); redisTemplate.setKeySerializer(stringSerializer); redisTemplate.setValueSerializer(stringSerializer); redisTemplate.setHashKeySerializer(stringSerializer); redisTemplate.setHashValueSerializer(stringSerializer); return redisTemplate; }}

補充:RedisTemplate初始化和創(chuàng)建(非Spring注入方式)

概述

在工作中, 可能會在非Spring項目(如Spark,Flink作業(yè))中去操作Redis, 重復(fù)造輪子去寫工具類沒有太大的意義, 使用RedisTemplate已經(jīng)足夠豐富和完善了,使用New的方式進行創(chuàng)建即可, 不同的spring-data-redis的版本會略有不同, 下面以2.3.0和1.8.9做為示例.

2.3.0

maven

<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>2.3.0.RELEASE</version></dependency><dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.3.0</version></dependency>

代碼

import org.springframework.data.redis.connection.RedisClusterConfiguration;import org.springframework.data.redis.connection.RedisNode;import org.springframework.data.redis.connection.RedisStandaloneConfiguration;import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.ValueOperations;import java.util.Collections;import java.util.List;import java.util.Objects;public class RedisTest { public static void main(String[] args) { //單機模式 RedisStandaloneConfiguration rsc = new RedisStandaloneConfiguration(); rsc.setPort(6379); rsc.setPassword('123456'); rsc.setHostName('192.168.1.1'); //集群模式 RedisClusterConfiguration rcc = new RedisClusterConfiguration(); rcc.setPassword('123456'); List<RedisNode> nodes = Collections.singletonList(new RedisNode('192.168.1.1', 6379)); rcc.setClusterNodes(nodes); RedisTemplate<String, String> template = new RedisTemplate<>(); //單機模式 JedisConnectionFactory fac = new JedisConnectionFactory(rsc); //集群模式 //JedisConnectionFactory fac = new JedisConnectionFactory(rcc); fac.afterPropertiesSet(); template.setConnectionFactory(fac); template.setDefaultSerializer(new StringRedisSerializer()); template.afterPropertiesSet(); ValueOperations<String, String> op = template.opsForValue(); final String key = '123_tmp'; final String value = 'abc'; template.delete(key); op.set(key, value); assert Objects.equals(op.get(key), value); }}

集群方式運行報錯

Exception in thread 'main' redis.clients.jedis.exceptions.JedisDataException: ERR This instance has cluster support disabled

解決

在redis.conf下將cluster-enabled改為yes

如果只有一個節(jié)點, 改為單機模式

1.8.9

maven

<dependency> <groupId>org.springframework.data</groupId> <artifactId>spring-data-redis</artifactId> <version>1.8.9.RELEASE</version></dependency><dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>2.9.0</version></dependency>

代碼

import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;import org.springframework.data.redis.core.RedisTemplate;import org.springframework.data.redis.core.ValueOperations;import redis.clients.jedis.JedisPoolConfig;import redis.clients.jedis.JedisShardInfo;import java.util.Objects;public class RedisTest { public static void main(String[] args) { RedisTemplate<String, String> template = new RedisTemplate<>(); JedisConnectionFactory fac = new JedisConnectionFactory(new JedisPoolConfig()); JedisShardInfo shardInfo = new JedisShardInfo('192.168.1.1', 6379); shardInfo.setPassword('123456'); fac.setShardInfo(shardInfo); template.setConnectionFactory(fac); template.setDefaultSerializer(new StringRedisSerializer()); template.afterPropertiesSet(); ValueOperations<String, String> op = template.opsForValue(); final String key = '123_tmp'; final String value = 'abc'; template.delete(key); op.set(key, value); assert Objects.equals(op.get(key), value); }}

這里有個小細節(jié), 如果不調(diào)用setShardInfo()方法, 那么需要執(zhí)行下面的代碼, afterPropertiesSet()用來初始化

JedisConnectionFactory fac = new JedisConnectionFactory(new JedisPoolConfig()); fac.setPort(6379); fac.setPassword('123456'); fac.setHostName('192.168.1.1'); fac.afterPropertiesSet();說明

RedisTemplate的構(gòu)造方法有多種, 上面所舉例子為其中的一種; 不通過SpringBoot自動裝配的方式, 必須手動去執(zhí)行afterPropertiesSet()進行初始化; 可參考SpringBoot整合redis的方式, 查看對應(yīng)實現(xiàn)

JAVA中 redisTemplate 和 jedis的配合使用操作

JAVA中 redisTemplate 和 jedis的配合使用操作

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持好吧啦網(wǎng)。如有錯誤或未考慮完全的地方,望不吝賜教。

標簽: Java
相關(guān)文章:
主站蜘蛛池模板: 国产伦理久久精品久久久久 | 欧美一区二区精品系列在线观看 | 欧美一二三区在线 | 国产亚洲福利精品一区二区 | av av片在线看 | 欧美日韩顶级毛片www免费看 | 国产精品日本 | 性欧美精品久久久久久久 | 国产精品日本一区二区不卡视频 | 久久久国产精品福利免费 | 日b毛片| 久久精品视频免费 | 精品国产无限资源免费观看 | 韩国毛片视频 | 日韩中文字幕一在线 | 成人18免费网站 | 亚洲毛片一级巨乳 | 一级aaa级毛片午夜在线播放 | 精品一区二区视频 | 加勒比一本一道在线 | 99久在线| 欧美不卡在线视频 | 国产精品黄网站 | 欧美精品一区二区在线观看播放 | 牛人国产偷窥女洗浴在线观看 | 欧美一级毛片日本 | 久久在线综合 | 日韩在线免费视频 | 国产成人精品日本亚洲语音1 | 啪啪一级视频 | 成人做爰| 欧美在线播放成人a | 97免费公开视频 | 性感美女视频黄.免费网站 性高湖久久久久久久久 | 玖玖在线免费视频 | 久草资源在线视频 | 亚洲七七久久精品中文国产 | 日韩一级片网址 | 玖玖精品国产 | 成人国产午夜在线视频 | 国产精选在线 |