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 是一个开源的基于内存的存储中间件，可以用作数据库，缓存，消息服务器。

支持很多数据结构如：字符串，哈希表，列表，集合，有序集 等...

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

如果安装不成功的话，有可能是系统还没有安装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>

百度发现解决方案如下：

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数据类型

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，不覆盖已经存在的值，要成功都成功，要失败都失败。

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值的长度

2. Hash

hset 设置一个hash 的field为指定值，如果key不存在则先创建 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数量

hdel 删除指定hash表的某个键值对

hkeys 返回hash表中所有的key

hvals 返回hash表中所有的value

hgetall 获取hash表中所有key和value

3. 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相同的元素,结果返回影响元素的个数 lrem mylist count "value"

ltrim 保留指定key范围内的数据，返回ok成功

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

lpop 从list的头部删除一个元素，并返回该删除的元素

rpop 从list的尾部弹出一个元素，并返回该删除的元素

rpoplpush 从第一个list的尾部元素异常元素并添加到第二个list的头部 rpoplpush mylistA mylistB

lindex 返回list位置的元素

llen 返回list中元素的个数

4. Sets
   sadd 向名称为key的set中添加元素，返回影响元素的个数，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 返回所有的并集并且存储到另一个集合中，返回影响的元素个数 sunionstore destSet myset1 myset2

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

scard 返回集合中元素的个数 scard myset1

sismember 测试某个元素是否在集合中，返回0是不是，大于0是存在 ismember mykey1 你好

srandmember 随机返回个集合中的元素 srandmemeber myset1

5. 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 根据排序索引的scores来返回元素 zrangebyscore myzset 1 3 withscores//

zcount 返回集合中给定区间的数量

zcount myzset 2 4 //集合中2-4索引元素的个数

zcard 返回集合中所有元素的个数 zcard myzset //返回所有元素的个数

zremrangebyrank 删除集合中排序在给定区间的所有元素(按索引删除) zremrangebyrank myzset 2 3 //

zremrangebyscore 删除集合中在给定排序区间的元素 (按顺序删除)

6. Pub/Sub

PUBLISH channel message 发布一则消息到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

官网文档

@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;
        }
    });
}