Java開發中對Redis的基本操做

Jedis操做redis指令

import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.SortingParams;

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

@RunWith(SpringRunner.class)
@SpringBootTest
public class JedisTest {

    private Jedis jedis;


    @Before
    public void setup() {
        //鏈接redis服務器，192.168.0.100:6379
        jedis = new Jedis("127.0.0.1", 6379);
        //權限認證
        jedis.auth("123456");
    }

    /**
     * redis key
     */
    @Test
    public void KeyOperate() {
        System.out.println("======================key==========================");
        // 清空數據
        System.out.println("清空庫中全部數據：" + jedis.flushDB());
        // 判斷key否存在
        System.out.println("判斷key999鍵是否存在：" + jedis.exists("key999"));
        System.out.println("新增key001,value001鍵值對：" + jedis.set("key001", "value001"));
        System.out.println("判斷key001是否存在：" + jedis.exists("key001"));
        // 輸出系統中全部的key
        System.out.println("新增key002,value002鍵值對：" + jedis.set("key002", "value002"));
        System.out.println("系統中全部鍵以下：");
        Set<String> keys = jedis.keys("*");
        Iterator<String> it = keys.iterator();
        while (it.hasNext()) {
            String key = it.next();
            System.out.println(key);
        }
        // 刪除某個key,若key不存在，則忽略該命令。
        System.out.println("系統中刪除key002: " + jedis.del("key002"));
        System.out.println("判斷key002是否存在：" + jedis.exists("key002"));
        // 設置 key001的過時時間
        System.out.println("設置 key001的過時時間爲5秒:" + jedis.expire("key001", 5));
        try {
            Thread.sleep(2000);
        } catch (InterruptedException e) {
        }
        // 查看某個key的剩餘生存時間,單位【秒】.永久生存或者不存在的都返回-1
        System.out.println("查看key001的剩餘生存時間：" + jedis.ttl("key001"));
        // 移除某個key的生存時間
        System.out.println("移除key001的生存時間：" + jedis.persist("key001"));
        System.out.println("查看key001的剩餘生存時間：" + jedis.ttl("key001"));
        // 查看key所儲存的值的類型
        System.out.println("查看key所儲存的值的類型：" + jedis.type("key001"));
        /*
         * 一些其餘方法：一、修改鍵名：jedis.rename("key6", "key0");
         *             二、將當前db的key移動到給定的db當中：jedis.move("foo", 1)
         */
    }


    /**
     * redis 字符串
     */
    @Test
    public void StringOperate() throws InterruptedException {
        System.out.println("======================String_1==========================");
        // 清空數據
        System.out.println("清空庫中全部數據：" + jedis.flushDB());

        System.out.println("=============增=============");
        jedis.set("key001", "value001");
        jedis.set("key002", "value002");
        jedis.set("key003", "value003");
        System.out.println("已新增的3個鍵值對以下：");
        System.out.println(jedis.get("key001"));
        System.out.println(jedis.get("key002"));
        System.out.println(jedis.get("key003"));

        System.out.println("=============刪=============");
        System.out.println("刪除key003鍵值對：" + jedis.del("key003"));
        System.out.println("獲取key003鍵對應的值：" + jedis.get("key003"));

        System.out.println("=============改=============");
        //一、直接覆蓋原來的數據
        System.out.println("直接覆蓋key001原來的數據：" + jedis.set("key001", "value001-update"));
        System.out.println("獲取key001對應的新值：" + jedis.get("key001"));
        //二、直接覆蓋原來的數據
        System.out.println("在key002原來值後面追加：" + jedis.append("key002", "+appendString"));
        System.out.println("獲取key002對應的新值" + jedis.get("key002"));

        System.out.println("=============增，刪，查（多個）=============");
        /**
         * mset,mget同時新增，修改，查詢多個鍵值對
         * 等價於：
         * jedis.set("name","ssss");
         * jedis.set("jarorwar","xxxx");
         */
        System.out.println("一次性新增key201,key202,key203,key204及其對應值：" + jedis.mset("key201", "value201",
                "key202", "value202", "key203", "value203", "key204", "value204"));
        System.out.println("一次性獲取key201,key202,key203,key204各自對應的值：" +
                jedis.mget("key201", "key202", "key203", "key204"));
        System.out.println("一次性刪除key201,key202：" + jedis.del(new String[]{"key201", "key202"}));
        System.out.println("一次性獲取key201,key202,key203,key204各自對應的值：" +
                jedis.mget("key201", "key202", "key203", "key204"));


        Thread.sleep(2000);


        //jedis具有的功能jedis中也可直接使用，下面測試一些前面沒用過的方法
        System.out.println("======================String_2==========================");
        // 清空數據
        System.out.println("清空庫中全部數據：" + jedis.flushDB());

        System.out.println("=============新增鍵值對時防止覆蓋原先值=============");
        System.out.println("原先key301不存在時，新增key301：" + jedis.setnx("key301", "value301"));
        System.out.println("原先key302不存在時，新增key302：" + jedis.setnx("key302", "value302"));
        System.out.println("當key302存在時，嘗試新增key302：" + jedis.setnx("key302", "value302_new"));
        System.out.println("獲取key301對應的值：" + jedis.get("key301"));
        System.out.println("獲取key302對應的值：" + jedis.get("key302"));

        System.out.println("=============超過有效期鍵值對被刪除=============");
        // 設置key的有效期，並存儲數據
        System.out.println("新增key303，並指定過時時間爲2秒" + jedis.setex("key303", 2, "key303-2second"));
        System.out.println("獲取key303對應的值：" + jedis.get("key303"));
        try {
            Thread.sleep(3000);
        } catch (InterruptedException e) {
        }
        System.out.println("3秒以後，獲取key303對應的值：" + jedis.get("key303"));

        System.out.println("=============獲取原值，更新爲新值一步完成=============");
        System.out.println("key302原值：" + jedis.getSet("key302", "value302-after-getset"));
        System.out.println("key302新值：" + jedis.get("key302"));

        System.out.println("=============獲取子串=============");
        System.out.println("獲取key302對應值中的子串：" + jedis.getrange("key302", 5, 7));
    }


