JavaWeb--Redis【进阶】

一、前言

通过Redis【入门】我们已经知道如何在通过命令行来操作Redis数据库了，但是我们实际的项目中当然是不可能这样做的。那么在程序中是如何通过java代码来操作Redis的呢？？？
其实我们已经知道，Redis虽然是NOSQL数据库，但它也是一款数据库，所以操作是不是会和JDBC有点相似呢？
在java中我们想要操作redis，可以使用Jedis。

二、Jedis是什么

Jedis就是集成了redis的一些命令操作，封装了redis的java客户端，并且提供了连接池管理。

三、如何使用Jedis

（一）使用步骤

1、导入相关jar包
2、创建Jedis连接对象
3、通过jedis对象调用相关方法操作redis
4、释放相关资源

（二）快速入门

需求：使用jedis存储一条字符串数据

public void test01(){
    /**
     * 1、获取连接
     * 2、调用方法进行操作
     * 3、释放连接
     */
    Jedis jedis = new Jedis("127.0.0.1", 6379);
    jedis.set("username", "zhangsan");
    jedis.close();
}

四、Jedis测试相关方法

（一）字符串类型

public void test02(){
    /**
     * 1、获取连接
     * 2、调用方法进行操作
     * 3、释放连接
     */
    Jedis jedis = new Jedis("127.0.0.1", 6379);
    jedis.set("username", "zhangsan");
    String username = jedis.get("username");
    System.out.println(username);
    jedis.del("username");
    
    //还可以使用setex()方法存储可以指定过期时间的数据
    jedis.setex("activecode", 10, "哈哈");
    String activecode = jedis.get("activecode");
    System.out.println(activecode);
    jedis.close();
}

（二）hash类型

public void test03(){
    Jedis jedis = new Jedis();  //默认的参数就是localhost，端口就是6379
    
    jedis.hset("user", "name", "zhangsan");
    jedis.hset("user", "age", "20");
    jedis.hset("user", "gender", "man");
    String name = jedis.hget("user", "name");
    String age = jedis.hget("user", "age");
    String gender = jedis.hget("user", "gender");
    System.out.println(name + ", " + age + ", " + gender);
    
    Map<String, String> user = jedis.hgetAll("user");
    Set<String> keys = user.keySet();
    for(String key:keys){
        String value = user.get(key);
        System.out.println(key + ":" + value);
    }
    
    jedis.close();
}

（三）list类型

public void test04(){
    Jedis jedis = new Jedis("localhost", 6379);
    
    jedis.lpush("mylist", "a", "b", "c");
    jedis.rpush("mylist", "a", "b", "c");
    List<String> mylist1 = jedis.lrange("mylist", 0, -1);
    System.out.println(mylist1);
    System.out.println(jedis.lpop("mylist"));
    System.out.println(jedis.rpop("mylist"));
    List<String> mylist2 = jedis.lrange("mylist", 0, -1);
    System.out.println(mylist2);
    
    jedis.close();
}

（四）set类型

public void test05(){
    Jedis jedis = new Jedis("localhost", 6379);
    
    jedis.sadd("myset", "张三", "李四", "王五");
    Set<String> myset1 = jedis.smembers("myset");
    System.out.println(myset1);
    jedis.srem("myset", "李四");
    
    jedis.close();
}

（五）sortedset类型

public void test06(){
    Jedis jedis = new Jedis("localhost", 6379);
    
    jedis.zadd("mySortedSet", 20, "张三");
    jedis.zadd("mySortedSet", 53, "李四");
    jedis.zadd("mySortedSet", 43, "王五");
    Set<String> mySortedSet1 = jedis.zrange("mySortedSet", 0, -1);
    System.out.println(mySortedSet1);
    jedis.zrem("mySortedSet", "李四");
    Set<String> mySortedSet2 = jedis.zrange("mySortedSet", 0, -1);
    System.out.println(mySortedSet2);
    
    jedis.close();
}

（六）通用命令

public void test07(){
    Jedis jedis = new Jedis("localhost", 6379);
    //keys *
    Set<String> keys = jedis.keys("*");
    for(String key:keys){
        System.out.println(key);
    }
}

五、Jedis连接池

（一）简单使用

通过JedisPool类可以直接创建连接池对象。

public void test08(){
    JedisPool jedisPool = new JedisPool( "localhost", 6379);
    
    Jedis jedis = jedisPool.getResource();
    
    jedis.set("name", "后羿");
    System.out.println(jedis.get("name"));
    
    jedis.close();
}

当然，通常我们需要对连接池进行一些设置：
1、通过调用连接池对象的相关方法进行设置
2、通过配置文件对其进行配置
此处使用的是配置文件方式，配置文件中可以有如下配置项：

#最大活动对象数     
redis.pool.maxTotal=1000    
#最大能够保持idel状态的对象数      
redis.pool.maxIdle=100  
#最小能够保持idel状态的对象数   
redis.pool.minIdle=50    
#当池内没有返回对象时，最大等待时间    
redis.pool.maxWaitMillis=10000    
#当调用borrow Object方法时，是否进行有效性检查    
redis.pool.testOnBorrow=true    
#当调用return Object方法时，是否进行有效性检查    
redis.pool.testOnReturn=true  
#“空闲链接”检测线程，检测的周期，毫秒数。如果为负值，表示不运行“检测线程”。默认为-1.  
redis.pool.timeBetweenEvictionRunsMillis=30000  
#向调用者输出“链接”对象时，是否检测它的空闲超时；  
redis.pool.testWhileIdle=true  
# 对于“空闲链接”检测线程而言，每次检测的链接资源的个数。默认为3.  
redis.pool.numTestsPerEvictionRun=50  
#redis服务器的IP    
redis.ip=xxxxxx  
#redis服务器的Port    
redis1.port=6379

（二）封装工具类

仔细想想就会发现，每次对连接池进配置时，都会有一些重复的代码，那么针对这种情况，我们就很有必要封装一个工具类了。

public class JedisPoolUtils {
    /**
     * 1、加载配置文件
     * 2、创建JedisPoolConfig对象,并进行配置
     * 3、创建JedisPool对象
     * 4、封装相关方法
     */
    private static JedisPool jedisPool;

   static {
       //加载配置文件
        InputStream is = JedisPoolUtils.class.getClassLoader().getResourceAsStream("jedis.properties");
        Properties prop = new Properties();
        try {
            prop.load(is);
        } catch (IOException e) {
            e.printStackTrace();
        }
        //创建JedisPoolConfig对象
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(Integer.parseInt(prop.getProperty("maxTotal")));
        jedisPoolConfig.setMaxIdle(Integer.parseInt(prop.getProperty("maxIdle")));

        //创建JedisPool对象
       jedisPool = new JedisPool(jedisPoolConfig, prop.getProperty("host"), Integer.parseInt(prop.getProperty("port")));
    }

    //获取Jedis对象
    public static Jedis getJedis(){
       return jedisPool.getResource();
    }
}

Java新手，若有错误，欢迎指正！

赏

都是码农，别客气了