文档章节

Redis源码分析系列六:initserver中

强子1985
 强子1985
发布于 2013/10/17 23:50
字数 580
阅读 171
收藏 0

server.db = zmalloc(sizeof(redisDb)*server.dbnum);
 //开辟缓冲区

listenToPort(server.port,server.ipfd,&server.ipfd_count);

显然这个函数是监听端口

跟踪这个函数,进入,发现最终是掉用_anetTcpServer函数。

下面是_anetTcpServer函数的解析。


static int _anetTcpServer(char *err, int port, char *bindaddr, int af)
{

    int s, rv;
    char _port[6];  /* strlen("65535") */
 //监听端口
 
    struct addrinfo hints;
 //.ai_family = AF_INET;
    //.ai_socktype = SOCK_STREAM;
    //.ai_flags = AI_PASSIVE;
   
    struct addrinfo *servinfo;
 struct addrinfo *p;

 

    snprintf(_port,6,"%d",port);

 
    memset(&hints,0,sizeof(hints));
 
    hints.ai_family = af;
    hints.ai_socktype = SOCK_STREAM;
    hints.ai_flags = AI_PASSIVE;    /* No effect if bindaddr != NULL */

 

    if ((rv = getaddrinfo(bindaddr,_port,&hints,&servinfo)) != 0) {
        anetSetError(err, "%s", gai_strerror(rv));
        return ANET_ERR;
  //获取解析的信息链表
    }
 
    for (p = servinfo; p != NULL; p = p->ai_next)
 {
        if ((s = socket(p->ai_family,p->ai_socktype,p->ai_protocol)) == -1)
            continue;
  //创建一个socket

  

        if (af == AF_INET6 && anetV6Only(err,s) == ANET_ERR) goto error;

        if (anetSetReuseAddr(err,s) == ANET_ERR) goto error;
  //设置socket重用

  
  
        if (anetListen(err,s,p->ai_addr,p->ai_addrlen) == ANET_ERR) goto error;
  //bind & listen
        goto end;
    }
    if (p == NULL) {
        anetSetError(err, "unable to bind socket");
        goto error;
    }

error:
    s = ANET_ERR;
end:
    freeaddrinfo(servinfo);
    return s;
}
总结:实现了socket,bind,listen并对socket设置了一些优化措施,比如设置passive,重用等。

成功的socket存于server.ipfd,个数由server.ipfd_count指示。

~~~~~~~~~~~~~~~~~~~~~~~~~~~~

下面的代码

/* Open the listening Unix domain socket. */
    if (server.unixsocket != NULL) {
        unlink(server.unixsocket); /* don't care if this fails */
        server.sofd = anetUnixServer(server.neterr,server.unixsocket,server.unixsocketperm);
        if (server.sofd == ANET_ERR) {
            redisLog(REDIS_WARNING, "Opening socket: %s", server.neterr);
            exit(1);
        }
    }

用于建立unix 域socket

刚才特意看了配置文件

# Specify the path for the unix socket that will be used to listen for
# incoming connections. There is no default, so Redis will not listen
# on a unix socket when not specified.
#
# unixsocket /tmp/redis.sock
# unixsocketperm 755

我认为这里没有使用domain socket.所以忽略不计。

/* Abort if there are no listening sockets at all. */
    if (server.ipfd_count == 0 && server.sofd < 0) {
        redisLog(REDIS_WARNING, "Configured to not listen anywhere, exiting.");
        exit(1);
    }

这个只是检查而已,继续往下看。

然后接下来的几行代码采用了dictCreate,还记得之前说过的模板么?

我找到了我的模板,然后替换几个参数,让若干变量得以顺利初始化。

listSetFreeMethod(server.pubsub_patterns,freePubsubPattern);

设置server.pubsub_patterns->free = freePubsubPattern

listSetMatchMethod(server.pubsub_patterns,listMatchPubsubPattern);

设置 server.pubsub_patterns->match = listMatchPubsubPattern

 

