skynet的流程分析一
首先是创建一个服务:
skynet.newservice(name, …) 用于启动一个新的 Lua 服务。name 是脚本的名字(不用写 .lua 后缀)。
函数调用流程如下:
skynet.newservice-“skynet.lua”->launch_service-“launcher.lua”->skynet.launch-“manager.lua”->cmd_launch-“skynet_server.c”
这里是如何创建lua虚拟机并加载服务对应的lua文件?暂时略过!。
然后是一个服务的启动与初始化:
skynet.init(func)——注册初始化函数可多次调用。将会将func注册到初始化列表(init_func)中。然后在调用skynet.start()时在start_func之前调用(调用顺序参见skynet.lua中的init_template函数)
function skynet.start(start_func)
c.callback(dispatch_message)
trace_handle = assert(c.stat "trace")
skynet.timeout(0, function()
init_service(start_func)
end)
end
skynet.start(start_func)——启动服务! 首先,执行c.callback,调用skynet.so库文件的接口_callback,设置服务的回调函数,这样每次有消息发送到本服务,都会用函数dispatch_message来处理。而后,才会执行传进来的闭包start_func。
服务的消息队列处理:
每当有消息进入时首先会调用到raw_dispatch_message()中,对于回复型的消息则会根据来源服务来查找对应的协程co,对于非回复型的消息会直接创建一个新的协程co(其执行函数即为skynet.dispatch()所注册的函数)。最终在调用suspend()函数时以传参的方式调用coroutine.resume激活协程co。
这里需要注意的是对于需要返回的消息,需要调用skynet.ret()将处理的结果传递给主协程
function skynet.ret(msg, sz)
msg = msg or ""
return coroutine_yield("RETURN",msg,sz)
end
参考资料:
[1] http://blog.csdn.net/riddick2z/article/details/17200297
[2]http://www.mamicode.com/info-detail-891453.html