redis入门到精通 / 憋错料

redis3.2.8学习

(1)redis安装及简单测试

官网地址为：https://redis.io/download

$ wget http://download.redis.io/releases/redis-3.2.8.tar.gz

$ tar xzf redis-3.2.8.tar.gz

$ cd redis-3.2.8

$ make

启动服务

$ src/redis-server

redis-server /root/soft/redis/sbin/redis.conf &

查看进程

ps -ef | grep 6379

交互式命令

$ src/redis-cli

redis> set foo bar

redis> get foo

"bar"

bgsave 命令持久化数据到磁盘

或者

[[email protected] redis]# redis-cli set id 1

[[email protected] redis]# redis-cli get id

"1"

redis-cli -h 192.168.175.29 -p 6379

(2)redis.conf配置文件解读(重要参数)

#bind 127.0.0.1

关闭保护模式远程可以连接

protected-mode no

port 6379

日志隔离级别

loglevel notice

#log文件名称

logfile "mylog.txt"

默认数据库个数

databases 16

# In the example below the behaviour will be to save:

# after 900 sec (15 min) if at least 1 key changed

# after 300 sec (5 min) if at least 10 keys changed

# after 60 sec if at least 10000 keys changed

快照

save 900 1

save 300 10

save 60 10000

#DB文件名字

# The filename where to dump the DB

dbfilename dump.rdb

#目录

# Note that you must specify a directory here, not a file name.

dir /root/soft/redis/sbin/db

(3)String 结构

中文网学习地址 http://www.redis.cn/commands.html#string

一：String 结构

Java String

C# String => char[]的封装。。。

Redis C语言实现 char[] 进行了封装。。。 append,length,substring，set，get。。。。setrange => replace...

二：最常用命令。。。

官网学习地址 http://www.redis.cn/documentation.html 翻译比较全，比较新

《1》 set/get 命令 [对string进行赋值] 时间复杂度：O(1)

SET key value [EX seconds] [PX milliseconds] [NX|XX]

GET key 【nil】 =>lua

应用场景分布式锁。。。。【zookeeper】相对来说重量级。

通过对username的赋值的返回值来判断是否获取到了一个分布式锁。。。

set username jack NX =》如果返回ok，说明获得到了锁。。。

set username mary NX =》如果返回nil，说明没有获取到锁。。。

《2》 Incr,Decr, =>自增或者自减1 【 i++, i-- 】

127.0.0.1:6379> set mykey "10"

127.0.0.1:6379> object encoding mykey

"int"

127.0.0.1:6379>

127.0.0.1:6379> incr mykey

(integer) 11

127.0.0.1:6379> get mykey

"11"

127.0.0.1:6379> get mykey

"11"

127.0.0.1:6379>

127.0.0.1:6379> decr mykey

(integer) 10

127.0.0.1:6379> get mykey

"10"

IncrBy，DecrBy =>自增或者自减去指定的值【 i=i + xx, i=i - xx 】

127.0.0.1:6379> get mykey

"10"

127.0.0.1:6379> incrby mykey 6

(integer) 16

127.0.0.1:6379> get mykey

"16"

127.0.0.1:6379> get mykey

"16"

127.0.0.1:6379> decrby mykey 9

(integer) 7

127.0.0.1:6379> get mykey

"7"

127.0.0.1:6379>

Redis中的String不是string类型。。。如果存放到string中的value是int，那么其实在内部还是用int的。。。

从encoding可以看出。。。

RedisObject中有一个type属性，

有一个encoding属性。。。

有一个ptr属性。 => SDS

查看类型 OBJECT ENCODING

127.0.0.1:6379> object encoding username

"embstr"

127.0.0.1:6379> set mykey "10"

127.0.0.1:6379> object encoding mykey

"int"

从一个简单的String类型中，我们发现有int，embstr.... 【性能优化】

三、String过期操作

一：String 过期操作一些工具函数

Redis 单线程的内存字典服务器。。。过期时间 =》 [mamcache] kv结构。

SET key value [EX seconds] [PX milliseconds] [NX|XX]

缓存，和memcache做一样的功能。。。

ttl username 用于查看当前还剩多少秒。。。 NativeCache

EX seconds – Set the specified expire time, in seconds.

PX milliseconds – Set the specified expire time, in milliseconds.

NX – Only set the key if it does not already exist.

XX – Only set the key if it already exist.

EX seconds – 设置键key的过期时间，单位时秒

PX milliseconds – 设置键key的过期时间，单位时毫秒

NX – 只有键key不存在的时候才会设置key的值

XX – 只有键key存在的时候才会设置key的值

设置一个key mykey1值为"hello" 过期时间为5s

127.0.0.1:6379> set mykey1 "hello" ex 5

127.0.0.1:6379> get mykey1

"hello"

查看用于查看当前还剩多少秒

