初始化服务器代码如下：
signal(SIGHUP,SIG_IGN);
signal(SIGPIPE,SIG_IGN);
setupSignalHandlers();
</span><span style="color: #0000ff;">if</span><span style="color: #000000;"> (server.syslog_enabled) {
openlog(server.syslog_ident,LOG_PID </span>| LOG_NDELAY |<span style="color: #000000;"> LOG_NOWAIT,server.syslog_facility);
}
server.current_client </span>=<span style="color: #000000;"> NULL;
server.clients </span>=<span style="color: #000000;"> listCreate(); //创建客户队列
server.clients_to_close </span>=<span style="color: #000000;"> listCreate(); //创建将关闭的客户队列
server.slaves </span>=<span style="color: #000000;"> listCreate(); //创建从机队列
server.monitors </span>=<span style="color: #000000;"> listCreate(); //创建监控队列
server.slaveseldb </span>= -<span style="color: #800080;">1</span>; <span style="color: #008000;">/*</span><span style="color: #008000;"> Force to emit the first SELECT command. </span><span style="color: #008000;">*/</span><span style="color: #000000;">
server.unblocked_clients </span>=<span style="color: #000000;"> listCreate(); //创建非堵塞客户队列
server.ready_keys </span>=<span style="color: #000000;"> listCreate(); //创建可读key队列
createSharedObjects(); // 创建共享对象
adjustOpenFilesLimit(); //改变可打开文件的最大数量
server.el </span>= aeCreateEventLoop(server.maxclients+<span style="color: #000000;">REDIS_EVENTLOOP_FDSET_INCR); //创建事件处理
server.db </span>= zmalloc(<span style="color: #0000ff;">sizeof</span>(redisDb)*<span style="color: #000000;">server.dbnum); //分别db内存
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Open the TCP listening socket for the user commands. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">if</span> (listenToPort(server.port,server.ipfd,&server.ipfd_count) ==<span style="color: #000000;"> REDIS_ERR) //监听端口
exit(</span><span style="color: #800080;">1</span><span style="color: #000000;">);
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Open the listening Unix domain socket. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">if</span> (server.unixsocket !=<span style="color: #000000;"> NULL) {
unlink(server.unixsocket); </span><span style="color: #008000;">/*</span><span style="color: #008000;"> don't care if this fails </span><span style="color: #008000;">*/</span><span style="color: #000000;">
server.sofd </span>=<span style="color: #000000;"> anetUnixServer(server.neterr,server.unixsocket,server.unixsocketperm);
</span><span style="color: #0000ff;">if</span> (server.sofd ==<span style="color: #000000;"> ANET_ERR) {
redisLog(REDIS_WARNING,</span><span style="color: #800000;">"</span><span style="color: #800000;">Opening socket: %s</span><span style="color: #800000;">"</span><span style="color: #000000;">,server.neterr);
exit(</span><span style="color: #800080;">1</span><span style="color: #000000;">);
}
}
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Abort if there are no listening sockets at all. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">if</span> (server.ipfd_count == <span style="color: #800080;">0</span> && server.sofd < <span style="color: #800080;">0</span><span style="color: #000000;">) {
redisLog(REDIS_WARNING,</span><span style="color: #800000;">"</span><span style="color: #800000;">Configured to not listen anywhere,exiting.</span><span style="color: #800000;">"</span><span style="color: #000000;">);
exit(</span><span style="color: #800080;">1</span><span style="color: #000000;">);
}
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Create the Redis databases,and initialize other internal state. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">for</span> (j = <span style="color: #800080;">0</span>; j < server.dbnum; j++<span style="color: #000000;">) {
server.db[j].dict </span>= dictCreate(&<span style="color: #000000;">dbDictType,NULL);
server.db[j].expires </span>= dictCreate(&<span style="color: #000000;">keyptrDictType,NULL);
server.db[j].blocking_keys </span>= dictCreate(&<span style="color: #000000;">keylistDictType,NULL);
server.db[j].ready_keys </span>= dictCreate(&<span style="color: #000000;">setDictType,NULL);
server.db[j].watched_keys </span>= dictCreate(&<span style="color: #000000;">keylistDictType,NULL);
server.db[j].id </span>=<span style="color: #000000;"> j;
server.db[j].avg_ttl </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
}
server.pubsub_channels </span>= dictCreate(&<span style="color: #000000;">keylistDictType,NULL);
server.pubsub_patterns </span>=<span style="color: #000000;"> listCreate();
listSetFreeMethod(server.pubsub_patterns,freePubsubPattern);
listSetMatchMethod(server.pubsub_patterns,listMatchPubsubPattern);
server.cronloops </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.rdb_child_pid </span>= -<span style="color: #800080;">1</span><span style="color: #000000;">;
server.aof_child_pid </span>= -<span style="color: #800080;">1</span><span style="color: #000000;">;
aofRewriteBufferReset();
server.aof_buf </span>=<span style="color: #000000;"> sdsempty();
server.lastsave </span>= time(NULL); <span style="color: #008000;">/*</span><span style="color: #008000;"> At startup we consider the DB saved. </span><span style="color: #008000;">*/</span><span style="color: #000000;">
server.lastbgsave_try </span>= <span style="color: #800080;">0</span>; <span style="color: #008000;">/*</span><span style="color: #008000;"> At startup we never tried to BGSAVE. </span><span style="color: #008000;">*/</span><span style="color: #000000;">
server.rdb_save_time_last </span>= -<span style="color: #800080;">1</span><span style="color: #000000;">;
server.rdb_save_time_start </span>= -<span style="color: #800080;">1</span><span style="color: #000000;">;
server.dirty </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_numcommands </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_numconnections </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_expiredkeys </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_evictedkeys </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_starttime </span>=<span style="color: #000000;"> time(NULL);
server.stat_keyspace_misses </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_keyspace_hits </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_peak_memory </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_fork_time </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_rejected_conn </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_sync_full </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_sync_partial_ok </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.stat_sync_partial_err </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
memset(server.ops_sec_samples,</span><span style="color: #800080;">0</span>,<span style="color: #0000ff;">sizeof</span><span style="color: #000000;">(server.ops_sec_samples));
server.ops_sec_idx </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.ops_sec_last_sample_time </span>=<span style="color: #000000;"> mstime();
server.ops_sec_last_sample_ops </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
server.unixtime </span>=<span style="color: #000000;"> time(NULL);
server.mstime </span>=<span style="color: #000000;"> mstime();
server.lastbgsave_status </span>=<span style="color: #000000;"> REDIS_OK;
server.repl_good_slaves_count </span>= <span style="color: #800080;">0</span><span style="color: #000000;">;
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Create the serverCron() time event,that's our main way to process
* background operations. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">if</span>(aeCreateTimeEvent(server.el,<span style="color: #800080;">1</span>,serverCron,NULL,NULL) ==<span style="color: #000000;"> AE_ERR) {
redisPanic(</span><span style="color: #800000;">"</span><span style="color: #800000;">Can't create the serverCron time event.</span><span style="color: #800000;">"</span><span style="color: #000000;">);
exit(</span><span style="color: #800080;">1</span><span style="color: #000000;">);
}
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Create an event handler for accepting new connections in TCP and Unix
* domain sockets. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">for</span> (j = <span style="color: #800080;">0</span>; j < server.ipfd_count; j++<span style="color: #000000;">) {
</span><span style="color: #0000ff;">if</span><span style="color: #000000;"> (aeCreateFileEvent(server.el,server.ipfd[j],AE_READABLE,acceptTcpHandler,NULL) </span>==<span style="color: #000000;"> AE_ERR)
{
redisPanic(
</span><span style="color: #800000;">"</span><span style="color: #800000;">Unrecoverable error creating server.ipfd file event.</span><span style="color: #800000;">"</span><span style="color: #000000;">);
}
}
</span><span style="color: #0000ff;">if</span> (server.sofd > <span style="color: #800080;">0</span> &&<span style="color: #000000;"> aeCreateFileEvent(server.el,server.sofd,acceptUnixHandler,NULL) </span>== AE_ERR) redisPanic(<span style="color: #800000;">"</span><span style="color: #800000;">Unrecoverable error creating server.sofd file event.</span><span style="color: #800000;">"</span><span style="color: #000000;">);
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> Open the AOF file if needed. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">if</span> (server.aof_state ==<span style="color: #000000;"> REDIS_AOF_ON) {
server.aof_fd </span>=<span style="color: #000000;"> open(server.aof_filename,O_WRONLY</span>|O_APPEND|O_CREAT,<span style="color: #800080;">0644</span><span style="color: #000000;">);
</span><span style="color: #0000ff;">if</span> (server.aof_fd == -<span style="color: #800080;">1</span><span style="color: #000000;">) {
redisLog(REDIS_WARNING,</span><span style="color: #800000;">"</span><span style="color: #800000;">Can't open the append-only file: %s</span><span style="color: #800000;">"</span><span style="color: #000000;">,strerror(errno));
exit(</span><span style="color: #800080;">1</span><span style="color: #000000;">);
}
}
</span><span style="color: #008000;">/*</span><span style="color: #008000;"> 32 bit instances are limited to 4GB of address space,so if there is
* no explicit limit in the user provided configuration we set a limit
* at 3 GB using maxmemory with 'noeviction' policy'. This avoids
* useless crashes of the Redis instance for out of memory. </span><span style="color: #008000;">*/</span>
<span style="color: #0000ff;">if</span> (server.arch_bits == <span style="color: #800080;">32</span> && server.maxmemory == <span style="color: #800080;">0</span><span style="color: #000000;">) {
redisLog(REDIS_WARNING,</span><span style="color: #800000;">"</span><span style="color: #800000;">Warning: 32 bit instance detected but no memory limit set. Setting 3 GB maxmemory limit with 'noeviction' policy now.</span><span style="color: #800000;">"</span><span style="color: #000000;">);
server.maxmemory </span>= 3072LL*(<span style="color: #800080;">1024</span>*<span style="color: #800080;">1024</span>); <span style="color: #008000;">/*</span><span style="color: #008000;"> 3 GB </span><span style="color: #008000;">*/</span><span style="color: #000000;">
server.maxmemory_policy </span>=<span style="color: #000000;"> REDIS_MAXMEMORY_NO_EVICTION;
}
replicationScriptCacheInit();
scriptingInit();
slowlogInit();
bioInit();
}
1.1 信号处理
signal语法：
#include
<span style="color: #0000ff;">void (signal(<span style="color: #0000ff;">int sig,<span style="color: #0000ff;">void (func)(<span style="color: #0000ff;">int)))(<span style="color: #0000ff;">int<span style="color: #000000;">);
<span style="color: #0000ff;">int sighold(<span style="color: #0000ff;">int<span style="color: #000000;"> sig);
<span style="color: #0000ff;">int sigignore(<span style="color: #0000ff;">int<span style="color: #000000;"> sig);
<span style="color: #0000ff;">int sigpause(<span style="color: #0000ff;">int<span style="color: #000000;"> sig);
<span style="color: #0000ff;">int sigrelse(<span style="color: #0000ff;">int<span style="color: #000000;"> sig);
<span style="color: #0000ff;">void (sigset(<span style="color: #0000ff;">int sig,<span style="color: #0000ff;">void (disp)(<span style="color: #0000ff;">int)))(<span style="color: #0000ff;">int);
signal变量定义在signal.h文件中，其中：
1.信号
文章浏览阅读1.3k次。在 Redis 中，键（Keys）是非常重要的概...
文章浏览阅读3.3k次，点赞44次，收藏88次。本篇是对单节点的...
文章浏览阅读978次，点赞25次，收藏21次。在Centos上安装Red...
文章浏览阅读1.2k次，点赞21次，收藏22次。Docker-Compose部...
文章浏览阅读2.2k次，点赞59次，收藏38次。合理的JedisPool资...