    /**
     * redis list
     */
    @Test
    public void ListOperate() {
        System.out.println("======================list==========================");
        // 清空數據
        System.out.println("清空庫中全部數據：" + jedis.flushDB());

        System.out.println("=============增=============");
        jedis.lpush("stringlists", "vector");
        jedis.lpush("stringlists", "ArrayList");
        jedis.lpush("stringlists", "vector");
        jedis.lpush("stringlists", "vector");
        jedis.lpush("stringlists", "LinkedList");
        jedis.lpush("stringlists", "MapList");
        jedis.lpush("stringlists", "SerialList");
        jedis.lpush("stringlists", "HashList");
        jedis.lpush("numberlists", "3");
        jedis.lpush("numberlists", "1");
        jedis.lpush("numberlists", "5");
        jedis.lpush("numberlists", "2");
        System.out.println("全部元素-stringlists：" + jedis.lrange("stringlists", 0, -1));
        System.out.println("全部元素-numberlists：" + jedis.lrange("numberlists", 0, -1));

        System.out.println("=============刪=============");
        // 刪除列表指定的值 ，第二個參數爲刪除的個數（有重複時），後add進去的值先被刪，相似於出棧
        System.out.println("成功刪除指定元素個數-stringlists：" + jedis.lrem("stringlists", 2, "vector"));
        System.out.println("刪除指定元素以後-stringlists：" + jedis.lrange("stringlists", 0, -1));
        // 刪除區間之外的數據
        System.out.println("刪除下標0-3區間以外的元素：" + jedis.ltrim("stringlists", 0, 3));
        System.out.println("刪除指定區間以外元素後-stringlists：" + jedis.lrange("stringlists", 0, -1));
        // 列表元素出棧
        System.out.println("出棧元素：" + jedis.lpop("stringlists"));
        System.out.println("元素出棧後-stringlists：" + jedis.lrange("stringlists", 0, -1));

        System.out.println("=============改=============");
        // 修改列表中指定下標的值
        jedis.lset("stringlists", 0, "hello list!");
        System.out.println("下標爲0的值修改後-stringlists：" + jedis.lrange("stringlists", 0, -1));
        System.out.println("=============查=============");
        // 數組長度
        System.out.println("長度-stringlists：" + jedis.llen("stringlists"));
        System.out.println("長度-numberlists：" + jedis.llen("numberlists"));
        // 排序
        /*
         * list中存字符串時必須指定參數爲alpha，若是不使用SortingParams，而是直接使用sort("list")，
         * 會出現"ERR One or more scores can't be converted into double"
         */
        SortingParams sortingParameters = new SortingParams();
        sortingParameters.alpha();
        sortingParameters.limit(0, 3);
        System.out.println("返回排序後的結果-stringlists：" + jedis.sort("stringlists", sortingParameters));
        System.out.println("返回排序後的結果-numberlists：" + jedis.sort("numberlists"));
        // 子串：   start爲元素下標，end也爲元素下標；-1表明倒數一個元素，-2表明倒數第二個元素
        System.out.println("子串-第二個開始到結束：" + jedis.lrange("stringlists", 1, -1));
        // 獲取列表指定下標的值
        System.out.println("獲取下標爲2的元素：" + jedis.lindex("stringlists", 2) + "\n");
    }



