Redis學習記錄之Java中的初步使用

1.關於Redis

redis下載地址：<span style="font-family: Arial, Helvetica, sans-serif;">http://download.csdn.net/detail/he90227/8569855</span>

 

Redis是什么？兩句話可以做下概括：
1. 是一個完全開源免費的key-value內存數據庫
2. 通常被認為是一個數據結構服務器，主要是因為其有着豐富的數據結構 strings、map、 list、sets、 sorted sets


它通過提供多種鍵值數據類型來適應不同場景下的存儲需求，並借助許多高層級的接口使其可以勝任如緩存、隊列系統等不同的角色
和Memcached類似，但是解決了斷電后數據完全丟失的情況，而且她支持更多無化的value類型，除了和string外，
還支持lists（鏈表）、sets（集合）和zsets（有序集合）幾種數據類型。這些數據類型都支持push/pop、add/remove及取交集並集和差集及更豐富的操作，而且這些操作都是原子性的


2.支持的數據類型
            字符串類型    string
            散列類型         Hash
            鏈表表類型     lists
            集合類型          sets
            有序集合類型  zsets

說明：
     string是最簡單的類型，你可以理解成與Memcached一模一個的類型，一個key對應一個value，其上支持的操作與Memcached的操作類似。但它的功能更豐富。
     list是一個鏈表結構，主要功能是push、pop、獲取一個范圍的所有值等等。操作中key理解為鏈表的名字。
     set是集合，和我們數學中的集合概念相似，對集合的操作有添加刪除元素，有對多個集合求交並差等操作。操作中key理解為集合的名字。
     zset是set的一個升級版本，他在set的基礎上增加了一個順序屬性，這一屬性在添加修改元素的時候可以指定，每次指定后，zset會自動重新按新的值調整順序。可以理解了有兩列的mysql表，一列存value，一列存順序。操作中key理解為zset的名字。
     Hash數據類型允許用戶用Redis存儲對象類型,Hash數據類型的一個重要優點是,當你存儲的數據對象只有很少幾個key值時,數據存儲的內存消耗會很小.



3.內存存儲於持久化

    Redis數據庫中的所有數據都存儲在內存中，同時提供了對持久化的支持，即：可以將內存中的數據異步寫入硬盤中，同時不會影響繼續提供服務


redis主從配置

redis支持master-slave的主從配置，配置方法是在從機的配置文件中指定slaveof參數為主機的ip和port即可


4. Redis VS  Memcached

   1.都可以做為緩存系統使用
   2.性能上Redis是單線程模型，Memcached支持多線程，所有在多核服務器上后者的性能更高一些
   3.Redis支持高級的數據類型和持久化等功能
   4.存儲方式方面：Memcached只支持簡單的key-value存儲，不支持枚舉，不支持持久化和復制等功能


5.安裝Redis  -- Redis官方僅支持 Linux、Unix和OS X，不支持Windows


Linux下安裝：  wget或拷貝到指定目錄下    ---  解壓后在src目錄下使用macke命令完成編譯


wget http://download.redis.io/redis-stable.tar.gz
tar xzf redis-stable.tar.gz
cd redis-stable
make


需要說明的事，redis的安裝非常簡單，已經有現成的Makefile文件，直接運行make命令即可。

make

make install


Redis 由四個可執行文件：redis-benchmark、redis-cli、redis-server、redis-stat 這四個文件，加上一個redis.conf就構成了整個redis的最終可用包。它們的作用如下：


redis-server：Redis服務器的daemon啟動程序
redis-cli：Redis命令行操作工具。當然，你也可以用telnet根據其純文本協議來操作
redis-benchmark：Redis性能測試工具，測試Redis在你的系統及你的配置下的讀寫性能
redis-stat：Redis狀態檢測工具，可以檢測Redis當前狀態參數及延遲狀況


6.啟動和停止Redis


編譯后生成的可執行文件
     redis-server                 ----  Redis 服務器
     redis-cli                    ----  Redis命令行客戶端



redis-server   是Redis的服務器，啟動Redis即運行redis-server
redis-cli      是Redis自帶的Redis命令行客戶端，學習Redis的重要工具




啟動Redis
       1.直接啟動      -- 運行redis-server即可啟動redis
                     注意：
           Redis服務器默認會使用6379端口，通過--port參數可以自定義使用的端口號
           eg:
               redis-server --port 6380

