1.Jedis
以redis命令作为方法名称,学习成本低,简单使用。但是jedis实例是不安全的,多线程环境下需要基于连接池来使用。
2.Lettuce
lettuce是基于Netty实现的,支持同步,异步和响应式编程方式,并且是线程安全的。支持redis的哨兵模式、集群模式和管道模式。
3.Redisson
redisson是一个基于redis实现分布式、可伸缩的java数据结构集合,包含了诸如Map,Queue,Lock,Semphore,AtomicLong等强大功能。
Spring Data Redis 可以兼容 Jedis和Lettuce两个客户端。
Jedis官方网站:https://github.com/redis/jedis
1.引入依赖
<dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>3.7.0</version> </dependency>
单元测试依赖
<dependency> <groupId>org.junit.jupiter</groupId> <artifactId>junit-jupiter</artifactId> <version>5.7.0</version> <scope>test</scope> </dependency>
2.建立连接
3.操作redis
4.释放资源
package com.xkj.org;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;
public class JedisTest {
private Jedis jedis;
@BeforeEach
void setUp() {
//建立连接
jedis = new Jedis("192.168.171.130", 6379);
//设置密码
jedis.auth("123456");
//选择库
jedis.select(0);
}
@Test
void testString() {
String result = jedis.set("name", "虎子");
System.out.println("result="+result);
String name = jedis.get("name");
System.out.println("name="+name);
}
@AfterEach
void tearDown() {
if(jedis!= null) {
jedis.close();
}
}
}
Hash类型的操作
@Test
void testHash() {
//插入hash数据
Long res = jedis.hset("person", "name", "张三");
jedis.hset("person", "age", "22");
System.out.println("res="+res);
//取出hash数据
String name = jedis.hget("person", "name");
System.out.println("name="+name);
//全部取出hash数据
Map<String, String> person = jedis.hgetAll("person");
System.out.println("person="+person);
}
jedis本身是线程不安全的,并且频繁的创建和销毁连接会有性能损耗,因此推荐使用jedis连接池代替jedis直连方式。
Jedis连接池
package com.xkj.org.utils;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;
public class JedisConnectionFactory {
public static final JedisPool jedisPool;
static {
//配置连接池
JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
jedisPoolConfig.setMaxTotal(8);
jedisPoolConfig.setMaxIdle(8);
jedisPoolConfig.setMaxWaitMillis(1000);
//创建连接池对象
jedisPool = new JedisPool(jedisPoolConfig, "192.168.171.130", 6379, 1000, "123456");
}
public static Jedis getJedis() {
return jedisPool.getResource();
}
}
package com.xkj.org;
import com.xkj.org.utils.JedisConnectionFactory;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisFactory;
import java.util.Map;
public class JedisTest {
private Jedis jedis;
@BeforeEach
void setUp() {
//建立连接
// jedis = new Jedis("192.168.171.130", 6379);
jedis = JedisConnectionFactory.getJedis();
//设置密码
jedis.auth("123456");
//选择库
jedis.select(0);
}
@Test
void testString() {
String result = jedis.set("name", "虎子");
System.out.println("result="+result);
String name = jedis.get("name");
System.out.println("name="+name);
}
@Test
void testHash() {
//插入hash数据
Long res = jedis.hset("person", "name", "张三");
jedis.hset("person", "age", "22");
System.out.println("res="+res);
//取出hash数据
String name = jedis.hget("person", "name");
System.out.println("name="+name);
//全部取出hash数据
Map<String, String> person = jedis.hgetAll("person");
System.out.println("person="+person);
}
@AfterEach
void tearDown() {
if(jedis!= null) {
//如果是连接池,会将连接还回池子
jedis.close();
}
}
}