    /**
     * redis set
     */
    @Test
    public void SetOperate() {

        System.out.println("======================set==========================");
        // 清空數據
        System.out.println("清空庫中全部數據：" + jedis.flushDB());

        System.out.println("=============增=============");
        System.out.println("向sets集合中加入元素element001：" + jedis.sadd("sets", "element001"));
        System.out.println("向sets集合中加入元素element002：" + jedis.sadd("sets", "element002"));
        System.out.println("向sets集合中加入元素element002：" + jedis.sadd("sets", "element002"));
        System.out.println("向sets集合中加入元素element003：" + jedis.sadd("sets", "element003"));
        System.out.println("向sets集合中加入元素element004：" + jedis.sadd("sets", "element004"));
        System.out.println("查看sets集合中的全部元素:" + jedis.smembers("sets"));
        System.out.println();

        System.out.println("=============刪=============");
        System.out.println("集合sets中刪除元素element003：" + jedis.srem("sets", "element003"));
        System.out.println("查看sets集合中的全部元素:" + jedis.smembers("sets"));
           /*System.out.println("sets集合中任意位置的元素出棧："+jedis.spop("sets"));//注：出棧元素位置竟然不定？--無實際意義
           System.out.println("查看sets集合中的全部元素:"+jedis.smembers("sets"));*/

        System.out.println("=============改=============");

        System.out.println("=============查=============");
        System.out.println("判斷element001是否在集合sets中：" + jedis.sismember("sets", "element001"));
        System.out.println("循環查詢獲取sets中的每一個元素：");
        Set<String> set = jedis.smembers("sets");
        Iterator<String> it = set.iterator();
        while (it.hasNext()) {
            Object obj = it.next();
            System.out.println(obj);
        }
        System.out.println();

        System.out.println("=============集合運算=============");
        System.out.println("sets1中添加元素element001：" + jedis.sadd("sets1", "element001"));
        System.out.println("sets1中添加元素element002：" + jedis.sadd("sets1", "element002"));
        System.out.println("sets1中添加元素element003：" + jedis.sadd("sets1", "element003"));
        System.out.println("sets1中添加元素element002：" + jedis.sadd("sets2", "element002"));
        System.out.println("sets1中添加元素element003：" + jedis.sadd("sets2", "element003"));
        System.out.println("sets1中添加元素element004：" + jedis.sadd("sets2", "element004"));
        System.out.println("查看sets1集合中的全部元素:" + jedis.smembers("sets1"));
        System.out.println("查看sets2集合中的全部元素:" + jedis.smembers("sets2"));
        System.out.println("sets1和sets2交集：" + jedis.sinter("sets1", "sets2"));
        System.out.println("sets1和sets2並集：" + jedis.sunion("sets1", "sets2"));
        System.out.println("sets1和sets2差集：" + jedis.sdiff("sets1", "sets2"));//差集：set1中有，set2中沒有的元素

    }



    /**
     * redis zset
     */
    @Test
    public void SortedSetOperate() {
        System.out.println("======================zset==========================");
        // 清空數據
        System.out.println(jedis.flushDB());

        System.out.println("=============增=============");
        System.out.println("zset中添加元素element001：" + jedis.zadd("zset", 7.0, "element001"));
        System.out.println("zset中添加元素element002：" + jedis.zadd("zset", 8.0, "element002"));
        System.out.println("zset中添加元素element003：" + jedis.zadd("zset", 2.0, "element003"));
        System.out.println("zset中添加元素element004：" + jedis.zadd("zset", 3.0, "element004"));
        System.out.println("zset集合中的全部元素：" + jedis.zrange("zset", 0, -1));//按照權重值排序
        System.out.println();

        System.out.println("=============刪=============");
        System.out.println("zset中刪除元素element002：" + jedis.zrem("zset", "element002"));
        System.out.println("zset集合中的全部元素：" + jedis.zrange("zset", 0, -1));
        System.out.println();

        System.out.println("=============改=============");
        System.out.println();

        System.out.println("=============查=============");
        System.out.println("統計zset集合中的元素中個數：" + jedis.zcard("zset"));
        System.out.println("統計zset集合中權重某個範圍內（1.0——5.0），元素的個數：" + jedis.zcount("zset", 1.0, 5.0));
        System.out.println("查看zset集合中element004的權重：" + jedis.zscore("zset", "element004"));
        System.out.println("查看下標1到2範圍內的元素值：" + jedis.zrange("zset", 1, 2));

    }


