当前位置：首页 > news >正文

龙影辅助lua脚本调用_skynet之lua服务

news 2025/9/18 1:09:15

其实从C层的代码看，skynet没有太出彩的地方(也仍然很优秀)，有些人草草瞄了几眼C层的代码，就断定skynet很一般：凡是有经验的服务器程序，用个什么东西分分钟就搭出一个skynet之类的话。其实他们不知道，skynet对Lua的封装才是最好的部分，云风前辈对Lua的理解当属国内最顶尖的那几个。

这一部分非常细节，也非常难懂，不想了解的人估计不会看，了解了的人大概也已经了解，所以就当是自己的备忘录

skynet提供了一个snlua模块，每创建一个snlua类型的服务，snlua就创建一个Lua虚拟机，这使得lua服务之间完全隔离，唯一的通讯方式就是通过skynet的消息机制，每一个消息都在一个lua协程处理，当消息处理完毕，或中间向其他服务发送消息，协程可能会挂起，等其他服务回应这个消息时，协程才重新唤醒，这种方式使得异步代码像同步一样执行，不用写一大堆回调函数。

有了Lua类型的服务，skynet是不是有点像操作系统的概念，skynet的C层代码像操作系统内核，负责服务的调度，而Lua服务很像进程，有自己独立的空间(虚拟机独立)，Lua协程则像系统线程，只不过区别在于线程是真正的并发，协程是协作式的并发。每个Lua服务可以保证，同一时刻，只有一个线程在执行Lua协程，所以我们完全不必担心线程同步的问题，当我们在编写Lua服务时，就把它当成一个单线程一样。

bootstrap

回头看skynet_start.c，在skynet_start函数中，有这样的代码片段：

// 创建logger服务
struct skynet_context *ctx = skynet_context_new(config->logservice, config->logger);
// 创建引导服务
bootstrap(ctx, config->bootstrap);

上面是创建一个Logger服务，config->logger是保存日志的路径，如果为NULL则输出到stdout，logger服务会调用skynet_command(ctx, "REG", ".logger")注册名字(logger)，这样就可以方便地用logger找到它的句柄，从而向他发送日志。

bootstrap函数负责创建一个lua服务，config->bootstrap的内容默认是snlua bootstrap，从C底层来看，它是一个snlua类型的服务，bootstrap是lua服务执行的脚本，从字面上看是一个引导服务。

bootstrap函数如下：

static void
bootstrap(struct skynet_context * logger, const char * cmdline) {// 启动一个引导服务，默认情况下name为snlua，args为bootstrap.lua这个脚本int sz = strlen(cmdline);char name[sz+1];char args[sz+1];sscanf(cmdline, "%s %s", name, args);// 创建服务struct skynet_context *ctx = skynet_context_new(name, args);... ...
}

看过skynet总体架构，很清楚的知道这是创建一个snlua的服务，bootstrap为作这个服务的参数传过去。

snlua服务

创建snlua服务后，模块中的snlua_create首先得到调用，它做的事情也非常简单：

struct snlua *
snlua_create(void) {// 初始化snlua结构struct snlua * l = skynet_malloc(sizeof(*l));memset(l,0,sizeof(*l));l->mem_report = MEMORY_WARNING_REPORT;l->mem_limit = 0;// 创建Lua状态机l->L = lua_newstate(lalloc, l);return l;
}

就是创建一个snlua结构，创建一个Lua虚拟机，内存分配指定的是lalloc，目的是为了监控Lua分配的内存。MEMORY_WARNING_REPORT为Lua服务的内存阀值，超过该值，会报警。

snlua结构如下：

struct snlua {lua_State * L;          // Lua状态机struct skynet_context * ctx;  // 关联的skynet服务size_t mem;             // Lua使用的内存，在lalloc记录size_t mem_report;      // 内存预警，当达到阀值会打一条日志，然后阀值翻倍size_t mem_limit;       // 内存限制
};

创建snlua实例之后，调用snlua_init：

int
snlua_init(struct snlua *l, struct skynet_context *ctx, const char * args) {int sz = strlen(args);char * tmp = skynet_malloc(sz);memcpy(tmp, args, sz);// 指定回调函数为launch_cbskynet_callback(ctx, l , launch_cb);// 取本服务的句柄const char * self = skynet_command(ctx, "REG", NULL);uint32_t handle_id = strtoul(self+1, NULL, 16);// it must be first message:// 第一个消息在launch_cb处理，见函数skynet_send(ctx, 0, handle_id, PTYPE_TAG_DONTCOPY,0, tmp, sz);return 0;
}