Redis 入門

Redis is an open source (BSD licensed), in-memory data structure store, used as a database, cache and message broker. 
It supports data structures such as strings, hashes, lists, sets, sorted sets with range queries, bitmaps, hyperloglogs and geospatial indexes with radius queries. 
Redis has built-in replication, Lua scripting, LRU eviction, transactions and different levels of on-disk persistence, and provides high availability via Redis Sentinel and automatic partitioning with Redis Cluster.

Redis 是一個(gè)開源的基于內(nèi)存的存儲(chǔ)中間件，可以用作數(shù)據(jù)庫，緩存，消息服務(wù)器。

支持很多數(shù)據(jù)結(jié)構(gòu)如：字符串，哈希表，列表，集合，有序集 等...

Redis 內(nèi)置支持了 復(fù)制，Lua腳本，XXX , 事務(wù)，不同級(jí)別的持久化，提供高可用的Sentinel機(jī)制，自動(dòng)分片的Redis集群

下載 安裝

$ wget http://download.redis.io/releases/redis-3.2.9.tar.gz
$ tar xzf redis-3.2.9.tar.gz
$ cd redis-3.2.9
$ make

如果安裝不成功的話，有可能是系統(tǒng)還沒有安裝c++的編譯器， 在Linux是GCC。
直接yum -y install gcc 安裝GCC

我安裝的時(shí)候還遇到了另一個(gè)原因

In file included from adlist.c:34:0:
zmalloc.h:50:31: fatal error: jemalloc/jemalloc.h: No such file or directory
#include <jemalloc/jemalloc.h>

百度發(fā)現(xiàn)解決方案如下：

make MALLOC=libc

運(yùn)行

$ cd src
$ ./redis-server
$ ./redis-cli


127.0.0.1:6379> set hello world
OK
127.0.0.1:6379> get hello
"world"
127.0.0.1:6379> set hello world2
OK
127.0.0.1:6379> get hello
"world2"
127.0.0.1:6379> del hello
(integer) 1
127.0.0.1:6379> get hello
(nil)

Redis數(shù)據(jù)類型

1. String

set 設(shè)置key對(duì)應(yīng)的的值為String類型的value

get 獲取對(duì)應(yīng)key對(duì)應(yīng)的String的值，如果不存在返回nil

setnx 設(shè)置可以為對(duì)應(yīng)的值為String類型的value，如果key存在返回0不覆蓋，不存在返回1

setex 置key對(duì)應(yīng)的值為String類型的value，并指定此鍵值對(duì)應(yīng)的有效期

setrange 設(shè)置key的value的子字符串

setrange key 位置 替換的內(nèi)容 如果替換內(nèi)容沒有原value長,則原value剩余的內(nèi)容將被保留

mset 一次設(shè)置多個(gè)key的值，成功返回ok，失敗返回0，要成功都成功，要不成功全部失敗。

msetnx 一次設(shè)置多個(gè)key的值，成功返回ok，失敗返回0，不覆蓋已經(jīng)存在的值，要成功都成功，要失敗都失敗。

getset 設(shè)置key的值并返回key的舊值 etset key newValuse

getrange 獲取key對(duì)應(yīng)的value子字符串

getrange key 0 5 //獲取前6個(gè)字符

mget 批量獲取 mget key1 key2 key3 //沒有設(shè)置則返回空

incr 對(duì)key的值做增加操作,并返回新的值

incrby 對(duì)可以的value加指定的值，

key如果不存在會(huì)設(shè)置key并value為0

incrby key1 5 //對(duì)key1的值加5

decr 對(duì)key的值做減減操作 -1

decrby 對(duì)key的值減去指定值

append 給指定key的字符串追加value，返回新的字符串長度

strlen 取指定key的value值的長度

2. Hash

hset 設(shè)置一個(gè)hash 的field為指定值，如果key不存在則先創(chuàng)建 hset tab ke1 val1

hget 獲取某個(gè)hash的某個(gè)field值 hget tab ke1

hsetnx 類似string只是操作的是hash

hmset 批量設(shè)置hash的內(nèi)容

hmget 獲取hash表的全部key值

Hmget key field1 field2 hincrby 給hash表的某個(gè)字段增加值

hexists 判斷hash表中某個(gè)key是否存在

hlen 返回hash表中的key數(shù)量

