Redis 入門

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 是一個開源的基于內存的存儲中間件，可以用作數(shù)據(jù)庫，緩存，消息服務器。

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

Redis 內置支持了 復制，Lua腳本，XXX , 事務，不同級別的持久化，提供高可用的Sentinel機制，自動分片的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

我安裝的時候還遇到了另一個原因

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

運行

$ 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 設置key對應的的值為String類型的value

get 獲取對應key對應的String的值，如果不存在返回nil

setnx 設置可以為對應的值為String類型的value，如果key存在返回0不覆蓋，不存在返回1

setex 置key對應的值為String類型的value，并指定此鍵值對應的有效期

setrange 設置key的value的子字符串

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

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

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

getset 設置key的值并返回key的舊值 etset key newValuse

getrange 獲取key對應的value子字符串

getrange key 0 5 //獲取前6個字符

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

incr 對key的值做增加操作,并返回新的值

incrby 對可以的value加指定的值，

key如果不存在會設置key并value為0

incrby key1 5 //對key1的值加5

decr 對key的值做減減操作 -1

decrby 對key的值減去指定值

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

strlen 取指定key的value值的長度

  1. Hash

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

hget 獲取某個hash的某個field值 hget tab ke1

hsetnx 類似string只是操作的是hash

hmset 批量設置hash的內容

hmget 獲取hash表的全部key值

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

hexists 判斷hash表中某個key是否存在

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

hdel 刪除指定hash表的某個鍵值對

hkeys 返回hash表中所有的key

hvals 返回hash表中所有的value

hgetall 獲取hash表中所有key和value

  1. Lists
    lpush 在key所對應的list頭部添加一個元素

rpush 在key說對應的list尾部添加一個元素

lrange 顯示list里面的內容 lrange 0 -1 //全部顯示

linsert 在key對應的list linsert mylist before one myvalue

lset 設置list中指定下標元素的值 lset mylist index myvalue

lrem 從key對應的list中刪除n個和value相同的元素,結果返回影響元素的個數(shù) lrem mylist count "value"

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

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

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

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

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

lindex 返回list位置的元素

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

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

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

srem 刪除集合的一個元素

spop 隨機返回并刪除set中一個元素

spop myset

sdiff 返回所有set與第一個set的差集 sdiff myset1 myset2

sdiffstore 比較差集并且存儲到另一個set中，返回1代表成功

sdiffstore setstoreSet mySet1 myset2

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

sinterstore 返回給定集合的交集并存儲到另一個集合 sinterstore desset myset1 myset2 //存到desset集合中

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

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

smove 把第一個集合的元素移動到第二個集合中 smove myset myset 你好

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

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

srandmember 隨機返回個集合中的元素 srandmemeber myset1

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

zrange 取出集合中的元素 zrange myset 0 -1 withscores//顯示序號 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索引元素的個數(shù)

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

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

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

  1. Pub/Sub

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

SUBSCRIBE channel 訂閱某個頻道

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個事務
    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;
        }
    });
}
最后編輯于 ：
?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成，瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明：文章內容（如有圖片或視頻亦包括在內）由作者上傳并發(fā)布，文章內容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容