127.0.0.1:6379> set mykey1 "hello" ex 5

127.0.0.1:6379> ttl mykey1

(integer) 4

PSETEX key milliseconds value 《=》 Set key value [PX milliseconds]

PSETEX和SETEX一样，唯一的区别是到期时间以毫秒为单位,而不是秒

127.0.0.1:6379> PSETEX mykey 10000 "Hello"

127.0.0.1:6379> get mykey

"Hello"

127.0.0.1:6379> pttl mykey

(integer) 2189

SETEX key seconds value 《=》 Set key value [EX seconds]

127.0.0.1:6379> setex mykey 10 "hello"

127.0.0.1:6379> get mykey

"hello"

一样用法

二：String

1. len => StrLen 时间复杂度：O(1)

返回key的string类型value的长度。如果key对应的非string类型，就返回错误

127.0.0.1:6379> set mykey "abcdef"

127.0.0.1:6379> get mykey

"abcdef"

127.0.0.1:6379> STRLEN mykey

(integer) 6

2. substring => GetRange =＞　getRange username 0 2

时间复杂度：O(N) N是字符串长度，复杂度由最终返回长度决定，但由于通过一个字符串创建子字符串是很容易的，它可以被认为是O(1)。

127.0.0.1:6379> SET mykey "This is a string"

127.0.0.1:6379> getrange mykey 0 3

"This"

127.0.0.1:6379>

127.0.0.1:6379> getrange mykey -3 -1

"ing"

127.0.0.1:6379> getrange mykey 0 -1

"This is a string"

127.0.0.1:6379> getrange mykey 10 100

"string"

127.0.0.1:6379>

3. replace => SetRange　

SETRANGE key offset value =>

127.0.0.1:6379> SET key1 "Hello World"

127.0.0.1:6379> SETRANGE key1 6 "Redis"

(integer) 11

127.0.0.1:6379>

127.0.0.1:6379> get key1

"Hello Redis"

127.0.0.1:6379> get username

"jack"

127.0.0.1:6379> setRange username 4 "12345"

(integer) 9

127.0.0.1:6379> get username

"jack12345"

Append命令

127.0.0.1:6379> set mykey a

127.0.0.1:6379> APPEND mykey bbbb

(integer) 5

127.0.0.1:6379> get amykey

(nil)

127.0.0.1:6379> get mykey

"abbbb"

exists判断一个key是否存在 1表示存在 0表示不存在

127.0.0.1:6379> EXISTS mykey

(integer) 1

127.0.0.1:6379>

127.0.0.1:6379> get mykey

"abbbb"

127.0.0.1:6379> exists sss

(integer) 0

###########非常重要############################################

四、String 4

一：位运算

SDS => char[] xxxx xxxx char

xxxx xxxx char

1. 百雀林：500w左右的用户 => customerid

比如给某一批用户发送短信【营销】。。。下午10点。。。上午创建

【交易金额大于50的，上海地区的，购买过某一个商品】

customerid,customerid,cutomerid,customerid。

table： customerid,customerid,cutomerid,customerid。【300w】 Max：500w

10，20，30，31，32，33，999，1222,...... 【几百M】

【customerid不重复】我们customerid上限。

SDS => char[] 0000 0000 char

0100 0000 char

0001 0000 char

char[375000] => 几M就搞定了。。。

C#： BitArray [位数组]

Redis位运算：

SETBIT key offset value => String的value大小是512M 【数据传输太慢了】【多而小的数据】

String的value大小是512M

static int checkStringLength(client *c, long long size) {

if (size > 512*1024*1024) {

addReplyError(c,"string exceeds maximum allowed size (512MB)");

return C_ERR;

}

return C_OK;

}

01234567

char => 从左到右 0000 0000 => offset = 7, set=1 => 0000 0001 => offset = 6, set=1 => 0000 0011

SDS => char[] 0000 0000 char

0100 0000 char

0001 0000 char

。。。

customerid：10，20,

127.0.0.1:6379> SETBIT num 7 1

(integer) 0

127.0.0.1:6379> get num

"\x01"

127.0.0.1:6379> SETBIT num 6 1

(integer) 0

127.0.0.1:6379> get num

"\x03"

查看数量BITCOUNT

127.0.0.1:6379> SETBIT num 10 1

(integer) 0

127.0.0.1:6379> SETBIT num 20 1

(integer) 0

127.0.0.1:6379> BITCOUNT num

(integer) 4

GETBIT key offset

127.0.0.1:6379> GETBIT num 6

(integer) 1

127.0.0.1:6379> GETBIT num 7

(integer) 1

127.0.0.1:6379> GETBIT num 10

(integer) 1

127.0.0.1:6379> GETBIT num 5

(integer) 0

127.0.0.1:6379> GETBIT num 20

(integer) 1

