java操作redis之jedis

我们之前对Redis的学习都是在命令行窗口，那么如何使用Java来对Redis进行操作呢？对于Java连接Redis的开发工具有很多，这里先介绍通过Jedis实现对Redis的各种操作。（前提是你的redis已经配置了远程访问）

1.创建一个maven工程，并且添加以下依赖

1. <dependencies>
2.      
3.     <dependency>
4.       <groupId>redis.clients</groupId>
5.       <artifactId>jedis</artifactId>
6.       <version>3.7.0</version>
7.     </dependency>
8.    
9.     <dependency>
10.       <groupId>org.junit.jupiter</groupId>
11.       <artifactId>junit-jupiter</artifactId>
12.       <version>5.7.0</version>
13.       <scope>test</scope>
14.     </dependency>
15. </dependencies>

复制代码

2.创建JedisTest.java测试类

1. package org.example.test;
3. import org.junit.jupiter.api.AfterEach;
4. import org.junit.jupiter.api.Test;
5. import redis.clients.jedis.Jedis;
6. import org.junit.jupiter.api.BeforeEach;
8. import java.util.Map;
11. public class JedisTest {
12.     private Jedis jedis;
14.     @BeforeEach
15.     void setUp(){
16.         // 建立连接
17.         jedis = new Jedis("192.168.***.***", 6379);
18.         // 设置密码
19.         jedis.auth("******");
20.         // 选择数据库
21.         jedis.select(0);
22.     }
24.     //测试String
25.     @Test
26.     void testString(){
27.         // 添加数据
28.         String result = jedis.set("name", "minqilianghhahahah");
29.         System.out.println(result);
30.         // 获取数据
31.         String data = jedis.mget(new String[]{"id","name"}).toString();
32.         System.out.println(data);
33.     }
35.     //测试hash
36.     @Test
37.     void testHash(){
38.         // 添加数据
39.         jedis.hset("user", "name", "张三");
40.         jedis.hset("user", "age", "23");
41.         // 获取数据
42.         String name = jedis.hget("user", "name");
43.         Map<String, String> user = jedis.hgetAll("user");
44.         System.out.println(name);
45.         System.out.println(user);
46.     }
48.     //释放资源
49.     @AfterEach
50.     void tearDown(){
51.         if(jedis != null){
52.             jedis.close();
53.         }
54.     }
55. }

复制代码

到这里Jedis如何连接redis以及常用操作已经了解了，其实这里的操作方法和原始的方法是一致的，降低了学习成本。但是还有一些不好的地方就是每次使用都要重新连接redis，使用完又要断开连接，那么可以使用连接池来解决这个问题。下面介绍连接池的使用。

3.使用连接池

• 创建连接工厂类，如下：
  1. package org.example;
  3. import redis.clients.jedis.Jedis;
  4. import redis.clients.jedis.JedisPool;
  5. import redis.clients.jedis.JedisPoolConfig;
  7. public class JedisConnectionFactory {
  8.     private static final JedisPool jedisPool;
  9.     static {
  10.         // 配置链接池信息
  11.         JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
  12.         // 设置最大连接数
  13.         jedisPoolConfig.setMaxTotal(8);
  14.         // 设置最大空闲连接数
  15.         jedisPoolConfig.setMaxIdle(8);
  16.         // 设置最小空闲连接数
  17.         jedisPoolConfig.setMinIdle(0);
  18.         // 设置连接池的最大等待时间
  19.         jedisPoolConfig.setMaxWaitMillis(1000);
  20.         // 创建连接池对象
  21.         jedisPool = new JedisPool(jedisPoolConfig,"192.168.***.***",6379,1000,
  22.                 "******");
  23.     }
  25.     public static Jedis getJedis() {
  26.         return jedisPool.getResource();
  27.     }
  28. }

  复制代码
• 测试类使用连接池
  1. package org.example.test;
  3. import org.example.JedisConnectionFactory;
  4. import org.junit.jupiter.api.AfterEach;
  5. import org.junit.jupiter.api.Test;
  6. import redis.clients.jedis.Jedis;
  7. import org.junit.jupiter.api.BeforeEach;
  9. import java.util.Map;
  12. public class JedisTest {
  13.     private Jedis jedis;
  15.     // 通过连接池获取连接
  16.     @BeforeEach
  17.     void setUp(){
  18.            // 建立连接
  19.            jedis = JedisConnectionFactory.getJedis();
  20.            // 选择数据库
  21.            jedis.select(0);
  22.     }
  24.     //测试String
  25.     @Test
  26.     void testString(){
  27.            // 添加数据
  28.            String result = jedis.set("name", "minqilianghhahahah");
  29.            System.out.println(result);
  30.            // 获取数据
  31.            String data = jedis.mget(new String[]{"id","name"}).toString();
  32.            System.out.println(data);
  33.     }
  35.     //测试hash
  36.     @Test
  37.     void testHash(){
  38.            // 添加数据
  39.            jedis.hset("user", "name", "张三");
  40.            jedis.hset("user", "age", "23");
  41.            // 获取数据
  42.            String name = jedis.hget("user", "name");
  43.            Map<String, String> user = jedis.hgetAll("user");
  44.            System.out.println(name);
  45.            System.out.println(user);
  46.     }
  48.     //释放资源
  49.     @AfterEach
  50.     void tearDown(){
  51.            if(jedis != null){
  52.                    jedis.close();
  53.            }
  54.     }
  55. }

  复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！