服务器之家:专注于服务器技术及软件下载分享
分类导航

PHP教程|ASP.NET教程|Java教程|ASP教程|编程技术|正则表达式|C/C++|IOS|C#|Swift|Android|JavaScript|易语言|

服务器之家 - 编程语言 - Java教程 - JAVA中 redisTemplate 和 jedis的配合使用操作

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

2021-08-08 14:39周永发 Java教程

这篇文章主要介绍了JAVA中 redisTemplate 和 jedis的配合使用操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧

首先项目A,也就是SpringBOOT项目中使用redisTemplate 来做REDIS的缓存时,你会发现存到REDIS里边的KEY和VALUE,redisTemplat使用jdkSerializeable存储二进制字节编码

项目B中使用jedis时,存储起来的是字符串,导致项目A要调用项目缓存的键值对时,获取不到

解决方案:

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

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
@Configuration
@EnableCaching
public class RedisConfig extends CachingConfigurerSupport {
  
  /**
   * redis模板,存储关键字是字符串,值是Jdk序列化
   * @param factory
   * @return
   * @Description:
   */
  @Bean
  public RedisTemplate<?, ?> redisTemplate(RedisConnectionFactory factory) {
    RedisTemplate<?, ?> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(factory);
    //key序列化方式;但是如果方法上有Long等非String类型的话,会报类型转换错误;
    RedisSerializer<String> redisSerializer = new StringRedisSerializer();//Long类型不可以会出现异常信息;
    redisTemplate.setKeySerializer(redisSerializer);
    redisTemplate.setHashKeySerializer(redisSerializer);
    //默认使用JdkSerializationRedisSerializer序列化方式;会出现乱码,改成StringRedisSerializer
    StringRedisSerializer stringSerializer = new StringRedisSerializer();
    redisTemplate.setKeySerializer(stringSerializer);
    redisTemplate.setValueSerializer(stringSerializer);
    redisTemplate.setHashKeySerializer(stringSerializer);
    redisTemplate.setHashValueSerializer(stringSerializer);
    return redisTemplate;
  }
}

补充:RedisTemplate初始化和创建(非Spring注入方式)

概述

在工作中, 可能会在非Spring项目(如Spark,Flink作业)中去操作Redis, 重复造轮子去写工具类没有太大的意义, 使用RedisTemplate已经足够丰富和完善了,使用New的方式进行创建即可, 不同的spring-data-redis的版本会略有不同, 下面以2.3.0和1.8.9做为示例.

2.3.0

maven

?
1
2
3
4
5
6
7
8
9
10
<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>

代码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
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

如果只有一个节点, 改为单机模式

1.8.9

maven

?
1
2
3
4
5
6
7
8
9
10
<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>

代码

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
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);
  }
}

这里有个小细节, 如果不调用setShardInfo()方法, 那么需要执行下面的代码, afterPropertiesSet()用来初始化

?
1
2
3
4
5
JedisConnectionFactory fac = new JedisConnectionFactory(new JedisPoolConfig());
    fac.setPort(6379);
    fac.setPassword("123456");
    fac.setHostName("192.168.1.1");
    fac.afterPropertiesSet();

说明

RedisTemplate的构造方法有多种, 上面所举例子为其中的一种; 不通过SpringBoot自动装配的方式, 必须手动去执行afterPropertiesSet()进行初始化; 可参考SpringBoot整合redis的方式, 查看对应实现

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

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

以上为个人经验,希望能给大家一个参考,也希望大家多多支持服务器之家。如有错误或未考虑完全的地方,望不吝赐教。

原文链接:https://www.cnblogs.com/yvanBk/p/10497542.html

延伸 · 阅读

精彩推荐
  • Java教程Spring Boot 验证码的生成和验证详解

    Spring Boot 验证码的生成和验证详解

    我们在做用户登录的时候,为了安全性考虑,会增加验证码的功能,下面这篇文章主要给大家介绍了关于Spring Boot中验证码的生成和验证的相关资料,文中...

    疯狂的米老鼠4712020-11-12
  • Java教程java环境变量path和classpath的配置

    java环境变量path和classpath的配置

    这篇文章主要为大家详细介绍了java系统环境变量path和classpath的配置过程,感兴趣的小伙伴们可以参考一下 ...

    czbxdd5752020-05-29
  • Java教程java WebSocket实现聊天消息推送功能

    java WebSocket实现聊天消息推送功能

    这篇文章主要为大家详细介绍了java WebSocket实现聊天消息推送功能,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    小爷胡汉三7892021-05-13
  • Java教程java简单快速排序实例解析

    java简单快速排序实例解析

    这篇文章主要为大家详细介绍了java简单快速排序实例,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    五岁i4622020-12-14
  • Java教程Java源码解析HashMap的tableSizeFor函数

    Java源码解析HashMap的tableSizeFor函数

    今天小编就为大家分享一篇关于Java源码解析HashMap的tableSizeFor函数,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随...

    李灿辉9142021-06-30
  • Java教程servlet的url-pattern匹配规则详细描述(小结)

    servlet的url-pattern匹配规则详细描述(小结)

    在利用servlet或Filter进行url请求的匹配时,很关键的一点就是匹配规则。这篇文章主要介绍了servlet的url-pattern匹配规则详细描述(小结),非常具有实用价值,...

    51kata6042021-05-20
  • Java教程详解JAVA8 函数式接口

    详解JAVA8 函数式接口

    这篇文章主要介绍了JAVA8 函数式接口的相关资料,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下...

    冰河团队4682020-07-22
  • Java教程Java判断字符串是否为IP地址的方法

    Java判断字符串是否为IP地址的方法

    这篇文章主要为大家详细介绍了Java判断字符串是否为IP地址的方法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...

    简简单单OnlineZuozuo3382020-08-09