【Redis快取機制】12.Java連線Redis_Jedis_常用API

阿新 • • 發佈：2019-01-05

上一篇總結我們使用我們本地的Eclipse中建立的jedis工程，連結
到了我們處於VMware虛擬機器上的Linux系統上的Redis服務，我們接下來
講一下jedis的一些常用的API。

(1)jedis儲存字串

package cn.com.redis;

import redis.clients.jedis.Jedis;

public class Test1 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        //新增資料
        jedis.set("username", "jack");//向key-->name中放入了value-->jack
        
        System.out.println(jedis.get("username"));//執行結果:jack
        
        jedis.append("username"," is a Coder");//拼接
        System.out.println(jedis.get("username"));
        
        jedis.del("username");//刪除某個鍵
        System.out.println(jedis.get("username"));//為null
        //設定多個鍵值對
        jedis.mset("username","liuling","age","23","qq","412345678");
        jedis.incr("age");//進行加1操作
        System.out.println(jedis.get("name")+"-"+jedis.get("age")+"-"+jedis.get("qq"));
    }
}

效果:

檢視一下redis:

說明我們的操作是成功的。

(2)jedis操作Map

package cn.com.redis;

import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import redis.clients.jedis.Jedis;

public class Test2 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        //新增資料
        Map<String,String> map = new HashMap<String,String>();
        map.put("name", "ZhangSan");
        map.put("age", "35");
        map.put("email", " 
[email protected]");
        jedis.hmset("user",map);
        //第一個引數是存入redis中map物件的key，後面跟的是放入map中的物件的key，
        //後面的key可以跟多個，是可變引數  
        
        List<String> rsmap = jedis.hmget("user", "name","age","email");
        System.out.println(rsmap);
        
        //刪除map中的某個值
        jedis.hdel("user","age");
        System.out.println(jedis.hmget("user", "age"));//因為刪除了，所以返回的是null
        System.out.println(jedis.hlen("user"));//返回key為user的鍵中存放值的個數2
        System.out.println(jedis.exists("user"));//是否存在key為user的記錄，返回true
        System.out.println(jedis.hkeys("user"));//返回map物件中的所有key
        System.out.println(jedis.hvals("user"));//返回map物件中的所有val
        
        Iterator<String> iter=jedis.hkeys("user").iterator();//得到iterator物件進行遍歷
        while(iter.hasNext()){
            String key = iter.next();
            System.out.println(key+":"+jedis.hmget("user", key));
        }
    }
}

效果:

檢視一下redis:

說明我們的操作是成功的。

(3)jedis操作List

package cn.com.redis;

import redis.clients.jedis.Jedis;

public class Test3 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        //開始前，先移出所有的內容
        jedis.del("java framework");
        System.out.println(jedis.lrange("java framework", 0, -1));
        
        //先向key java framework中存放三條資料
        //lpush key string  在key對應list的頭部新增字串元素
        jedis.lpush("java framework","spring");
        jedis.lpush("java framework","struts");
        jedis.lpush("java framework","hibernate");
        
        //取出所有資料，jedis.lrange是按範圍取出，
        //第一個是key，第二個是起始位置，第三個是結束位置，-1表示取得所有
        System.out.println(jedis.lrange("java framework", 0, -1));
        
        //jedis.llen獲取長度
        System.out.println(jedis.llen("java framework"));
        
        //刪除資料
        jedis.del("java framework");
        
        //rpush key string  在key對應list的尾部新增字串元素
        //插入資料的時候如果List不存在，就建立它再插入
        jedis.rpush("java framework", "spring");
        jedis.rpush("java framework", "struts");
        jedis.rpush("java framework", "hibernate");
        System.out.println(jedis.lrange("java framework", 0, -1));
        
    }
}

效果:

檢視以下redis:

說明我們的操作是成功的。

(4)jedis操作Set

package cn.com.redis;

import redis.clients.jedis.Jedis;

public class Test4 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        //新增
        jedis.sadd("users", "ZhangSan");
        jedis.sadd("users", "LiSi");
        jedis.sadd("users", "WangWu");
        jedis.sadd("users", "ZhangEr");
        jedis.sadd("users", "MaLiu");
        
        //移出MaLiu
        jedis.srem("users", "MaLiu");
        System.out.println(jedis.smembers("users"));//獲取所有加入的value
        
        System.out.println(jedis.sismember("users", "MaLiu"));//判斷MaLiu是否是user結合的元素
        System.out.println(jedis.srandmember("users"));
        System.out.println(jedis.scard("users"));//返回集合的元素個數
        
    }
}

效果:

檢視以下redis:

說明我們的操作是成功的。

(5)jedis排序

package cn.com.redis;

import redis.clients.jedis.Jedis;