hdel 刪除指定hash表的某個(gè)鍵值對(duì)

hkeys 返回hash表中所有的key

hvals 返回hash表中所有的value

hgetall 獲取hash表中所有key和value

3. Lists
   lpush 在key所對(duì)應(yīng)的list頭部添加一個(gè)元素

rpush 在key說對(duì)應(yīng)的list尾部添加一個(gè)元素

lrange 顯示list里面的內(nèi)容 lrange 0 -1 //全部顯示

linsert 在key對(duì)應(yīng)的list linsert mylist before one myvalue

lset 設(shè)置list中指定下標(biāo)元素的值 lset mylist index myvalue

lrem 從key對(duì)應(yīng)的list中刪除n個(gè)和value相同的元素,結(jié)果返回影響元素的個(gè)數(shù) lrem mylist count "value"

ltrim 保留指定key范圍內(nèi)的數(shù)據(jù)，返回ok成功

ltrim mylist 0 3 //0-3是保留的范圍

lpop 從list的頭部刪除一個(gè)元素，并返回該刪除的元素

rpop 從list的尾部彈出一個(gè)元素，并返回該刪除的元素

rpoplpush 從第一個(gè)list的尾部元素異常元素并添加到第二個(gè)list的頭部 rpoplpush mylistA mylistB

lindex 返回list位置的元素

llen 返回list中元素的個(gè)數(shù)

4. Sets
   sadd 向名稱為key的set中添加元素，返回影響元素的個(gè)數(shù)，0為失敗，1為成功 sadd myset value

smembers 查看集合中所有的成員 smebers myset

srem 刪除集合的一個(gè)元素

spop 隨機(jī)返回并刪除set中一個(gè)元素

spop myset

sdiff 返回所有set與第一個(gè)set的差集 sdiff myset1 myset2

sdiffstore 比較差集并且存儲(chǔ)到另一個(gè)set中，返回1代表成功

sdiffstore setstoreSet mySet1 myset2

sinter 返回所有給定集合的交集 sinter myset1 mysert2 //1集合和2集合的交集

sinterstore 返回給定集合的交集并存儲(chǔ)到另一個(gè)集合 sinterstore desset myset1 myset2 //存到desset集合中

sunion 返回所有給定集合的并集 sunion set1 set2

sunionstore 返回所有的并集并且存儲(chǔ)到另一個(gè)集合中，返回影響的元素個(gè)數(shù) sunionstore destSet myset1 myset2

smove 把第一個(gè)集合的元素移動(dòng)到第二個(gè)集合中 smove myset myset 你好

scard 返回集合中元素的個(gè)數(shù) scard myset1

sismember 測(cè)試某個(gè)元素是否在集合中，返回0是不是，大于0是存在 ismember mykey1 你好

srandmember 隨機(jī)返回個(gè)集合中的元素 srandmemeber myset1

5. Sorted Sets
   zadd 向zset中添加元素

zrange 取出集合中的元素 zrange myset 0 -1 withscores//顯示序號(hào) by index

zrem 刪除名稱為key的zset中的元素member zrem myset itim

zincrby 修改元素的排序，如果元素不存在則添加該元素，且排序的score值為增加值 zincrby myzset score itim

zrank 返回元素在集合中的排序位置，就是索引值 zrank myzset itim //itim在集合中的位置

zrevrank 返回從大到小的排序索引值，就是逆序位置 zrevrangk myzset itim//逆序的位置

zrevrange 返回集合中從大到小排序（降序）的，索引start到end的所有元素 zrevrange myzset 0 -1 //逆序后的元素

zrangebyscore 根據(jù)排序索引的scores來返回元素 zrangebyscore myzset 1 3 withscores//

zcount 返回集合中給定區(qū)間的數(shù)量

zcount myzset 2 4 //集合中2-4索引元素的個(gè)數(shù)

zcard 返回集合中所有元素的個(gè)數(shù) zcard myzset //返回所有元素的個(gè)數(shù)

zremrangebyrank 刪除集合中排序在給定區(qū)間的所有元素(按索引刪除) zremrangebyrank myzset 2 3 //

zremrangebyscore 刪除集合中在給定排序區(qū)間的元素 (按順序刪除)

6. Pub/Sub

PUBLISH channel message 發(fā)布一則消息到channel

