IDEA連接Redis

1、創建一個Maven項目

 

2、在src下的pom.xml文件里，添加相關包引用

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.otwb</groupId>
    <artifactId>redisLink</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <!--用於單元測試的包-->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
        <!--mysql數據庫的jdbc驅動包：用於連接mysql數據庫-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.18</version>
        </dependency>
        <!--redis數據庫的連接驅動包-->
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.9.0</version>
        </dependency>
        <!--數據庫工具包：用於操作數據庫-->
        <dependency>
            <groupId>commons-dbutils</groupId>
            <artifactId>commons-dbutils</artifactId>
            <version>1.5</version>
        </dependency>
        <!--對象池驅動包：用於存放我們需要池化的對象，如創建redis數據庫連接池-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.5.0</version>
        </dependency>
        <!--c3p0數據庫連接池包-->
        <dependency>
            <groupId>c3p0</groupId>
            <artifactId>c3p0</artifactId>
            <version>0.9.1.2</version>
        </dependency>
    </dependencies>


</project>

 

3、創建redis連接池工具包

package utils;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

public class RedisUtils {
    //服務器IP地址
    private static String ADDR = "43.109.234.69";
    //端口
    private static int PORT = 6379;
    //連接超時的時間　　
    private static int TIMEOUT = 10000;
    //密碼
    private static String AUTH = "123";
    //數據庫模式是16個數據庫（0~15），這里設置第一個為默認數據庫
    public static final int DEFAULT_DATABASE = 0;
    //連接實例的最大連接數
    private static int MAX_ACTIVE = 1024;
    //控制一個pool最多有多少個狀態為idle(空閑的)的jedis實例，默認值也是8。
    private static int MAX_IDLE = 200;
    //等待可用連接的最大時間，單位毫秒，默認值為-1，表示永不超時。如果超過等待時間，則直接拋出JedisConnectionException
    private static int MAX_WAIT = 10000;
    //在borrow一個jedis實例時，是否提前進行validate操作；如果為true，則得到的jedis實例均是可用的；
    private static boolean TEST_ON_BORROW = true;
    //創建一個redis數據庫連接池
    private static JedisPool jedisPool = null;

