曹工说Redis源码（2）-- redis server 启动过程解析及简单c语言基础知识补充
三国梦回 人气:1文章导航
Redis源码系列的初衷，是帮助我们更好地理解Redis，更懂Redis，而怎么才能懂，光看是不够的，建议跟着下面的这一篇，把环境搭建起来，后续可以自己阅读源码，或者跟着我这边一起阅读。由于我用c也是好几年以前了，些许错误在所难免，希望读者能不吝指出。
曹工说Redis源码（1）-- redis debug环境搭建，使用clion，达到和调试java一样的效果
一些补充知识
项目结构及入口
除了大学那些玩具，一个真正的项目，都是由大量源代码文件组成一个工程。在Java里，一个 java 文件要使用其他 java 文件中的函数、类型、变量等，都需要使用import语句来引入。在c语言里，也是一样的，在c语言中，要引入其他文件的功能，需要使用include语句。
比如，在redis的主入口，redis.c文件中，就包含了如下一堆语句：
#include "redis.h"
#include "cluster.h"
#include "slowlog.h"
#include "bio.h"
#include <time.h>
#include <signal.h>
其中，以<开头的，比如<time.h>是标准库的头文件，会在系统指定的路径下查找，可类比为jdk官方的class；"bio.h"这种，以""包裹的，则是工程里自定义的。
比如，time.h，我在linux的以下路径查找到了：
[root@mini1 src]# locate time.h
/usr/include/time.h
其他include相关知识，可以参考：
https://www.runoob.com/cprogramming/c-header-files.html
我对头文件的理解
一般来说，我们会在.c文件中，去编写我们的业务逻辑方法，其中，一些方法，可能是只在本文件内部用到的，类似于java class的private方法；一些方法呢，可能是需要在外部的其他源码文件中，也需要用到的，这些方法，要怎么才能让外部可以使用呢？
就是通过头文件机制，可以理解为各大高级语言中的接口，在java中，定义一个class，虽然可以直接把方法设为public，其他类可以直接访问；但是，在平时的业务开发中，我们一般并不会直接访问一个实现类，而是通过它实现的接口去访问；一个好的实现类，也不应该把没在接口中定义的方法，设为public权限。
说回头文件，比如有个源码文件test.c 如下：
long long ustime(void) {
struct timeval tv;
long long ust;
gettimeofday(&tv, NULL);
ust = ((long long)tv.tv_sec)*1000000;
ust += tv.tv_usec;
return ust;
}
/* Return the UNIX time in milliseconds */
// 返回毫秒格式的 UNIX 时间
// 1 秒 = 1 000 毫秒
long long mstime(void) {
return ustime()/1000;
}
这个文件里，定义了2个方法，但假设我们只需要对外暴露mstime(void)方法，那么，头文件test.h应该是下面这样的：
long long mstime(void);
这样的话，我们的另一个方法，ustime，对外就不可见了。
总之，大家可以把头文件理解为实现类要对外暴露的接口；大家可能觉得我的比喻不恰当，为啥把c文件，说成实现类，实际上，我们之前在华为的时候，确实是用c++的思想，面向对象的思想，来写c语言的。
我看到网上一篇文章，这里引用一下（https://zhuanlan.zhihu.com/p/57882822）：
反观Redis，他是纯C编码，但是融入了面向对象的思想。和上述观点截然相反，可谓是『用C++去设计，用C编码』。当然本文目的并非挑起语言之争，各种语言自有其利弊，开源项目的语言选择也主要是由于项目作者的个人经历和主观意愿。
但是c语言中的头文件，和java这些语言中的接口，还是不同的；在java中，接口和实现类一样，最终都是编译为独立的class文件。
在c语言中，在编译实现类之前，会有一个预处理的过程，预处理的过程，就是把include语句，直接替换为被include的头文件的内容，比如，以菜鸟教程中的例子举例：
header.h
char *test (void);
在如下的 program.c中，需要使用上面的header.h中的test方法，则需要include：
int x;
#include "header.h"
int main (void)
{
puts (test ());
}
经过预处理后，（就是进行简单的replace），效果如下：
int x;
char *test (void);
int main (void)
{
puts (test ());
}
我们可以使用如下命令，来演示这个过程：
[root@mini1 test]# gcc -E program.c
int x;
# 1 "header.h" 1
char *test (void);
# 3 "program.c" 2
int main (void)
{
puts (test ());
}
从上面可以看到，已经replace进去了；如果我们include两次，会怎样？
[root@mini1 test]# gcc -E program.c
int x;
# 1 "header.h" 1
char *test (void);
# 3 "program.c" 2
# 1 "header.h" 1
char *test (void);
# 4 "program.c" 2
int main (void)
{
puts (test ());
}
可以发现，这个header的内容，出现了2次，重复了。但是上面这种情况，并不会报错，无非是方法被定义了两次。
为什么头文件里都要来一句ifndef
大家看头文件，都会发现如下语句，比如在redis.h中：
#ifndef __REDIS_H
#define __REDIS_H
#include "fmacros.h"
#include "config.h"
...
typedef struct redisObject {
// 类型
unsigned type:4;
// 编码
unsigned encoding:4;
// 对象最后一次被访问的时间
unsigned lru:REDIS_LRU_BITS; /* lru time (relative to server.lruclock) */
// 引用计数
int refcount;
// 指向实际值的指针
void *ptr;
} robj;
...
#endif
可以看到，最开始，有一句：
#ifndef __REDIS_H
#define __REDIS_H
结尾有一句：
#endif
这个就是为了解决如下问题：
在头文件被重复引入时（间接地，或直接地，被include了两次），如果不加这个，就会导致头文件里的内容，被引入两次；加了这个之后呢，即使被include了两次，程序在运行时，一开始，发现没有定义__REDIS_H这个宏，然后定义它；等到程序遇到第二次include的内容时，发现__REDIS_H这个宏已经被定义了，就直接跳过了，这样保证了同一个头文件，即使被多次include，也能保证其内容，只被解析一次。
另外，像方法声明这种，定义多次可能没事，但是，如果在头文件里，有如下类型定义呢：
typedef char my_char;
char *test (void);
如果重复include同一个头文件的话，就会造成类型重复定义。不过，很奇怪的是，我在centos 7.3.1611上试了，gcc版本：gcc (GCC) 4.8.5 20150623 (Red Hat 4.8.5-16)，竟然没报错。看来我之前的c语言知识，也没学到家。
我在网上暂时也没找到重复include，具体的害处是啥，网上找到的答案就两种：
- 在header文件里定义了全局变量；
- 浪费编译时间
但是，第一个答案，严格来说 ，是不存在的，因为公司一般禁止在头文件中定义变量。
有个知乎问题，大家可以看看：头文件被重复包含究竟有哪些危害？
华为c语言编程规范中，对头文件的部分规定
大家可以自行搜索：华为技术有限公司c语言编程规范
我这里仅截取部分：
规则1.6 禁止在头文件中定义变量。
说明： 在头文件中定义变量，将会由于头文件被其他.c文件包含而导致变量重复定义。
规则1.7 只能通过包含头文件的方式使用其他.c提供的接口，禁止在.c中通过extern的方式使用外部
函数接口、变量。
说明：若a.c使用了b.c定义的foo()函数，则应当在b.h中声明extern int foo(int input)；并在a.c
中通过#include <b.h>来使用foo。禁止通过在a.c中直接写extern int foo(int input);来使用foo，
后面这种写法容易在foo改变时可能导致声明和定义不一致。
这里的1.7，也是和我们的理解是一致的，头文件就是一个实现模块的对外接口，在里面一般只能允许放以下内容：
- 类型定义
- 宏定义
- 函数的声明（不包括实现）
- 变量的声明（不是定义）
最后这一点，我要补充下。我们刚才禁止了，在头文件中定义变量，所以，我们的变量，是在c文件中定义。比如，在redis.c中，定义了一个全局变量：
/* Global vars */
struct redisServer server; /* server global state */
这么一个重要的全局变量，基本维护了redis-server的一个实例的全部状态值，只在自己redis.c中使用，是不可能的。那要怎么在其他文件使用呢，就要在redis.h头文件中进行如下声明：
/*-----------------------------------------------------------------------------
* Extern declarations
*----------------------------------------------------------------------------*/
extern struct redisServer server;
关于类型定义
一般使用struct来定义一个结构体，类似高级语言中的class。
比如，redis中的字符串，一般会使用sds这个数据结构来存储，其结构体定义就像下面这样：
struct sdshdr {
// buf 中已占用空间的长度
int len;
// buf 中剩余可用空间的长度
int free;
// 数据空间
char buf[];
};
另外，c语言中，会大量使用typedef来定义一个类型的别名。
具体可以参考这个教程看看：
https://www.runoob.com/cprogramming/c-typedef.html
关于指针
基础知识：https://www.runoob.com/cprogramming/c-pointers.html
我这里说下我对指针的理解，指针一般指向一个内存地址，大家可以先不管这个指针是什么类型，事实上，当我们不关心其指向的地址上，是什么数据类型时，可以直接定义为 void * ptr。
这个指针，假设指向A这个地址，当我们认为上面存储的是一个char时，就可以把这个指针，从void *强转为char * 类型，然后对该指针解引用的话，因为char类型只占用一个字节，所以只需要，从该指针指向的位置开始，取当前这个字节的内容，然后解析为char，就能获取到这个地址上的char值。
如果我们把void * 强转为int *的话，对其解引用时，就会取当前指针位置开始的4个字节，因为整数占4个字节，然后将其转为整数。
总的来说，对一个指针解引用时，首先就是看当前指针的数据类型，比如 int *指针，那么说明指向int，就会取4个字节来进行解引用；如果是指向一个结构体，就会计算结构体占用的字节数，然后取对应的字节，来解引用为结构体类型的变量。
这部分，大家可以看看这块：
https://www.runoob.com/cprogramming/c-data-types.html
https://www.runoob.com/cprogramming/c-pointer-arithmetic.html
redis启动过程之配置项初始化
前面说了很多，我们本讲也不够讲完全部的redis启动过程了，可能还要两讲的样子，本讲先讲解一部分。
启动入口在：redis.c中的main 方法，如果使用我这边的代码来搭建调试环境，可以直接启动redis-server。
int main(int argc, char **argv) {
struct timeval tv;
/**
* 1 设置时区
*/
setlocale(LC_COLLATE,"");
/**
*2
*/
zmalloc_enable_thread_safeness();
// 3
zmalloc_set_oom_handler(redisOutOfMemoryHandler);
// 4
srand(time(NULL)^getpid());
// 5
gettimeofday(&tv,NULL);
// 6
dictSetHashFunctionSeed(tv.tv_sec^tv.tv_usec^getpid());
// 检查服务器是否以 Sentinel 模式启动
server.sentinel_mode = checkForSentinelMode(argc,argv);
// 7 初始化服务器
initServerConfig();
-
1处，设置时区
-
2处，设置进行内存分配的线程的数量，这里会设为1
-
3处，设置oom发生时的函数指针，函数指针指向一个函数，类似于java 8中，lambda表达式中，丢一个方法的引用给流；函数指针会在oom时，被回调，总体来说，就类似于java中的模板设计模式或者策略模式。
-
4处，设置随机数的种子
-
5处，获取当前时间，设置到
tv这个变量中注意，这里把tv的地址传进去了，这是c语言中典型的用法，类似于java中传一个对象的引用进去，然后在方法内部，会修改该对象的内部field等
-
6处，设置hash函数的种子
-
7处，初始化服务器。
这里重点说下7处：
void initServerConfig() {
int j;
// 服务器状态
// 设置服务器的运行 ID
getRandomHexChars(server.runid,REDIS_RUN_ID_SIZE);
// 设置默认配置文件路径
server.configfile = NULL;
// 设置默认服务器频率
server.hz = REDIS_DEFAULT_HZ;
// 为运行 ID 加上结尾字符
server.runid[REDIS_RUN_ID_SIZE] = '\0';
// 设置服务器的运行架构
server.arch_bits = (sizeof(long) == 8) ? 64 : 32;
// 设置默认服务器端口号
server.port = REDIS_SERVERPORT;
// tcp 全连接队列的长度
server.tcp_backlog = REDIS_TCP_BACKLOG;
// 绑定的地址的数量
server.bindaddr_count = 0;
// UNIX socket path
server.unixsocket = NULL;
server.unixsocketperm = REDIS_DEFAULT_UNIX_SOCKET_PERM;
// 绑定的 TCP socket file descriptors
server.ipfd_count = 0;
server.sofd = -1;
// redis可使用的redis db的数量
server.dbnum = REDIS_DEFAULT_DBNUM;
// redis 日志级别
server.verbosity = REDIS_DEFAULT_VERBOSITY;
// Client timeout in seconds,客户端最大空闲时间;超过这个时间的客户端，会被强制关闭
server.maxidletime = REDIS_MAXIDLETIME;
// Set SO_KEEPALIVE if non-zero. 如果设为非0，则开启tcp的SO_KEEPALIVE
server.tcpkeepalive = REDIS_DEFAULT_TCP_KEEPALIVE;
// 打开这个选项，会周期性地清理过期key
server.active_expire_enabled = 1;
// 客户端发来的请求中，查询缓存的最大值；比如一个set命令，value的大小就会和这个缓冲区大小比较，
// 如果大了，就根本放不进缓冲区
server.client_max_querybuf_len = REDIS_MAX_QUERYBUF_LEN;
// rdb保存参数，比如每60s保存，n个键被修改了保存，之类的
server.saveparams = NULL;
// 如果为1，表示服务器正在从磁盘载入数据： We are loading data from disk if true
server.loading = 0;
// 日志文件位置
server.logfile = zstrdup(REDIS_DEFAULT_LOGFILE);
// 开启syslog等机制
server.syslog_enabled = REDIS_DEFAULT_SYSLOG_ENABLED;
server.syslog_ident = zstrdup(REDIS_DEFAULT_SYSLOG_IDENT);
server.syslog_facility = LOG_LOCAL0;
// 后台运行
server.daemonize = REDIS_DEFAULT_DAEMONIZE;
// aof状态
server.aof_state = REDIS_AOF_OFF;
// aof的刷磁盘策略，默认每秒刷盘
server.aof_fsync = REDIS_DEFAULT_AOF_FSYNC;
// 正在rewrite时，不刷盘
server.aof_no_fsync_on_rewrite = REDIS_DEFAULT_AOF_NO_FSYNC_ON_REWRITE;
// Rewrite AOF if % growth is > M and...
server.aof_rewrite_perc = REDIS_AOF_REWRITE_PERC;
// the AOF file is at least N bytes. aof达到多大时，触发rewrite
server.aof_rewrite_min_size = REDIS_AOF_REWRITE_MIN_SIZE;
// 最后一次执行 BGREWRITEAOF 时， AOF 文件的大小
server.aof_rewrite_base_size = 0;
// Rewrite once BGSAVE terminates.开启该选项时，BGSAVE结束时，触发rewrite
server.aof_rewrite_scheduled = 0;
// 最近一次aof进行fsync的时间
server.aof_last_fsync = time(NULL);
// 最近一次aof重写，消耗的时间
server.aof_rewrite_time_last = -1;
// Current AOF rewrite start time.
server.aof_rewrite_time_start = -1;
// 最后一次执行 BGREWRITEAOF 的结果
server.aof_lastbgrewrite_status = REDIS_OK;
// 记录 AOF 的 fsync 操作被推迟了多少次
server.aof_delayed_fsync = 0;
// File descriptor of currently selected AOF file
server.aof_fd = -1;
// AOF 的当前目标数据库
server.aof_selected_db = -1; /* Make sure the first time will not match */
// UNIX time of postponed AOF flush
server.aof_flush_postponed_start = 0;
// fsync incrementally while rewriting? 重写过程中，增量触发fsync
server.aof_rewrite_incremental_fsync = REDIS_DEFAULT_AOF_REWRITE_INCREMENTAL_FSYNC;
// pid文件
server.pidfile = zstrdup(REDIS_DEFAULT_PID_FILE);
// rdb 文件名
server.rdb_filename = zstrdup(REDIS_DEFAULT_RDB_FILENAME);
// aof 文件名
server.aof_filename = zstrdup(REDIS_DEFAULT_AOF_FILENAME);
// 是否要密码
server.requirepass = NULL;
// 是否进行rdb压缩
server.rdb_compression = REDIS_DEFAULT_RDB_COMPRESSION;
// rdb checksum
server.rdb_checksum = REDIS_DEFAULT_RDB_CHECKSUM;
// bgsave失败，停止写入
server.stop_writes_on_bgsave_err = REDIS_DEFAULT_STOP_WRITES_ON_BGSAVE_ERROR;
// 在执行 serverCron() 时进行渐进式 rehash
server.activerehashing = REDIS_DEFAULT_ACTIVE_REHASHING;
server.notify_keyspace_events = 0;
// 支持的最大客户端数量
server.maxclients = REDIS_MAX_CLIENTS;
// bpop阻塞的客户端
server.bpop_blocked_clients = 0;
// 可以使用的最大内存
server.maxmemory = REDIS_DEFAULT_MAXMEMORY;
// 内存淘汰策略，也就是key的过期策略
server.maxmemory_policy = REDIS_DEFAULT_MAXMEMORY_POLICY;
server.maxmemory_samples = REDIS_DEFAULT_MAXMEMORY_SAMPLES;
// hash表的元素小于这个值时，使用ziplist 编码模式;以下几个类似
server.hash_max_ziplist_entries = REDIS_HASH_MAX_ZIPLIST_ENTRIES;
server.hash_max_ziplist_value = REDIS_HASH_MAX_ZIPLIST_VALUE;
server.list_max_ziplist_entries = REDIS_LIST_MAX_ZIPLIST_ENTRIES;
server.list_max_ziplist_value = REDIS_LIST_MAX_ZIPLIST_VALUE;
server.set_max_intset_entries = REDIS_SET_MAX_INTSET_ENTRIES;
server.zset_max_ziplist_entries = REDIS_ZSET_MAX_ZIPLIST_ENTRIES;
server.zset_max_ziplist_value = REDIS_ZSET_MAX_ZIPLIST_VALUE;
server.hll_sparse_max_bytes = REDIS_DEFAULT_HLL_SPARSE_MAX_BYTES;
// 该标识打开时，表示正在关闭服务器
server.shutdown_asap = 0;
// 复制相关
server.repl_ping_slave_period = REDIS_REPL_PING_SLAVE_PERIOD;
server.repl_timeout = REDIS_REPL_TIMEOUT;
server.repl_min_slaves_to_write = REDIS_DEFAULT_MIN_SLAVES_TO_WRITE;
server.repl_min_slaves_max_lag = REDIS_DEFAULT_MIN_SLAVES_MAX_LAG;
// cluster模式相关
server.cluster_enabled = 0;
server.cluster_node_timeout = REDIS_CLUSTER_DEFAULT_NODE_TIMEOUT;
server.cluster_migration_barrier = REDIS_CLUSTER_DEFAULT_MIGRATION_BARRIER;
server.cluster_configfile = zstrdup(REDIS_DEFAULT_CLUSTER_CONFIG_FILE);
// lua脚本
server.lua_caller = NULL;
server.lua_time_limit = REDIS_LUA_TIME_LIMIT;
server.lua_client = NULL;
server.lua_timedout = 0;
//
server.migrate_cached_sockets = dictCreate(&migrateCacheDictType,NULL);
server.loading_process_events_interval_bytes = (1024*1024*2);
// 初始化 LRU 时间
server.lruclock = getLRUClock();
// 初始化并设置保存条件
resetServerSaveParams();
// rdb的默认保存策略
appendServerSaveParams(60*60,1); /* save after 1 hour and 1 change */
appendServerSaveParams(300,100); /* save after 5 minutes and 100 changes */
appendServerSaveParams(60,10000); /* save after 1 minute and 10000 changes */
/* Replication related */
// 初始化和复制相关的状态
server.masterauth = NULL;
server.masterhost = NULL;
server.masterport = 6379;
server.master = NULL;
server.cached_master = NULL;
server.repl_master_initial_offset = -1;
server.repl_state = REDIS_REPL_NONE;
server.repl_syncio_timeout = REDIS_REPL_SYNCIO_TIMEOUT;
server.repl_serve_stale_data = REDIS_DEFAULT_SLAVE_SERVE_STALE_DATA;
server.repl_slave_ro = REDIS_DEFAULT_SLAVE_READ_ONLY;
server.repl_down_since = 0; /* Never connected, repl is down since EVER. */
server.repl_disable_tcp_nodelay = REDIS_DEFAULT_REPL_DISABLE_TCP_NODELAY;
server.slave_priority = REDIS_DEFAULT_SLAVE_PRIORITY;
server.master_repl_offset = 0;
/* Replication partial resync backlog */
// 初始化 PSYNC 命令所使用的 backlog
server.repl_backlog = NULL;
server.repl_backlog_size = REDIS_DEFAULT_REPL_BACKLOG_SIZE;
server.repl_backlog_histlen = 0;
server.repl_backlog_idx = 0;
server.repl_backlog_off = 0;
server.repl_backlog_time_limit = REDIS_DEFAULT_REPL_BACKLOG_TIME_LIMIT;
server.repl_no_slaves_since = time(NULL);
/* Client output buffer limits */
// 设置客户端的输出缓冲区限制
for (j = 0; j < REDIS_CLIENT_LIMIT_NUM_CLASSES; j++)
server.client_obuf_limits[j] = clientBufferLimitsDefaults[j];
/* Double constants initialization */
// 初始化浮点常量
R_Zero = 0.0;
R_PosInf = 1.0/R_Zero;
R_NegInf = -1.0/R_Zero;
R_Nan = R_Zero/R_Zero;
// 初始化命令表,比如get、set、hset等各自的处理函数，放进一个hash表，方便后续处理请求
server.commands = dictCreate(&commandTableDictType,NULL);
server.orig_commands = dictCreate(&commandTableDictType,NULL);
populateCommandTable();
server.delCommand = lookupCommandByCString("del");
server.multiCommand = lookupCommandByCString("multi");
server.lpushCommand = lookupCommandByCString("lpush");
server.lpopCommand = lookupCommandByCString("lpop");
server.rpopCommand = lookupCommandByCString("rpop");
/* Slow log */
// 初始化慢查询日志
server.slowlog_log_slower_than = REDIS_SLOWLOG_LOG_SLOWER_THAN;
server.slowlog_max_len = REDIS_SLOWLOG_MAX_LEN;
/* Debugging */
// 初始化调试项
server.assert_failed = "<no assertion failed>";
server.assert_file = "<no file>";
server.assert_line = 0;
server.bug_report_start = 0;
server.watchdog_period = 0;
}
以上都加了注释，我们可以先不看：复制、cluster、lua等相关的，先看其他的。
总结
太久没碰c了，有些遗忘，不过总体来说，并不难，难的是内存泄露之类，但我们只是debug学习使用，不用担心这些问题。
指针那一块，需要一点点基础，大家可以花点时间学一下。
大家看看有啥问题或者建议，欢迎指出。
加载全部内容