    /**
     * redis hash
     */
    @Test
    public void HashOperate() {
        System.out.println("======================hash==========================");
        //清空數據
        System.out.println(jedis.flushDB());

        System.out.println("=============增=============");
        System.out.println("hashs中添加key001和value001鍵值對：" + jedis.hset("hashs", "key001", "value001"));
        System.out.println("hashs中添加key002和value002鍵值對：" + jedis.hset("hashs", "key002", "value002"));
        System.out.println("hashs中添加key003和value003鍵值對：" + jedis.hset("hashs", "key003", "value003"));
        System.out.println("新增key004和4的整型鍵值對：" + jedis.hincrBy("hashs", "key004", 4L));
        System.out.println("hashs中的全部值：" + jedis.hvals("hashs"));
        System.out.println();

        System.out.println("=============刪=============");
        System.out.println("hashs中刪除key002鍵值對：" + jedis.hdel("hashs", "key002"));
        System.out.println("hashs中的全部值：" + jedis.hvals("hashs"));
        System.out.println();

        System.out.println("=============改=============");
        System.out.println("key004整型鍵值的值增長100：" + jedis.hincrBy("hashs", "key004", 100L));
        System.out.println("hashs中的全部值：" + jedis.hvals("hashs"));
        System.out.println();

        System.out.println("=============查=============");
        System.out.println("判斷key003是否存在：" + jedis.hexists("hashs", "key003"));
        System.out.println("獲取key004對應的值：" + jedis.hget("hashs", "key004"));
        System.out.println("批量獲取key001和key003對應的值：" + jedis.hmget("hashs", "key001", "key003"));
        System.out.println("獲取hashs中全部的key：" + jedis.hkeys("hashs"));
        System.out.println("獲取hashs中全部的value：" + jedis.hvals("hashs"));
        System.out.println();
    }


}

 

Redis 經常使用命令集

 

1）鏈接操做命令

 

• quit：關閉鏈接（connection）

• auth：簡單密碼認證

• help cmd： 查看cmd幫助，例如：help quit

2）持久化

 

• save：將數據同步保存到磁盤

• bgsave：將數據異步保存到磁盤

• lastsave：返回上次成功將數據保存到磁盤的Unix時戳

• shundown：將數據同步保存到磁盤，而後關閉服務

3）遠程服務控制

 

• info：提供服務器的信息和統計

• monitor：實時轉儲收到的請求

• slaveof：改變複製策略設置

• config：在運行時配置Redis服務器

4）對value操做的命令

 

• exists(key)：確認一個key是否存在

• del(key)：刪除一個key

• type(key)：返回值的類型

• keys(pattern)：返回知足給定pattern的全部key

• randomkey：隨機返回key空間的一個

• keyrename(oldname, newname)：重命名key

• dbsize：返回當前數據庫中key的數目

• expire：設定一個key的活動時間（s）

• ttl：得到一個key的活動時間

• select(index)：按索引查詢

• move(key, dbindex)：移動當前數據庫中的key到dbindex數據庫

• flushdb：刪除當前選擇數據庫中的全部key

• flushall：刪除全部數據庫中的全部key

5）String

 

• set(key, value)：給數據庫中名稱爲key的string賦予值value

• get(key)：返回數據庫中名稱爲key的string的value

• getset(key, value)：給名稱爲key的string賦予上一次的value

• mget(key1, key2,…, key N)：返回庫中多個string的value

• setnx(key, value)：添加string，名稱爲key，值爲value

• setex(key, time, value)：向庫中添加string，設定過時時間time

• mset(key N, value N)：批量設置多個string的值

• msetnx(key N, value N)：若是全部名稱爲key i的string都不存在

• incr(key)：名稱爲key的string增1操做

• incrby(key, integer)：名稱爲key的string增長integer

• decr(key)：名稱爲key的string減1操做

• decrby(key, integer)：名稱爲key的string減小integer

