深入了解 Redis使用 Java 操作 Redis
Posted 思想累积
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了深入了解 Redis使用 Java 操作 Redis相关的知识,希望对你有一定的参考价值。
1、Jedis
Redis 官方推荐的 java 开发工具,使用 java 操作 Redis 中间件
导入依赖
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.75</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>3.3.0</version>
</dependency>
编码测试
package com.example.redis;
import redis.clients.jedis.Jedis;
/**
* 测试 Redis 连接
*/
public class TestPing {
public static void main(String[] args) {
// 1、new jedis 对象
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.auth("root");
// 使用命令
// 测试连接
System.out.println(jedis.ping());
}
}
常用 API
String,List,Set,Hash,Zset
所有的命令与常用命令一致。
Jedis 操作事务
package com.example.redis;
import com.alibaba.fastjson.JSONObject;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;
public class TestTX {
public static void main(String[] args) {
Jedis jedis = new Jedis("127.0.0.1", 6379);
jedis.auth("root");
JSONObject jsonObject = new JSONObject();
jsonObject.put("hello", "word");
// jedis.flushDB();
// 开启事务
Transaction multi = jedis.multi();
String result = jsonObject.toJSONString();
jedis.watch("user1");
try {
multi.set("user1", result);
multi.set("user2", result);
// 代码出现异常,执行失败
int i = 1 / 0;
// 执行事务
multi.exec();
} catch (Exception e) {
// 放弃事务
multi.discard();
e.printStackTrace();
}finally {
System.out.println(jedis.get("user1"));
System.out.println(jedis.get("user2"));
// 关闭连接
jedis.close();
}
}
}
2、SpringBoot 整合 Redis
SpringBoot 操作数据:spring-data jpa mongodb redis 等
SpringBoot 2.X 之后,原来的 Jedis
被替换为 lettuce
Jedis:使用的直连,多个线程操作不安全。使用 Jedis pool 连接池。BIO
lettuce:使用 Netty
,实例可以在多个线程中共享,不存在线程不安全情况,可以减少线程数量,NIO
导入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
源码:RedisTemplate
@Bean
@ConditionalOnMissingBean(name = {"redisTemplate"}) // 我们可以自定义一个 RedisTemplate 替换默认的
@ConditionalOnSingleCandidate(RedisConnectionFactory.class)
public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
// 默认的 RedisTemplate 没有过多的设置,Redis 对象都需要序列化
// 两个泛型都是 Object 类型,我们需要强制转换 <String, Object>
RedisTemplate<Object, Object> template = new RedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
@Bean
@ConditionalOnMissingBean
@ConditionalOnSingleCandidate(RedisConnectionFactory.class) // String 类型是 Redis 中最常使用的
public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
StringRedisTemplate template = new StringRedisTemplate();
template.setConnectionFactory(redisConnectionFactory);
return template;
}
配置连接
properties配置文件:
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=root
@Configuration
public class RedisConfig {
@Bean
@SuppressWarnings("all")
public RedisTemplate<String, Object> redisTemplate (RedisConnectionFactory factory) {
// 我们为了使用方便,使用<String, Object>
RedisTemplate<String, Object> template = new RedisTemplate<String, Object>();
template.setConnectionFactory(factory);
// JSON 序列化设置
new Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = Jackson2JsonRedisSerializer(Object.class);
ObjectMapper om = new ObjectMapper();
om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON)FINAL);
jackson2JsonRedisSerializer.setObjectMapper(om);
// String 的序列化
StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
// key 使用 String 的序列化方式
template.setKeySerializer(stringRedisSerializer);
// hash 的 key 使用 String的序列化方式
template.setHashKeySerializer(stringRedisSerializer);
// value 序列化使用 jackson
template.setValueSerializer(jackson2JsonRedisSerializer);
// hash 的序列化方式采用 jackson
template.setHashValueSerializer(jackson2JsonRedisSerializer);
template.afterPropertiesSet();
return template;
}
}
以上是关于深入了解 Redis使用 Java 操作 Redis的主要内容,如果未能解决你的问题,请参考以下文章