剩下的若干初始化就很简单,不用多说,代码如下:


    server.cronloops = 0;
    server.rdb_child_pid = -1;
    server.aof_child_pid = -1;
    aofRewriteBufferReset();
    server.aof_buf = sdsempty();
    server.lastsave = time(NULL); /* At startup we consider the DB saved. */
    server.lastbgsave_try = 0;    /* At startup we never tried to BGSAVE. */
    server.rdb_save_time_last = -1;
    server.rdb_save_time_start = -1;
    server.dirty = 0;
    server.stat_numcommands = 0;
    server.stat_numconnections = 0;
    server.stat_expiredkeys = 0;
    server.stat_evictedkeys = 0;
    server.stat_starttime = time(NULL);
    server.stat_keyspace_misses = 0;
    server.stat_keyspace_hits = 0;
    server.stat_peak_memory = 0;
    server.stat_fork_time = 0;
    server.stat_rejected_conn = 0;
    server.stat_sync_full = 0;
    server.stat_sync_partial_ok = 0;
    server.stat_sync_partial_err = 0;
    memset(server.ops_sec_samples,0,sizeof(server.ops_sec_samples));
    server.ops_sec_idx = 0;
    server.ops_sec_last_sample_time = mstime();
    server.ops_sec_last_sample_ops = 0;
    server.unixtime = time(NULL);
    server.mstime = mstime();
    server.lastbgsave_status = REDIS_OK;
    server.repl_good_slaves_count = 0;

 

© 著作权归作者所有

共有 人打赏支持
强子1985

强子1985

粉丝 890
博文 1261
码字总数 932462
作品 8
南京
架构师
私信 提问
Redis网络架构及单线程模型

最近略有闲暇时间,于是对Redis进行了一些学习,学习途径除了官方文档还有Redis源代码,我看的版本是2.8.13,Redis源码总行数不到5W行,不同组件拆分非常细致,阅读起来也很清晰。这篇博客主...

Float_Luuu
2016/05/20
1K
0
Redis源码分析系列七:initServer下

这个函数快到尾声了,一鼓作气! if(aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL) == AE_ERR) { redisPanic("Can't create the serverCron time event."); exit(1); } 这个函数......

强子哥哥
2013/10/18
0
0
深入Redis内部-Redis 源码讲解

作者:nosqlfan on 星期一, 三月 7, 2011 · 评论本文 【阅读:4,036 次】 Redis 作为 NoSQL 数据库的杰出代表,一直广受关注,其轻量级的敏捷架构,向来有存储中的瑞士军刀之称。下面推荐的...

Dicky
2011/09/25
0
0
Redis源码分析系列五:initServer上

刚下班,吃了点饭,精神饱满,让我们继续分析initServer,这个函数还是很重要的。 ~~ int j; signal(SIGHUP, SIGIGN);//注册信号处理程序为忽略 signal(SIGPIPE, SIGIGN);//注册信号处理程序...

强子哥哥
2013/10/17
0
0
Redis 的事件驱动库结构

原文地址:http://blog.ddup.us/?p=114 这是一篇翻译文章,原文见这里。Redis实现了它自己的事件库。事件库的实现在ae.c文件中。要弄明白Redis事件库是如何工作的最好的方法就是弄明白Red...

红薯
2011/08/14
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

用 C 语言编写 Windows 服务程序的五个步骤(转)

摘要   Windows 服务被设计用于需要在后台运行的应用程序以及实现没有用户交互的任务。为了学习这种控制台应用程序的基础知识,C(不是C++)是最佳选择。本文将建立并 实现一个简单的服务程...

_编程菜鸟_
22分钟前
0
0
Linux各目录及每个目录的详细介绍

目录 /bin 存放二进制可执行文件(ls,cat,mkdir等),常用命令一般都在这里。 /etc 存放系统管理和配置文件 /home 存放所有用户文件的根目录,是用户主目录的基点,比如用户user的主目录就是/...

若杰
24分钟前
4
0
vue组件系列5、日期选择

插件部分源码 <template> <div class="date-picker" @click.stop> <input class="input" v-model="dateValue" v-on:mouseover="openPanel" /> <!-- 动画特效 --> <transi......

轻轻的往前走
25分钟前
1
0
SQL

BEGIN #定义一个变量来保存该记录是否存在 declare num int; #这条sql,就是查询对应的记录有多少条,注意 into num 这两句话,就是把count(*) 查出的值,赋给到num中 select co...

张泽立
26分钟前
1
0
云栖科技评论87期:建立AI规则非常重要 但充分对话更重要

【卷首语】建立AI规则非常重要 但充分对话更重要    2016年,谷歌CEO Sundar Pichai宣布谷歌战略从Mobile First(移动优先)转向AI First(人工智能优先),在此之后,谷歌不仅在AI领域持续投入...

Mr_zebra
27分钟前
1
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部