---__init__--- 这一行是固定格式, 用于标记启动脚本是否有设置启动选项
if _G["__init__"] then
    local arg = ... --- command line args
    return {
        -- 基础配置
        thread = 8,                -- 工作线程数
        enable_stdout = true,      -- 启用标准输出
        logfile = string.format("log/node-%s-%s.log", 
            arg[1], 
            os.date("%Y-%m-%d-%H-%M-%S")
        ),
        loglevel = "DEBUG",        -- 日志级别
        
        -- Lua搜索路径
        path = table.concat({
            "./?.lua",            -- 当前目录
            "./?/init.lua",       -- 当前目录的init文件
            "../lualib/?.lua",    -- moon库
            "../service/?.lua",   -- moon服务
            -- Append your lua module search path
        }, ";")
    }
end

---__init__---  初始化进程选项标识
if _G["__init__"] then
    local arg = ... ---这里可以获取命令行参数, string[] 类型
    return {
        thread = 8, ---启动8条线程
        enable_stdout = true,
        logfile = string.format("log/game-%s.log", os.date("%Y-%m-%d-%H-%M-%S")),
        loglevel = "DEBUG", ---默认日志等级
        path = table.concat({ --- 注意: 工作目录会切换到当前脚本所在的路径
            "./?.lua",
            "./?/init.lua",
            "../lualib/?.lua",   -- moon lualib 搜索路径
            "../service/?.lua",  -- moon 自带的服务搜索路径，需要用到redisd服务
            -- Append your lua module search path
        }, ";")
    }
end

--------开始编写第一个服务的逻辑代码----

local moon = require("moon")

local socket = require "moon.socket"

--初始化服务配置
local db_conf= {host = "127.0.0.1", port = 6379, timeout = 1000}

local gate_host = "0.0.0.0"
local gate_port = 8889
local client_timeout = 300

local services = {
    {
        unique = true,
        name = "db",
        file = "../service/redisd.lua",
        threadid = 2, ---独占线程
        poolsize = 5, ---连接池
        opts = db_conf
    },
    {
        unique = true,
        name = "center",
        file = "game/service_center.lua",
        threadid = 3,
    },
}

moon.async(function ()
    for _, one in ipairs(services) do
        local id = moon.new_service( one)
        if 0 == id then
            moon.exit(-1) ---如果唯一服务创建失败，立刻退出进程
            return
        end
    end

    local listenfd = socket.listen(gate_host, gate_port, moon.PTYPE_SOCKET_TCP)
    if 0 == listenfd then
        moon.exit(-1) ---监听端口失败，立刻退出进程
        return
    end

    print("server start", gate_host, gate_port)

    while true do
        local id = moon.new_service( {
            name = "user",
            file = "game/service_user.lua"
        })

        local fd, err = socket.accept(listenfd, id)
        if not fd then
            print("accept",err)
            moon.kill(id)
        else
            moon.send("lua", id,"start", fd, client_timeout)
        end
    end

end)

-- 注册进程退出回调
moon.shutdown(function ()
    moon.async(function ()
        -- 控制其它唯一服务的退出逻辑
        assert(moon.call("lua", moon.queryservice("center"), "shutdown"))
        moon.raw_send("system", moon.queryservice("db"), "wait_save")

        ---wait all service quit
        while true do
            local size = moon.server_stats("service.count")
            if size == 1 then
                break
            end
            moon.sleep(200)
            print("bootstrap wait all service quit, now count:", size)
        end

        moon.quit()
    end)
end)

    ---向指定节点的唯一服务发送消息, 无返回值, 如果网络或其它原因造成消息不可达，消息会被丢弃
    cluster.send(receiver_node, receiver_sname, ...)
    ---向指定节点的唯一服务发起RPC调用, 不管成功和失败一定会得到返回值，可以检测返回值判断执行是否成功
    cluster.call(receiver_node, receiver_sname, ...)