Java 连接到 Redis

待我称王封你为后i 2022-12-26 04:56 119阅读 0赞

### 文章目录 ###

*  Java 使用 Redis
 *   *  连接到 redis 服务
     *  Redis Java String(字符串) 实例
     *  Redis Java List(列表) 实例
     *  Redis Java Keys 实例
     *  工具类

# Java 使用 Redis #

下载驱动包 下载 **jedis.jar**

## 连接到 redis 服务 ##

import redis.clients.jedis.Jedis;
     
    public class RedisJava { 
        public static void main(String[] args) { 
            //连接本地的 Redis 服务
            Jedis jedis = new Jedis("localhost");
            // 如果 Redis 服务设置来密码，需要下面这行，没有就不需要
            // jedis.auth("123456"); 
            System.out.println("连接成功");
            //查看服务是否运行
            System.out.println("服务正在运行: "+jedis.ping());
        }
    }

Exception in thread "main" redis.clients.jedis.exceptions.JedisDataException: NOAUTH Authentication required.

这是因为 redis 设置了密码验证，而没有进行密码验证所引起的异常。我们设置了密码验证：

CONFIG set requirepass "redis"

处理方式 1，在源代码的基础上加上代码：

jedis.auth("redis");//此处为你设置的密码

处理方式 2，关闭密码验证：

CONFIG set requirepass ""

编译以上 Java 程序，确保驱动包的路径是正确的。

连接成功
    服务正在运行: PONG

## Redis Java String(字符串) 实例 ##

import redis.clients.jedis.Jedis;
     
    public class RedisStringJava { 
        public static void main(String[] args) { 
            //连接本地的 Redis 服务
            Jedis jedis = new Jedis("localhost");
            System.out.println("连接成功");
            //设置 redis 字符串数据
            jedis.set("mykey", "hello..redis");
            // 获取存储的数据并输出
            System.out.println("redis 存储的字符串为: "+ jedis.get("mykey"));
        }
    }

编译以上程序。

连接成功
    redis 存储的字符串为: hello..redis

## Redis Java List(列表) 实例 ##

import java.util.List;
    import redis.clients.jedis.Jedis;
     
    public class RedisListJava { 
        public static void main(String[] args) { 
            //连接本地的 Redis 服务
            Jedis jedis = new Jedis("localhost");
            System.out.println("连接成功");
            //存储数据到列表中
            jedis.lpush("site-list", "redis");
            jedis.lpush("site-list", "Google");
            jedis.lpush("site-list", "Taobao");
            // 获取存储的数据并输出
            List<String> list = jedis.lrange("site-list", 0 ,2);
            for(int i=0; i<list.size(); i++) { 
                System.out.println("列表项为: "+list.get(i));
            }
        }
    }

编译以上程序。

连接成功
    列表项为: Taobao
    列表项为: Google
    列表项为: redis

## Redis Java Keys 实例 ##

import java.util.Iterator;
    import java.util.Set;
    import redis.clients.jedis.Jedis;
     
    public class RedisKeyJava { 
        public static void main(String[] args) { 
            //连接本地的 Redis 服务
            Jedis jedis = new Jedis("localhost");
            System.out.println("连接成功");
     
            // 获取数据并输出
            Set<String> keys = jedis.keys("*"); 
            Iterator<String> it=keys.iterator() ;   
            while(it.hasNext()){    
                String key = it.next();   
                System.out.println(key);   
            }
        }
    }

## 工具类 ##

public class RedisUtil { 
    
        //服务器IP地址
        private static String ADDR = "192.168.41.65";
        //端口
        private static int PORT = 6379;
        //密码
        private static String AUTH = "123456";
        //连接实例的最大连接数
        private static int MAX_ACTIVE = 1024;
        //控制一个pool最多有多少个状态为idle(空闲的)的jedis实例，默认值也是8。
        private static int MAX_IDLE = 200;
        //等待可用连接的最大时间，单位毫秒，默认值为-1，表示永不超时。如果超过等待时间，则直接抛出JedisConnectionException
        private static int MAX_WAIT = 10000;
        //连接超时的时间　　
        private static int TIMEOUT = 10000;
        // 在borrow一个jedis实例时，是否提前进行validate操作；如果为true，则得到的jedis实例均是可用的；
        private static boolean TEST_ON_BORROW = true;
    
        private static JedisPool jedisPool = null;
        //数据库模式是16个数据库 0~15 
        public static final int DEFAULT_DATABASE = 0;
        /** * 初始化Redis连接池 */
    
        static { 
    
            try { 
    
                JedisPoolConfig config = new JedisPoolConfig();
                config.setMaxTotal(MAX_ACTIVE);
                config.setMaxIdle(MAX_IDLE);
                config.setMaxWaitMillis(MAX_WAIT);
                config.setTestOnBorrow(TEST_ON_BORROW);
                jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT,AUTH,DEFAULT_DATABASE);
    
            } catch (Exception e) { 
    
                e.printStackTrace();
            }
    
        }
    
        /** * 获取Jedis实例 */
    
        public synchronized static Jedis getJedis() { 
    
            try { 
    
                if (jedisPool != null) { 
                    Jedis resource = jedisPool.getResource();
                    System.out.println("redis--服务正在运行: "+resource.ping());
                    return resource;
                } else { 
                    return null;
                }
    
            } catch (Exception e) { 
                e.printStackTrace();
                return null;
            }
    
        }
    
        /*** * 释放资源 */
        
        //public static void returnResource(final Jedis jedis) { 
        // if(jedis != null) { 
        // jedisPool.returnResource(jedis);
        // }
            
        //}
        /*** * * 释放资源 */
        public static void close(final Jedis jedis) { 
            if (jedis != null) { 
                jedis.close();
            }
        }
    }
    
    
    外部调用关闭资源:
    
    RedisUtil.close(myRedis)

使用 JedisPoolConfig 需要导入 Commons Pool 包