停止Redis


       redis-cli shutdown


Redis有可能正在將內存中的數據同步到硬盤中，強行終止Redis進程可能會導致數據丟失，正確的做法是向Redis發送shutdown命令
當Redis收到shutdown命令后，會先斷開所有客戶端連接，然后根據配置執行持久化，最后完成退出

 

2.Redis配置和常用命令

1.Redis配置

redis.conf配置文件：
引用
#是否作為守護進程運行
daemonize yes
#配置pid的存放路徑及文件名，默認為當前路徑下
pidfile redis.pid
#Redis默認監聽端口
port 6379
#客戶端閑置多少秒后，斷開連接
timeout 300
#日志顯示級別
loglevel verbose
#指定日志輸出的文件名，也可指定到標准輸出端口
logfile stdout
#設置數據庫的數量，默認連接的數據庫是0，可以通過select N來連接不同的數據庫
databases 16
#保存數據到disk的策略
#當有一條Keys數據被改變是，900秒刷新到disk一次
save 900 1
#當有10條Keys數據被改變時，300秒刷新到disk一次
save 300 10
#當有1w條keys數據被改變時，60秒刷新到disk一次
save 60 10000
#當dump  .rdb數據庫的時候是否壓縮數據對象
rdbcompression yes
#dump數據庫的數據保存的文件名
dbfilename dump.rdb
#Redis的工作目錄
dir /home/falcon/redis-2.0.0/
###########  Replication #####################
#Redis的復制配置
# slaveof <masterip> <masterport>
# masterauth <master-password>

############## SECURITY ###########
# requirepass foobared

############### LIMITS ##############
#最大客戶端連接數
# maxclients 128
#最大內存使用率
# maxmemory <bytes>

########## APPEND ONLY MODE #########
#是否開啟日志功能
appendonly no
# 刷新日志到disk的規則
# appendfsync always
appendfsync everysec
# appendfsync no
################ VIRTUAL MEMORY ###########
#是否開啟VM功能
vm-enabled no
# vm-enabled yes
vm-swap-file logs/redis.swap
vm-max-memory 0
vm-page-size 32
vm-pages 134217728
vm-max-threads 4
############# ADVANCED CONFIG ###############
glueoutputbuf yes
hash-max-zipmap-entries 64
hash-max-zipmap-value 512
#是否重置Hash表
activerehashing yes

 

常規操作命令

01  exits key              //測試指定key是否存在，返回1表示存在，0不存在
02  del key1 key2 ....keyN //刪除給定key,返回刪除key的數目，0表示給定key都不存在
03  type key               //返回給定key的value類型。返回 none 表示不存在key,string字符類型，list 鏈表類型 set 無序集合類型...
04  keys pattern           //返回匹配指定模式的所有key,下面給個例子
05  randomkey              //返回從當前數據庫中隨機選擇的一個key,如果當前數據庫是空的，返回空串
06  rename oldkey newkey   //原子的重命名一個key,如果newkey存在，將會被覆蓋，返回1表示成功，0失敗。可能是oldkey不存在或者和newkey相同
07  renamenx oldkey newkey //同上，但是如果newkey存在返回失敗
08  dbsize                 //返回當前數據庫的key數量
09  expire key seconds     //為key指定過期時間，單位是秒。返回1成功，0表示key已經設置過過期時間或者不存在
10  ttl key                //返回設置過過期時間的key的剩余過期秒數 -1表示key不存在或者沒有設置過過期時間
11  select db-index        //通過索引選擇數據庫，默認連接的數據庫所有是0,默認數據庫數是16個。返回1表示成功，0失敗
12  move key db-index      //將key從當前數據庫移動到指定數據庫。返回1成功。0 如果key不存在，或者已經在指定數據庫中
13  flushdb                //刪除當前數據庫中所有key,此方法不會失敗。慎用
14  flushall               //刪除所有數據庫中的所有key，此方法不會失敗。更加慎用
string 類型數據操作命令