BITCOUNT key [start end] => 获取1的个数

BITOP operation destkey key [key ...] => AND OR XOR NOT [JAVA,C#]

对一个或多个保存二进制位的字符串 key 进行位元操作，并将结果保存到 destkey 上。

0000 0001 => 1

& 0000 0010 => 2

--------------

0000 0000 => 0

1 & 2 = 0

BITOP AND destkey srckey1 srckey2 srckey3 ... srckeyN ，对一个或多个 key 求逻辑并，并将结果保存到 destkey 。

BITOP OR destkey srckey1 srckey2 srckey3 ... srckeyN，对一个或多个 key 求逻辑或，并将结果保存到 destkey 。

BITOP XOR destkey srckey1 srckey2 srckey3 ... srckeyN，对一个或多个 key 求逻辑异或，并将结果保存到 destkey 。

BITOP NOT destkey srckey，对给定 key 求逻辑非，并将结果保存到 destkey

127.0.0.1:6379> setbit num1 7 1

(integer) 0

127.0.0.1:6379> setbit num2 6 1

(integer) 0

127.0.0.1:6379> get num1

"\x01"

127.0.0.1:6379> get num2

"\x02"

127.0.0.1:6379> bitop and num3 num1 num2

(integer) 1

127.0.0.1:6379> get num3

"\x00"

127.0.0.1:6379>

JS： BufferArray数组

###########非常重要#################################################################

(4)list双向结构

一：List JAVA,C# 【Array】形式来实现的。。。

双向链表，[单链表，单向循环链表，双向。。。十字链表]

[队列和栈] queue, stack

二：从源代码中了解List是如何构造的。。。

typedef struct listNode {

struct listNode *prev;

struct listNode *next;

void *value;

} listNode;

//迭代一个中间变量

typedef struct listIter {

listNode *next;

int direction;

} listIter;

typedef struct list {

listNode *head;

listNode *tail;

void *(*dup)(void *ptr);

void (*free)(void *ptr);

int (*match)(void *ptr, void *key);

unsigned long len;

} list;

为了方便对listNode进行管理，redis中使用list进行包装。。。

len：统计当前双向链表中的listnode的个数。。。 O(1)

list在redis中存放的形式：

redisObject

type: (0,1,2,3,4) 1

encoding:

ptr

ptr => string sds

prtr =>list list -> listNode

RedisDb => Dict => key: redisObject value:redisObject

ptr => list[双向链表]

/* Object types */

#define OBJ_STRING 0

#define OBJ_LIST 1

#define OBJ_SET 2

#define OBJ_ZSET 3

#define OBJ_HASH 4

时间复杂度都是：O(1)

LPUSH key value [value ...] 【redis做催付订单，卖家发货，签收提醒】

LPOP key

RPUSH key value [value ...]

RPOP key

LLEN key

例子LPUSH：

127.0.0.1:6379> LLEN mylist

(integer) 0

127.0.0.1:6379> lpush mylist "world"

(integer) 1

127.0.0.1:6379> LLEN mylist

(integer) 1

127.0.0.1:6379> lpush mylist "hello"

(integer) 2

127.0.0.1:6379> LLEN mylist

(integer) 2

127.0.0.1:6379> lrange mylist 0 -1

1) "hello"

2) "world"

#####RPOP用法

127.0.0.1:6379> lpush order "1001"

(integer) 1

127.0.0.1:6379> lpush order "1002"

(integer) 2

127.0.0.1:6379> lpush order "1003"

(integer) 3

127.0.0.1:6379> LRANGE order 0 -1

1) "1003"

2) "1002"

3) "1001"

127.0.0.1:6379> rpop order

"1001"

127.0.0.1:6379> LRANGE order 0 -1

1) "1003"

2) "1002"

127.0.0.1:6379>

client redis:list server

orderid: 1001

orderid: 1002

orderid: 1003

一：list 阻塞版本

client -> list -> server

while(true){

try{

var info= list.Rpop();

....process....

}

catch{

}

finally{

Thread.Sleep(1000);

}

没有数据的情况下，我们还是一直的轮询redis。。。

while(true){

try{

var info= list.BRpop(); => 阻塞

....process....

}

catch{

}

finally{

Thread.Sleep(1000);

}

BRpop，BLpop 两种方式

BRPOP key [key ...] timeout 【s为单位】

timeout： 0 表示永远等待【connection被阻塞】

timeout：10 表示10s过期

MSMQ,RabbitMQ 都有这种等待。。。

例子：

127.0.0.1:6379> rpush orders 1001

(integer) 1

127.0.0.1:6379> rpush orders 1002

(integer) 2

127.0.0.1:6379> rpush orders 1003

(integer) 3

127.0.0.1:6379> rpush orders 1004

(integer) 4

127.0.0.1:6379> rpush orders 1005

(integer) 5

现象