public class Test5 {
    public static void main(String[] args) {
        Jedis jedis = new Jedis("192.168.248.129",6379);
        
        //jedis排序
        //注意，此處的rpush和lpush是List的操作，是一個雙向連結串列
        //rpush是從尾部加入資料，lpush是從頭部加入資料
        
        jedis.del("a");//先清楚資料，再加入資料進行測試
        jedis.rpush("a", "1");
        jedis.rpush("a", "6");
        jedis.rpush("a", "3");
        jedis.rpush("a", "9");
        System.out.println(jedis.lrange("a", 0, -1));//[1,6,3,9]
        System.out.println(jedis.sort("a"));//[1,3,6,9]  輸出排序後結果
        
        jedis.del("a");//先清楚資料，再加入資料進行測試
        jedis.lpush("a", "1");
        jedis.lpush("a", "6");
        jedis.lpush("a", "3");
        jedis.lpush("a", "9");
        System.out.println(jedis.lrange("a", 0, -1));//[9,3,6,1]
        System.out.println(jedis.sort("a"));//[1,3,6,9]  輸出排序後結果
        
    }
}

效果:

檢視以下redis:

說明我們的操作是成功的。

(6)Redis連線池
我們每一次使用redis的時候，都要寫Jedis jedis = new Jedis("192.168.248.129",6379);
我們要優化連線，不能使用一次就new一個連線物件，我們要建立一個工具類，管理redis的
連線和一些配置引數的設定。

package cn.com.redis;

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

public class RedisUtil {
    //redis伺服器IP
    private static String ADDR = "192.168.248.129";
    
    //redis的埠號
    private static int PORT = 6379;
    
    //訪問密碼
    private static String AUTH = "root";
    
    //可用連線例項的最大數目，預設為8
    //如果賦值為-1，則表示不限制；如果pool已經分配了maxActive個jedis例項，則此
    //時pool的狀態為exhausted(耗盡)。
    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一個redis例項時，是否提前進行validate操作；
    //如果為true，則得到的jedis例項均是可用的
    private static boolean TEST_ON_BORROW = true;
    
    private static JedisPool jedisPool = null;
    
    /**
     * 初始化Redis連線池
     * Jedis的連線池配置需要用到org.apache.commons.pool.impl.GenericObjectPool.Config.class
     * 所以要引入commons-pool.jar
     * */
    static{
        try {
            JedisPoolConfig config = new JedisPoolConfig();  
            config.setMaxTotal(MAX_ACTIVE);//老版本是setMaxActive
            config.setMaxIdle(MAX_IDLE);
            config.setMaxWaitMillis(MAX_WAIT);//老版本是maxMaxWait
            config.setTestOnBorrow(TEST_ON_BORROW);
            jedisPool = new JedisPool(config,ADDR,PORT,TIMEOUT);//有密碼的時候傳入AUTH
            
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 獲取Jedis例項
     * */
    public synchronized static Jedis getJedis(){
        try {
            if(jedisPool != null){
                Jedis resource = jedisPool.getResource();
                return resource;
            }else{
                return null;
            }
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
    
    /**
     * 釋放jedis資源
     * */
    public static void returnResource(final Jedis jedis){
        if(jedis != null){
            jedisPool.returnResourceObject(jedis);
        }
    }

}

不要忘記引入commons-pool.jar:

測試:

package cn.com.redis;

import redis.clients.jedis.Jedis;

public class Test6 {
    public static void main(String[] args) {
        RedisUtil redisUtil = new RedisUtil();
        Jedis jedis = redisUtil.getJedis();
        
        try {
            System.out.println(jedis.lrange("a", 0, -1));
            System.out.println(jedis.smembers("users"));
        } catch (Exception e) {
            e.printStackTrace();
        }finally{
            redisUtil.returnResource(jedis);
        }
        
    }
}

結果:

使用連線池獲取jedis物件會更符合開發規範。

【Redis快取機制】12.Java連線Redis_Jedis_常用API

【Redis快取機制】12.Java連線Redis_Jedis_常用API

【Redis快取機制】14.Java連線Redis_Jedis_主從模式

【Redis快取機制】13.Java連線Redis_Jedis_事務

【Redis快取機制】10.主從模式

【Redis快取機制】3.key的操作

【Redis快取機制】9.快照持久化和AOF持久化

【redis，1】java操作redis：將string、list、map、自己定義的對象保存到redis中

詳解leetcode146題【LRU (最近最少使用) 快取機制】(附js最優解法！)

【Redis進階】Redis哨兵機制

【譯】12. Java反射——類的動態載入和重新載入

【Mybatis原始碼分析】12-外掛PageHelper機制

【redis原始碼分析】RDB持久化機制

【redis，1】java操作redis：將string、list、map、自定義的物件儲存到redis中

【redis快取】Redis封裝類

【redis 基礎學習】（六）Redis HyperLogLog

【劍指Offer】12連結串列中倒數第k個結點

linux上安裝redis資料庫，並實現 java連線redis一路遇到的錯誤

【學亮開講】Oracle內外連線查詢20181119

【redis-安裝篇】

【神經網路入門】用JAVA實現感知器演算法

【Redis快取機制】12.Java連線Redis_Jedis_常用API

相關推薦