01  set key value         //設置key對應的值為string類型的value,返回1表示成功，0失敗
02  setnx key value       //同上，如果key已經存在，返回0 。nx 是not exist的意思
03  get key               //獲取key對應的string值,如果key不存在返回nil
04  getset key value      //原子的設置key的值，並返回key的舊值。如果key不存在返回nil
05  mget key1 key2 ... keyN            //一次獲取多個key的值，如果對應key不存在，則對應返回nil。下面是個實驗,首先清空當前數據庫，然后設置k1,k2.獲取時k3對應返回nil
06  mset key1 value1 ... keyN valueN   //一次設置多個key的值，成功返回1表示所有的值都設置了，失敗返回0表示沒有任何值被設置
07  msetnx key1 value1 ... keyN valueN //同上，但是不會覆蓋已經存在的key
08  incr key              //對key的值做加加操作,並返回新的值。注意incr一個不是int的value會返回錯誤，incr一個不存在的key，則設置key為1
09  decr key              //同上，但是做的是減減操作，decr一個不存在key，則設置key為-1
10  incrby key integer    //同incr，加指定值 ，key不存在時候會設置key，並認為原來的value是 0
11  decrby key integer    //同decr，減指定值。decrby完全是為了可讀性，我們完全可以通過incrby一個負值來實現同樣效果，反之一樣。
12  append key value      //給指定key的字符串值追加value,返回新字符串值的長度。下面給個例子
13  substr key start end  //返回截取過的key的字符串值,注意並不修改key的值。下標是從0開始的，接着上面例子
list 類型數據操作命令

01  lpush key string          //在key對應list的頭部添加字符串元素，返回1表示成功，0表示key存在且不是list類型
02  rpush key string          //同上，在尾部添加
03  llen key                  //返回key對應list的長度，key不存在返回0,如果key對應類型不是list返回錯誤
04  lrange key start end      //返回指定區間內的元素，下標從0開始，負值表示從后面計算，-1表示倒數第一個元素 ，key不存在返回空列表
05  ltrim key start end       //截取list，保留指定區間內元素，成功返回1，key不存在返回錯誤
06  lset key index value      //設置list中指定下標的元素值，成功返回1，key或者下標不存在返回錯誤
07  lrem key count value      //從key對應list中刪除count個和value相同的元素。count為0時候刪除全部
08  lpop key                  //從list的頭部刪除元素，並返回刪除元素。如果key對應list不存在或者是空返回nil，如果key對應值不是list返回錯誤
09  rpop                      //同上，但是從尾部刪除
10  blpop key1...keyN timeout //從左到右掃描返回對第一個非空list進行lpop操作並返回，比如blpop list1 list2 list3 0 ,如果list不存在list2,list3都是非空則對list2做lpop並返回從list2中刪除的元素。如果所有的list都是空或不存在，則會阻塞timeout秒，timeout為0表示一直阻塞。當阻塞時，如果有client對key1...keyN中的任意key進行push操作，則第一在這個key上被阻塞的client會立即返回。如果超時發生，則返回nil。有點像unix的select或者poll
11  brpop                     //同blpop，一個是從頭部刪除一個是從尾部刪除
12  rpoplpush srckey destkey  //從srckey對應list的尾部移除元素並添加到destkey對應list的頭部,最后返回被移除的元素值，整個操作是原子的.如果srckey是空或者不存在返回nil
set 類型數據操作命令

01  sadd key member                //添加一個string元素到,key對應的set集合中，成功返回1,如果元素以及在集合中返回0,key對應的set不存在返回錯誤
02  srem key member                //從key對應set中移除給定元素，成功返回1，如果member在集合中不存在或者key不存在返回0，如果key對應的不是set類型的值返回錯誤
03  spop key                       //刪除並返回key對應set中隨機的一個元素,如果set是空或者key不存在返回nil
04  srandmember key                //同spop，隨機取set中的一個元素，但是不刪除元素
05  smove srckey dstkey member     //從srckey對應set中移除member並添加到dstkey對應set中，整個操作是原子的。成功返回1,如果member在srckey中不存在返回0，如果key不是set類型返回錯誤
06  scard key                      //返回set的元素個數，如果set是空或者key不存在返回0
07  sismember key member           //判斷member是否在set中，存在返回1，0表示不存在或者key不存在
08  sinter key1 key2...keyN        //返回所有給定key的交集
09  sinterstore dstkey key1...keyN //同sinter，但是會同時將交集存到dstkey下
10  sunion key1 key2...keyN        //返回所有給定key的並集
11  sunionstore dstkey key1...keyN //同sunion，並同時保存並集到dstkey下
12  sdiff key1 key2...keyN         //返回所有給定key的差集
13  sdiffstore dstkey key1...keyN  //同sdiff，並同時保存差集到dstkey下
14  smembers key                   //返回key對應set的所有元素，結果是無序的
sorted set 類型數據操作命令

