Skynet 进程启动
初始化配置
skynet 进程启动时需要指定配置文件,启动后读取配置文件中的内容并存储在内存中。配置文件格式是 k = v
且 k
必须是字符串而 v
必须是字符串或者 lua boolean
类型。
通过 L
读取配置,随后把配置存储在 skynet_env.c
模块中新创建的 lua state 中,每个配置项都是一个全局变量。
// skynet_main.c
int main {
skynet_env_init();
err = lua_pcall(L, 1, 1, 0);
if (err) {
fprintf(stderr,"%s\n",lua_tostring(L,-1));
lua_close(L);
return 1;
}
_init_env(L);
}
创建第一个服务
skynet 进程启动时,创建的第一个服务就是日志服务,服务名是 config-logservice
。skynet 提供的默认服务是 service_logger.c
。由于此服务被直接通过 skynet_context_new
创建,如果想提供自定义日志服务,需要写个 C 服务替换 service_logger.c
。
如果日志服务创建失败,则整个进程退出。
// skynet_start.c
void skynet_start {
struct skynet_context *ctx = skynet_context_new(config->logservice, config->logger);
if (ctx == NULL) {
fprintf(stderr, "Can't launch %s service\n", config->logservice);
exit(1);
}
skynet_handle_namehandle(skynet_context_handle(ctx), "logger");
}
创建 skynet 需要的 lua 服务和配置中 start
服务
启动 config->bootstrap
lua 服务,进行初始化,创建 skynet 需要的 lua 服务。
创建 launcher
服务,管理之后通过 skynet.newservice
创建的服务。
创建 service_mgr
服务,提供管理功能。
创建配置中的 start
服务,供业务逻辑进行初始化。 最后该服务退出。
// skynet_start.c
void skynet_start {
bootstrap(ctx, config->bootstrap); // snlua bootstrap
}
-- service/bootstrap.lua
skynet.start(function()
-- 创建 launcher 服务
local launcher = assert(skynet.launch("snlua","launcher"))
skynet.name(".launcher", launcher)
-- 创建配置中的 start 服务
pcall(skynet.newservice,skynet.getenv "start" or "main")
-- 提供管理的服务
skynet.newservice "service_mgr"
-- 创建完其他服务后,本服务退出
skynet.exit()
end)
创建子线程
skynet 目前创建了四种线程,分别是 thread_monitor, thread_timer, thread_socket, thread_worker
。消息的调度和派发是在 thread_worker
线程中执行的,且 worker 线程根据权重 weight
决定处理队列中消息的数量。
static void start {
// 创建监控,定时器,网络线程
create_thread(&pid[0], thread_monitor, m);
create_thread(&pid[1], thread_timer, m);
create_thread(&pid[2], thread_socket, m);
// 创建 worker 线程
static int weight[] = {
-1, -1, -1, -1, 0, 0, 0, 0,
1, 1, 1, 1, 1, 1, 1, 1,
2, 2, 2, 2, 2, 2, 2, 2,
3, 3, 3, 3, 3, 3, 3, 3, };
struct worker_parm wp[thread];
for (i=0;i<thread;i++) {
wp[i].m = m;
wp[i].id = i;
if (i < sizeof(weight)/sizeof(weight[0])) {
wp[i].weight= weight[i];
} else {
wp[i].weight = 0;
}
create_thread(&pid[i+3], thread_worker, &wp[i]);
}
// 等待所有线程执行完毕后,则退出
for (i=0;i<thread+3;i++) {
pthread_join(pid[i], NULL);
}
}
skynet_start.c start
函数执行到 pthread_join
时,skynet 初始化完毕。
注意:在 worker 线程工作之前,框架就已经创建了服务并且有向服务发送消息。