Jedis操作Redis數據庫

添加Maven依賴:

    <dependencies>
        <!-- 單元測試 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>redis.clients</groupId>
            <artifactId>jedis</artifactId>
            <version>2.8.0</version>
        </dependency>
    </dependencies>

聯系Jedis操作redis的常用命令:

TestRedis.java

 import java.util.List;
 import org.junit.Test;
 import redis.clients.jedis.Jedis;
 import redis.clients.jedis.JedisPool;
 import redis.clients.jedis.JedisPoolConfig;
 import redis.clients.jedis.Pipeline;
 import redis.clients.jedis.Transaction;
 
 public class TestRedis {
     
     String host = "192.168.1.99";
     int port = 6379;
     Jedis jedis = new Jedis(host, port);
     /**
      * 單機單鏈接的方式
      * 這種獲取連接的方式只在測試的時候使用
      * 注意需要關閉redis服務器的防火牆
      * @throws Exception
      */
     @Test
     public void test1() throws Exception {
         //獲取redis連接
         //jedis.set("hehe", "aaaaaa");
         String value = jedis.get("hehe");
         System.out.println(value);
         jedis.close();
     }
     
     /**
      * 單機連接池方式
      * 實際工作中建議使用這種方式
      * @throws Exception
      */
     @Test
     public void test2() throws Exception {
         //指定連接池的參數
         JedisPoolConfig poolConfig = new JedisPoolConfig();
         //最大空閑連接數
         poolConfig.setMaxIdle(10);
         //連接池的最大連接數
         poolConfig.setMaxTotal(100);
         //設置獲取連接的最大等待時間
         poolConfig.setMaxWaitMillis(1000);
         //從連接池中獲取連接的時候是否需要校驗，這樣可以保證取出的連接都是可用的
         poolConfig.setTestOnBorrow(true);
         //獲取jedis連接池
         JedisPool jedisPool = new JedisPool(poolConfig , host, port);
         //從連接池中取一個鏈接
         Jedis jedis = jedisPool.getResource();
         String value = jedis.get("hehe");
         System.out.println(value);
         //這個close並不是關閉連接，而是把連接還給連接池。
         jedis.close();
     }
     
     /**
      * 手工實現incr命令
      * @throws Exception
      */
     @Test
     public void testIncr() throws Exception {
        //監控鍵a的值,如果在事務開啟(multi命令執行之間這個鍵的值被其他命令修改了
        //watch並不能取消其他線程的修改那么就會取消事務代碼的執行,事務會返回一個null(nil))
         jedis.watch("a");
         String value = jedis.get("a");
         int parseInt = Integer.parseInt(value);
         parseInt++;
         System.out.println("休息一會....");
         Thread.sleep(5000);
         Transaction multi = jedis.multi();
         multi.set("a", parseInt+"");
         List<Object> exec = multi.exec();
         if(exec==null){//exec返回的是null說明鍵的值被其它線程修改了.
             System.out.println("值被修改了,事務沒有執行。。。。");
             testIncr();
         }else{
             System.out.println("正常執行....");
         }
     }
     
     /**
      * 模擬惡意登陸的場景,
      * 限制一個IP的訪問次數
      */     
     private boolean testLogin(String ip) {
         String value = jedis.get(ip);
         if(value==null){
             jedis.set(ip, 1+"");
             jedis.expire(ip, 60);//如果不加這個設置這個ip只能訪問10次
         }else{
             int parseInt = Integer.parseInt(value);
             if(parseInt>10){
                 System.out.println("訪問受限！");
                 return false;
             }
             jedis.incr(ip);
         }
         
         return true;
     }
     
     /**
      * 不使用管道
      * 初始化1000條數據
      * 消耗時間：5365(老師機器)  122(我的機器)
      * @throws Exception
      */
     @Test
     public void test3() throws Exception {
         long start_time = System.currentTimeMillis();
         for(int i=0;i<1000;i++){
             jedis.set("he"+i, "hello");
         }
         System.out.println("消耗時間："+(System.currentTimeMillis()-start_time));
     }
     
     
     /**
      * 使用管道
      * 初始化1000條數據
      * 消耗時間：281(老師機器) 27(我的機器)
      * @throws Exception
      */
     @Test
     public void test4() throws Exception {
         long start_time = System.currentTimeMillis();
         Pipeline pipelined = jedis.pipelined();
         for(int i=0;i<1000;i++){
             pipelined.set("ha"+i, "hello");
         }
         
         pipelined.sync();//執行管道中的命令
         System.out.println("消耗時間："+(System.currentTimeMillis()-start_time));
     }
 }

 一般通過一個工具類來從redis連接池中獲得redis連接.

 RedisUtil.java

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

/**
 * 靜態工具類
 * @author Administrator
 *
 */
public class RedisUtils {
    
    private static JedisPool jedisPool = null;
    
    /**
     * 從連接池中獲取一個redis鏈接
     * 如果兩個線程,第一個線程先進來還沒有new出來,第二個線程進入if了,這樣就造
     * 線程的安全性問題.
     * @return
     */
    public static synchronized Jedis getJedis(){
        if(jedisPool==null){//第一次初始化的時候是null,第一次出事后之后就不再執行
            JedisPoolConfig poolConfig = new JedisPoolConfig();
            //最大空閑連接數
            poolConfig.setMaxIdle(10);
            //連接池中最大連接數
            poolConfig.setMaxTotal(100);
            //在獲取鏈接的時候設置的超市時間
            poolConfig.setMaxWaitMillis(1000);
            //表示在向連接池中創建連接的時候會對鏈接進行測試，保證連接池中的鏈接都是可用的。
            poolConfig.setTestOnBorrow(true);
            jedisPool = new JedisPool(poolConfig, "192.168.1.170", 6379);
        }
        Jedis jedis = jedisPool.getResource();
        return jedis;
    }
    
    /**
     * 把redis鏈接返回連接池
     */
    public static void returnJedis(Jedis jedis){
        jedisPool.returnResourceObject(jedis);
    }
}

通過Jedis來操作Redis集群.

ClusterTest.java

import java.util.HashSet;
import java.util.Set;

import org.junit.Test;

import redis.clients.jedis.HostAndPort;
import redis.clients.jedis.JedisCluster;
import redis.clients.jedis.JedisPoolConfig;

public class ClusterTest {
    
    
    @Test
    public void test() throws Exception{
        JedisPoolConfig poolConfig = new JedisPoolConfig();
        //最大空閑連接數
        poolConfig.setMaxIdle(10);
        //連接池中最大連接數
        poolConfig.setMaxTotal(100);
        //在獲取鏈接的時候設置的超市時間
        poolConfig.setMaxWaitMillis(1000);
        //表示在向連接池中創建連接的時候會對鏈接進行測試，保證連接池中的鏈接都是可用的。
        poolConfig.setTestOnBorrow(true);
        Set<HostAndPort> nodes = new HashSet<HostAndPort>();
        nodes.add(new HostAndPort("192.168.0.172", 7000));
        nodes.add(new HostAndPort("192.168.0.172", 7001));
        nodes.add(new HostAndPort("192.168.0.172", 7002));
        nodes.add(new HostAndPort("192.168.0.172", 7003));
        nodes.add(new HostAndPort("192.168.0.172", 7004));
        nodes.add(new HostAndPort("192.168.0.172", 7005));
        
        JedisCluster jedisCluster = new JedisCluster(nodes, poolConfig);
        jedisCluster.set("a", "1");
        String value = jedisCluster.get("a");
        System.out.println(value);
    }
}