01  zadd key score member        //添加元素到集合，元素在集合中存在則更新對應score
02  zrem key member              //刪除指定元素，1表示成功，如果元素不存在返回0
03  zincrby key incr member      //增加對應member的score值，然后移動元素並保持skip list保持有序。返回更新后的score值
04  zrank key member             //返回指定元素在集合中的排名（下標）,集合中元素是按score從小到大排序的
05  zrevrank key member          //同上,但是集合中元素是按score從大到小排序
06  zrange key start end         //類似lrange操作從集合中去指定區間的元素。返回的是有序結果
07  zrevrange key start end      //同上，返回結果是按score逆序的
08  zrangebyscore key min max    //返回集合中score在給定區間的元素
09  zcount key min max           //返回集合中score在給定區間的數量
10  zcard key                    //返回集合中元素個數
11  zscore key element           //返回給定元素對應的score
12  zremrangebyrank key min max  //刪除集合中排名在給定區間的元素
13  zremrangebyscore key min max //刪除集合中score在給定區間的元素
hash 類型數據操作命令

01  hset key field value       //設置hash field為指定值，如果key不存在，則先創建
02  hget key field             //獲取指定的hash field
03  hmget key filed1....fieldN //獲取全部指定的hash filed
04  hmset key filed1 value1 ... filedN valueN //同時設置hash的多個field
05  hincrby key field integer  //將指定的hash filed 加上給定值
06  hexists key field          //測試指定field是否存在
07  hdel key field             //刪除指定的hash field
08  hlen key                   //返回指定hash的field數量
09  hkeys key                  //返回hash的所有field
10  hvals key                  //返回hash的所有value
11  hgetall                    //返回hash的所有filed和value

3.redis在Java中的使用

1.maven依賴：

 

<!-- Redis依賴 -->
<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>2.7.0</version>
</dependency>

<!-- Spring整合Redis依賴 -->
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
    <version>1.5.0.RELEASE</version>
</dependency>

2.客戶端實例

 

properties文件基本配置
redis.pool.maxActive=100
redis.pool.maxIdle=20
redis.pool.maxWait=3000
redis.ip=localhost
redis.port=6379

import java.util.ResourceBundle;

import com.alibaba.fastjson.JSON;

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

public class RedisClient {

    public  static  JedisPool jedisPool; // 池化管理jedis鏈接池

      static {

        //讀取相關的配置
        ResourceBundle resourceBundle = ResourceBundle.getBundle("redis");
        int maxActive = Integer.parseInt(resourceBundle.getString("redis.pool.maxActive"));
        int maxIdle = Integer.parseInt(resourceBundle.getString("redis.pool.maxIdle"));
        int maxWait = Integer.parseInt(resourceBundle.getString("redis.pool.maxWait"));

        String ip = resourceBundle.getString("redis.ip");
        int port = Integer.parseInt(resourceBundle.getString("redis.port"));

        JedisPoolConfig config = new JedisPoolConfig();
        //設置最大連接數
        config.setMaxTotal(maxActive);
        //設置最大空閑數
        config.setMaxIdle(maxIdle);
        //設置超時時間
        config.setMaxWaitMillis(maxWait);

        //初始化連接池
        jedisPool = new JedisPool(config, ip, port);
      }

      /**
       * 向緩存中設置字符串內容
       * @param key key
       * @param value value
       * @return
       * @throws Exception
       */
      public static boolean  set(String key,String value) throws Exception{
        Jedis jedis = null;
        try {
          jedis = jedisPool.getResource();
          jedis.set(key, value);
          return true;
        } catch (Exception e) {
          e.printStackTrace();
          return false;
        }finally{
          jedisPool.returnResource(jedis);
        }
      }