• append(key, value)：名稱爲key的string的值附加value

• substr(key, start, end)：返回名稱爲key的string的value的子串

6）List 

 

• rpush(key, value)：在名稱爲key的list尾添加一個值爲value的元素

• lpush(key, value)：在名稱爲key的list頭添加一個值爲value的 元素

• llen(key)：返回名稱爲key的list的長度

• lrange(key, start, end)：返回名稱爲key的list中start至end之間的元素

• ltrim(key, start, end)：截取名稱爲key的list

• lindex(key, index)：返回名稱爲key的list中index位置的元素

• lset(key, index, value)：給名稱爲key的list中index位置的元素賦值

• lrem(key, count, value)：刪除count個key的list中值爲value的元素

• lpop(key)：返回並刪除名稱爲key的list中的首元素

• rpop(key)：返回並刪除名稱爲key的list中的尾元素

• blpop(key1, key2,… key N, timeout)：lpop命令的block版本。

• brpop(key1, key2,… key N, timeout)：rpop的block版本。

• rpoplpush(srckey, dstkey)：返回並刪除名稱爲srckey的list的尾元素，並將該元素添加到名稱爲dstkey的list的頭部

7）Set

 

• sadd(key, member)：向名稱爲key的set中添加元素member

• srem(key, member) ：刪除名稱爲key的set中的元素member

• spop(key) ：隨機返回並刪除名稱爲key的set中一個元素

• smove(srckey, dstkey, member) ：移到集合元素

• scard(key) ：返回名稱爲key的set的基數

• sismember(key, member) ：member是不是名稱爲key的set的元素

• sinter(key1, key2,…key N) ：求交集

• sinterstore(dstkey, (keys)) ：求交集並將交集保存到dstkey的集合

• sunion(key1, (keys)) ：求並集

• sunionstore(dstkey, (keys)) ：求並集並將並集保存到dstkey的集合

• sdiff(key1, (keys)) ：求差集

• sdiffstore(dstkey, (keys)) ：求差集並將差集保存到dstkey的集合

• smembers(key) ：返回名稱爲key的set的全部元素

• srandmember(key) ：隨機返回名稱爲key的set的一個元素

8）Hash

 

• hset(key, field, value)：向名稱爲key的hash中添加元素field

• hget(key, field)：返回名稱爲key的hash中field對應的value

• hmget(key, (fields))：返回名稱爲key的hash中field i對應的value

• hmset(key, (fields))：向名稱爲key的hash中添加元素field 

• hincrby(key, field, integer)：將名稱爲key的hash中field的value增長integer

• hexists(key, field)：名稱爲key的hash中是否存在鍵爲field的域

• hdel(key, field)：刪除名稱爲key的hash中鍵爲field的域

• hlen(key)：返回名稱爲key的hash中元素個數

• hkeys(key)：返回名稱爲key的hash中全部鍵

• hvals(key)：返回名稱爲key的hash中全部鍵對應的value

• hgetall(key)：返回名稱爲key的hash中全部的鍵（field）及其對應的value

 

9） Redis 發佈訂閱命令

 

• PSUBSCRIBE pattern [pattern ...] ：訂閱一個或多個符合給定模式的頻道。

• PUBSUB subcommand [argument [argument ...]] ：查看訂閱與發佈系統狀態。

• PUBLISH channel message ：將信息發送到指定的頻道。

• PUNSUBSCRIBE [pattern [pattern ...]] ：退訂全部給定模式的頻道。

• SUBSCRIBE channel [channel ...] ：訂閱給定的一個或多個頻道的信息。

• UNSUBSCRIBE [channel [channel ...]] ：指退訂給定的頻道。

 

10） Redis 事務命令

 

• DISCARD ：取消事務，放棄執行事務塊內的全部命令。

• EXEC ：執行全部事務塊內的命令。

• MULTI ：標記一個事務塊的開始。

• UNWATCH ：取消 WATCH 命令對全部 key 的監視。

• WATCH key [key ...] ：監視一個(或多個) key ，若是在事務執行以前這個(或這些) key 被其餘命令所改動，那麼事務將被打斷。

 

11） 查看keys個數

 

• keys *      // 查看全部keys

• keys prefix_*     // 查看前綴爲"prefix_"的全部keys

 

12） 清空數據庫

 

• flushdb   // 清除當前數據庫的全部keys

• flushall    // 清除全部數據庫的全部keys        

 

參考博客：http://www.javashuo.com/article/p-orlvbtjm-md.html