Java客户端操作Redis
Java生态丰富，自定义的客户端非常多，常见的有Jedis、Lettuce、以及Spring整合后的RedisTemplate，但是对于初学者而言，从Jedis开始入门学习是非常容易上手的，因为Jedis中的API与原生Redis命令高度一致。
1. 引入Jedis依赖
此处引入如下依赖：
- Jedis：Java操作Redis客户端
- Junit：方便编写单元测试
<!-- https://mvnrepository.com/artifact/redis.clients/jedis -->
<dependency><groupId>redis.clients</groupId><artifactId>jedis</artifactId><version>4.4.3</version>
</dependency>
<!-- https://mvnrepository.com/artifact/junit/junit -->
<dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.12</version><scope>test</scope>
</dependency>
2. 配置Xshell端口转发
- 操作步骤：1. 打开Xshell点击属性 => 2. 配置SSH隧道 => 3. 配置如下端口转发内容
- 打开windows cmd程序输入：
netstat -ano | findstr 8888如果观察如下
- 确保
redis.conf配置中设置protect-mode为no以及bind为0.0.0.0
3. 编写Demo
使用Jedis的步骤如下：
- 创建JedisPool连接池对象（配置redis服务器所在IP地址+端口号）
- 从JedisPool连接池中取出连接对象，并操作其中提供的API方法
- 解析响应内容
/*** 测试Redis连通性* @author 米饭好好吃*/
@Test
public void testPing() {// 1. 创建JedisPoolJedisPool pool = new JedisPool("tcp://127.0.0.1:8888");// 2. 获取连接对象try(Jedis jedis = pool.getResource();) {// 设置密码（如果有）jedis.auth("xxxxxx");// 3. 调用API-pingString pong = jedis.ping();// 4. 解析响应结果System.out.println(pong);}
}
4. 测试通用命令
- 测试SET、GET命令：
:::success
注意：此处GET、SET命令是针对string类型的，此处测试通用命令需要借助SET、GET命令
:::
/*** 测试通用命令* @author 米饭好好吃*/
public class TestCommon {// redis连接池对象private JedisPool pool;@Beforepublic void init() {pool = new JedisPool("tcp://127.0.0.1:6379");}/*** 测试SET、GET命令*/@Testpublic void testGETAndSET() {// 1. 获取连接对象try(Jedis jedis = pool.getResource();) {// 2. 配置密码（如果有的话）jedis.auth("xxxxxx");// 3. 清空数据库jedis.flushDB();// 4. 测试SET命令jedis.set("k1", "hello");// 5. 测试GET命令String resp = jedis.get("k1");System.out.println("k1: " + resp);// 6. 测试SET 选项NX命令SetParams params = new SetParams();params.nx(); // 不存在才新增jedis.set("k1", "222", params);resp = jedis.get("k1");System.out.println("k1: " + resp);}}
}
- 测试EXISTS命令：
/*** 测试EXISTS命令* @author 米饭好好吃*/
@Test
public void testEXISTS() {// 1. 获取到redis连接对象try(Jedis jedis = pool.getResource();) {// 2. 配置密码（如果有的话）jedis.auth("xxxxxx");// 3. 清空数据库jedis.flushDB();// 4. 测试EXISTS命令jedis.set("k1", "111");boolean exists = jedis.exists("k1");System.out.println("k1: " + exists);jedis.del("k1");exists = jedis.exists("k1");System.out.println("k1: " + exists);}
}
- 测试DEL命令：
/*** 测试DEL命令* @author 米饭好好吃*/
@Test
public void testDEL() {// 1. 创建redis连接对象try(Jedis jedis = pool.getResource();) {// 2. 配置密码（如果有的话）jedis.auth("xxxxxx");// 3. 清空数据库jedis.flushDB();// 4. 测试del命令jedis.set("k1", "111");jedis.set("k2", "222");jedis.set("k3", "333");long delCount = jedis.del("k1", "k2", "k3");System.out.println("delCount: " + delCount);String resp = jedis.get("k1");System.out.println("k1: " + resp);}
}
注意：DEL命令中参数列表为可边长参数，可以同时删除多个key，并且返回值为删除成功的个数，这与命令行中DEL命令一致
- 测试KEYS命令：
/*** 测试KEYS命令* @author 米饭好好吃*/
@Test
public void testKEYS() {// 1. 获取redis连接对象try(Jedis jedis = pool.getResource();) {// 2. 配置密码（如果有的话）jedis.auth("xxxxxx");// 3. 清空数据库jedis.flushDB();// 4. 测试KEYS命令jedis.set("k1", "111");jedis.set("k2", "222");jedis.set("k3", "333");Set<String> keys = jedis.keys("*");System.out.println("keys: " + keys);}
}
注意：KEYS命令返回的是一个Java当中的Set类型，这是因为redis中的key都是不允许重复且对于顺序没有要求的，KEYS方法可以传递一个pattern参数，即KEYS命令后紧跟的匹配模式
- 测试EXPIRE、TTL命令：
/*** 测试EXPIRE命令* @author 米饭好好吃*/
@Test
public void testEXPIRE() {// 1. 获取redis连接对象try(Jedis jedis = pool.getResource();) {// 2. 设置密码（如果有的话）jedis.auth("xxxxxx");// 3. 清空数据库jedis.flushDB();// 4. 测试expire、ttljedis.set("k1", "111");jedis.expire("k1", 10);long ttl = jedis.ttl("k1");System.out.println("ttl: " + ttl);}
}
- 测试TYPE命令：
/*** 测试TYPE命令* @author 米饭好好吃*/
@Test
public void testTYPE() {// 1. 获取redis连接对象try(Jedis jedis = pool.getResource();) {// 2. 设置密码（如果有的话）jedis.auth("xxxxxx");// 3. 清空数据库jedis.flushDB();// 4. 测试type命令jedis.hset("k1", "f1", "v1");jedis.lpush("k2", "11", "22", "33");jedis.sadd("k3", "abc");System.out.println("k1: " + jedis.type("k1"));System.out.println("k2: " + jedis.type("k2"));System.out.println("k3: " + jedis.type("k3"));}
}
