• 字符串
• 哈希表
• 列表
• 集合
• 有序集

• redisObject 对象
• 基于 redisObject 对象的类型检查
• 基于 redisObject 对象的显式多态函数
• 对 redisObject 进行分配、共享和销毁的机制

/*
* Redis 对象
*/
typedef struct redisObject {
// 类型
unsigned type:4;
 
// 对齐位
unsigned notused:2;
 
// 编码方式
unsigned encoding:4;
 
// LRU 时间（相对于 server.lruclock）
unsigned lru:22;
 
// 引用计数
int refcount;
 
// 指向对象的值
void *ptr;
} robj;

• type（类型）
  • REDIS_STRING 0 // 字符串
  • REDIS_LIST 1      // 列表
  • REDIS_SET 2       // 集合
  • REDIS_ZSET 3     // 有序集
  • REDIS_HASH 4    // 哈希表
• encoding（编码）
  • REDIS_ENCODING_RAW 0             // 编码为字符串
  • REDIS_ENCODING_INT 1               // 编码为整数
  • REDIS_ENCODING_HT 2                // 编码为字典
  • REDIS_ENCODING_ZIPMAP 3        // 编码为 zipmap
  • REDIS_ENCODING_LINKEDLIST 4   // 编码为双端链表
  • REDIS_ENCODING_ZIPLIST 5          // 编码为压缩列表
  • REDIS_ENCODING_INTSET 6          // 编码为整数集合
  • REDIS_ENCODING_SKIPLIST 7        // 编码为跳跃表
• ptr
  • 指向实际保存值得数据结构
    • 这个数据结构由type属性 和encoding 属性决定
  • 例子
    • redisObject 的 type属性为REDIS_LIST，encoding属性为REDIS_ENCODING_LINKEDLIST
    • 那么这个对象就是一个Redis列表，它的值保存在一个双端链表内，而ptr指针就指向这个双端链表

 

 

• 根据给定 key ，在数据库字典中查找和它像对应的 redisObject ，如果没找到，就返回NULL 。
• 检查 redisObject 的 type 属性和执行命令所需的类型是否相符，如果不相符，返回类型错误。
• 根据 redisObject 的 encoding 属性所指定的编码，选择合适的操作函数来处理底层的数据结构。
• 返回数据结构的操作结果作为命令的返回值。

 

• 各种命令的返回值，比如执行成功时返回的 OK ，执行错误时返回的 ERROR ，类型错误时返回的 WRONGTYPE ，命令入队事务时返回的 QUEUED ，等等。
• 包括0在内，小于redis.h/REDIS_SHARED_INTEGERS的所有整数
• • （REDIS_SHARED_INTEGERS的默认值为10000）

• 每个redisObject 结构都带有一个 refcount 属性，指示这个对象被引用了多少次。
• 当新创建一个对象时，它的 refcount 属性被设置为 1 。
• 当对一个对象进行共享时，Redis 将这个对象的 refcount 增一。
• 当使用完一个对象之后，或者取消对共享对象的引用之后，程序将对象的 refcount 减一。
• 当对象的 refcount 降至 0 时，这个 redisObject 结构，以及它所引用的数据结构的内存，都会被释放。

• Redis 使用自己实现的对象机制来实现类型判断、命令多态和基于引用计数的垃圾回收。
• 一种 Redis 类型的键可以有多种底层实现。
• Redis 会预分配一些常用的数据对象，并通过共享这些对象来减少内存占用，和避免频繁地为小对象分配内存。

 

 

 

 

 

• 只有当这些命令被用于空列表时，它们才会阻塞客户端
• 如果被处理的列表不为空的话，它们就执行无阻塞版本的 LPOP 、 RPOP 或 RPOPLPUSH 命令。

 

 

 

• 检查这个键是否存在于前面提到的 server.db[i]->blocking_keys 字典里，
  • 如果是的话，那么说明有至少一个客户端因为这个 key 而被阻塞，
  • 程序会为这个键创建一个redis.h/readyList 结构，并将它添加到 server.ready_keys链表中。
  • 即将readylist 添加到服务器
• 将给定的值添加到列表键中。

def handleClientsBlockedOnLists():
 
# 执行直到 ready_keys 为空
while server.ready_keys != NULL:
 
     # 弹出链表中的第一个 readyList
     rl = server.ready_keys.pop_first_node()
    
     # 遍历所有因为这个键而被阻塞的客户端
     for client in all_client_blocking_by_key(rl.key, rl.db):
 
          # 只要还有客户端被这个键阻塞，就一直从键中弹出元素
          # 如果被阻塞客户端执行的是 BLPOP ，那么对键执行 LPOP
          # 如果执行的是 BRPOP ，那么对键执行 RPOP
          element = rl.key.pop_element()
 
          if element == NULL:
               # 键为空，跳出 for 循环
               # 余下的未解除阻塞的客户端只能等待下次新元素的进入了
               break
          else:
               # 清除客户端的阻塞信息
               server.blocking_keys.remove_blocking_info(client)
               # 将元素返回给客户端，脱离阻塞状态
               client.reply_list_item(element)

 

 

• 如果第一个元素可以表示为 long long 类型值（也即是，它是一个整数），那么集合的初始编码为 REDIS_ENCODING_INTSET
• 否则，集合的初始编码为 REDIS_ENCODING_HT

 

 

Redis数据类型