    //初始化Redis連接池（靜態代碼塊）
    static {
        try {
            //新建連接池的配置參數
            JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
            //指定連接實例的最大連接數
            jedisPoolConfig.setMaxTotal(MAX_ACTIVE);
            //指定一個pool最多有多少個狀態為idle(空閑的)的jedis實例
            jedisPoolConfig.setMaxIdle(MAX_IDLE);
            //指定等待可用連接的最大時間，單位毫秒
            jedisPoolConfig.setMaxWaitMillis(MAX_WAIT);
            //在borrow一個jedis實例時，是否提前進行validate操作
            jedisPoolConfig.setTestOnBorrow(TEST_ON_BORROW);
            //初始化Redis連接池
            jedisPool = new JedisPool(jedisPoolConfig, ADDR, PORT, TIMEOUT,AUTH,DEFAULT_DATABASE);
            //jedisPool = new JedisPool(jedisPoolConfig, ADDR, PORT);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    //獲取Jedis實例
    public synchronized static Jedis getJedis() {
        try {
            if (jedisPool != null) {
                Jedis jedis = jedisPool.getResource();
                System.out.println("redis--服務正在運行: "+jedis.ping());
                return jedis;
            } else {
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }

    //釋放資源
    public static void returnResource(final Jedis jedis) {
        if(jedis != null) {
            jedisPool.returnResource(jedis);
        }
    }
}

 

4、在src——main——java下添加RedisLinkTest類，測試連接操作Redis數據庫

import org.junit.Test;
import redis.clients.jedis.Jedis;
import utils.RedisUtils;

import java.util.Iterator;
import java.util.List;
import java.util.Set;

public class RedisLinkTest {
    //@Test表示這個方法是單元測試的方法
    //連接並添加String類型數據
    @Test
    public void fun1() {
        //直接連接redis數據庫
        Jedis jedis = new Jedis("43.109.234.69",6379);
        //設置連接密碼
        jedis.auth("123");
        //添加String類型數據
        jedis.set("field1","i am field1");
        //輸出添加的數據（根據鍵，輸出對應的值）
        System.out.println(jedis.get("field1"));
        //刪除String類型數據（根據鍵刪除）
        jedis.del("field1");
        //輸出數據，查看是否刪除成功
        System.out.println(jedis.get("field1"));
    }

    //連接並添加hash類型數據（我理解為給String類型的數據進行了分類，每個hash可以存儲2^32-1個鍵值對）
    @Test
    public void fun2(){
        //通過連接池方式連接redis數據庫
        Jedis jedis = RedisUtils.getJedis();
        //添加hash類型數據
        jedis.hset("hset1","name","張三");
        jedis.hset("hset1","age","22");
        jedis.hset("hset1","sex","男");
        //獲取數據
        List<String> hmget = jedis.hmget("hset1", "name","age","sex");
        //輸出
        System.out.println(hmget);
        //刪除
        jedis.hdel("hset1","name","sex");
        //刪除后再輸出，看看是否刪除成功
        System.out.println(jedis.hmget("hset1", "name","age","sex"));
        RedisUtils.returnResource(jedis);
    }

    //連接並添加List類型數據（隊列，按照插入順序排序，可以添加一個元素到列表的頭部（左邊），或者尾部（右邊））
    @Test
    public void fun3() {
        //通過連接池方式連接redis數據庫
        Jedis jedis = RedisUtils.getJedis();
        //添加List類型數據，lpush添加到列表頭部，即后添加的數據在最前面
        jedis.lpush("field2","aaa");
        jedis.lpush("field2","bbb");
        jedis.lpush("field2","ccc");
        //從索引1的位置獲取到索引6位置的值，因為超出了實際索引2，所以后面會繼續循環輸出
        List<String> field2 = jedis.lrange("field2", 0, 6);
        //輸出添加的鍵值對
        for(String item:field2){
            System.out.println(item);
        }
        RedisUtils.returnResource(jedis);
    }

    //連接並添加Set類型數據（一堆不重復值的組合）
    @Test
    public void fun4(){
        //通過連接池方式連接redis數據庫
        Jedis jedis = RedisUtils.getJedis();
        //添加Set類型數據
        jedis.sadd("name","zhangsan");
        jedis.sadd("name","lisi");
        jedis.sadd("name","lisi");  //同一個數據再次添加，會覆蓋上一次的
        jedis.sadd("age","16");
        jedis.sadd("sex","nan");
        jedis.sadd("address","china");
        //獲取Set類型數據
        Set<String> name = jedis.smembers("name");
        //輸出獲取到的Set類型數據（輸出的順序是無序的）
        System.out.println(name);
        System.out.println("\n");
        //獲取當前redis數據庫中，所有key，以Set集合的方式返回數據
        Set<String> set = jedis.keys("*");
        Iterator<String> iterator = set.iterator();
        while(iterator.hasNext()){
            System.out.println(iterator.next());
        }
        RedisUtils.returnResource(jedis);
    }

    //連接並添加ZSet類型數據（zset是set的升級版，它在set的基礎上增加了順序屬性score，這一屬性在添加修改元素的時候可以指定，每次指定后，zset會自動重新按新的值調整順序）
    @Test
    public void fun5(){
        //通過連接池方式連接redis數據庫
        Jedis jedis = RedisUtils.getJedis();
        //添加zset型數據
        jedis.zadd("field3",1,"hhh");
        jedis.zadd("field3",0,"jjj");
        jedis.zadd("field3",3,"bbb");
        //獲取set型數據
        Set<String> field3 = jedis.zrangeByScore("field3", 0, 5);
        //用迭代器循環輸出
        Iterator<String> iterator = field3.iterator();
        while(iterator.hasNext()){
            System.out.println(iterator.next());
        }
        RedisUtils.returnResource(jedis);
    }
}

 

。