SUBSCRIBE channel 訂閱某個(gè)頻道

Java客戶端 Jedis

@Test
public void testJedis(){
    try (Jedis jedis = new Jedis("123.207.229.137",6379)){
        //set string normally
        jedis.set("jedis","redis.client");
        System.out.println(jedis.get("jedis"));
        //set string expire
        jedis.setex("jedis.ex",30,"redis.client");
        System.out.println(jedis.get("jedis.ex"));
        //hash (map)
        jedis.hset("hash","name","jiangjiaze");
        jedis.hset("hash","age","12");
        System.out.println(jedis.hgetAll("hash"));
        //set
        jedis.sadd("set","a");
        jedis.sadd("set","b","c");
        System.out.println(jedis.srandmember("set"));
        //list
        jedis.lpush("list","l1","l2","l3");
        System.out.println(jedis.lrange("list",0,10));
        //number
        jedis.set("number","1");
        jedis.incr("number");
        System.out.println(jedis.get("number"));
        //sorted sets , can add a map into
        jedis.zadd("sorted sets",90,"kong");
        jedis.zadd("sorted sets",98,"kong");
        jedis.zadd("sorted sets",98,"fancy");
        System.out.println(jedis.zrange("sorted sets",0,10));
        //publish
        jedis.pubsubChannels("chat");
        jedis.publish("chat","hello subscriber");
        jedis.publish("chat","how old are you");
        //receive
        jedis.subscribe(new JedisPubSub() {
            @Override
            public void onMessage(String channel, String message) {
                System.out.println(channel+""+message);
            }
        },"chat");
    }
}

@Test
public void testRedisTransaction() throws InterruptedException {
    //100個(gè)事務(wù)
    try (Jedis jedis = new Jedis("123.207.229.137",6379)){
        for (int j = 0; j < 100; j++) {
            jedis.watch("number");
            try (Transaction transaction = jedis.multi()){
                Thread.sleep(300);
                transaction.incrBy("number",1);
                System.out.println(transaction.exec().get(0));
            } catch (IOException e) {
                e.printStackTrace();
            }finally {
                jedis.unwatch();
            }
        }
    }
    Thread.currentThread().join();
}

@Test
public void testPipeline(){
    long start = System.currentTimeMillis();
    try(Jedis jedis = new Jedis("123.207.229.137",6379)){
        Pipeline pipeline = jedis.pipelined();
        for (int i = 0; i < 10000; i++) {
            pipeline.set("key"+i,"value");
        }
        pipeline.sync();
        jedis.flushDB();
    }
    System.out.println(System.currentTimeMillis()-start);//183
    start = System.currentTimeMillis();
    try(Jedis jedis = new Jedis("123.207.229.137",6379)){
        for (int i = 0; i < 10000; i++) {
            jedis.set("key"+i,"value");
        }
        jedis.flushDB();
    }
    System.out.println(System.currentTimeMillis()-start);//64212
}

@Test
public void testJedisPool() throws IOException {
    GenericObjectPoolConfig config = new GenericObjectPoolConfig();
    config.setMaxIdle(2);
    config.setMinIdle(1);
    config.setMaxTotal(2);
    config.setMaxWaitMillis(2000);
    JedisPool jedisPool = new JedisPool(config,"123.207.229.137",6379);
    Jedis jedis = jedisPool.getResource();
    jedis.close();
}

Spring支持 Spring Data Redis

官網(wǎng)文檔

@Value("${spring.redis.host}")
private String hostName;

@Bean
public JedisConnectionFactory jedisConnectionFactory(){
    JedisConnectionFactory factory = new JedisConnectionFactory();
    factory.setHostName(hostName);
    factory.setPort(6379);
    factory.setUsePool(true);
    return factory;
}

@Bean
public RedisTemplate<?,?> listOperations(){
    RedisTemplate<?,?> redisTemplate = new RedisTemplate<>();
    redisTemplate.setConnectionFactory(jedisConnectionFactory());
    return redisTemplate;
}

@Test
public void testSpring(){
    redisTemplate.executePipelined(new RedisCallback<String>() {
        @Override
        public String doInRedis(RedisConnection redisConnection) throws DataAccessException {
            redisConnection.set("keykey".getBytes(),"value".getBytes());
            return null;
        }
    });
}