      /**
       * 向緩存中設置對象
       * @param key
       * @param value
       * @return
       */
      public static boolean  set(String key,Object value){
        Jedis jedis = null;
        try {
          String objectJson = JSON.toJSONString(value);
          jedis = jedisPool.getResource();
          jedis.set(key, objectJson);
          return true;
        } catch (Exception e) {
          e.printStackTrace();
          return false;
        }finally{
          jedisPool.returnResource(jedis);
        }
      }

      /**
       * 刪除緩存中得對象，根據key
       * @param key
       * @return
       */
      public static boolean del(String key){
        Jedis jedis = null;
        try {
          jedis = jedisPool.getResource();
          jedis.del(key);
          return true;
        } catch (Exception e) {
          e.printStackTrace();
          return false;
        }finally{
          jedisPool.returnResource(jedis);
        }
      }

      /**
       * 根據key 獲取內容
       * @param key
       * @return
       */
      public static Object get(String key){
        Jedis jedis = null;
        try {
          jedis = jedisPool.getResource();
          Object value = jedis.get(key);
          return value;
        } catch (Exception e) {
          e.printStackTrace();
          return false;
        }finally{
          jedisPool.returnResource(jedis);
        }
      }


      /**
       * 根據key 獲取對象
       * @param key
       * @return
       */
      public static <T> T get(String key,Class<T> clazz){
        Jedis jedis = null;
        try {
          jedis = jedisPool.getResource();
          String value = jedis.get(key);
          return JSON.parseObject(value, clazz);
        } catch (Exception e) {
          e.printStackTrace();
          return null;
        }finally{
          jedisPool.returnResource(jedis);
        }
      }

//  private Jedis jedis;  //非切片的客戶端連接
//  private JedisPool jedisPool; //非切片連接池
//  private ShardedJedis shardedJedis; //切片的數據庫連接
//  private ShardedJedisPool shardedJedisPool; // 切片連接池
//
//  public RedisClient() {
//      initialPool();
//      initialShardedPool();
//      shardedJedis = shardedJedisPool.getResource();
//      jedis = jedisPool.getResource();
//  }
//
//  /*
//   * 初始化非切片池
//   */
//  private void initialPool() {
//      //池基本配置
//      JedisPoolConfig config = new JedisPoolConfig();
//      config.setMaxIdle(5);
//      config.set
//  }
//
//  private void initialShardedPool() {
//      shardedJedisPool
//
//  }

}

測試代碼
package com.jay.demo6.redis.test;

import org.junit.Test;

public class RedisDemoTest {

    /*
     * 向Redis中添加需要緩存的數據
     */
    @Test
    public void setUserCache() {
        // 向緩沖中添加保存對象
        UserDO user1 = new UserDO();
        user1.setId(1111);
        user1.setSex(true);
        user1.setPhone("1783797435");
        user1.setEmail("[e-mail]");

        // 調用方法處理
        boolean resultCache = RedisClient.set("user1", user1);
        if (resultCache) {
            System.out.println("向緩存中保存對象成功。");
        } else {
            System.out.println("向緩存中保存對象失敗。");
        }
    }

    /*
     *從Reids中獲取緩存的數據
     */
    @Test
    public void getUserCahce(){
        UserDO user1 = RedisClient.get("user1",UserDO.class);
        if(user1!=null){
            System.out.println(user1.toString());
        }
    }
}

</pre><pre code_snippet_id="637583" snippet_file_name="blog_20150407_12_3514709" name="code" class="html">package com.jay.demo6.redis.test;


public class UserDO {
    private int id;
    private boolean sex;
    private String name;
    private String phone;
    private String email;


    public UserDO() {
        super();
    }


    public int getId() {
        return id;
    }


    public void setId(int id) {
        this.id = id;
    }


    public boolean isSex() {
        return sex;
    }


    public void setSex(boolean sex) {
        this.sex = sex;
    }


    public String getName() {
        return name;
    }


    public void setName(String name) {
        this.name = name;
    }


    public String getPhone() {
        return phone;
    }


    public void setPhone(String phone) {
        this.phone = phone;
    }


    public String getEmail() {
        return email;
    }


    public void setEmail(String email) {
        this.email = email;
    }


    @Override
    public String toString() {
        return "UserDO [id=" + id + ", sex=" + (sex?"男":"女") + ", name=" + name
                + ", phone=" + phone + ", email=" + email + "]";
    }
}