0
0

日程表服务

云风 发表于 2017年09月07日 15:48 | Hits: 876
Tag: skynet

skynet 的用户中,问的比较多的一个问题是,为什么我改了系统时间对 skynet 却没有生效?继续追问发现,有这个需求的人大多是想实现一个日程表,到某个特定时间触发特定的任务,修改系统时间是为了测试。

不得不说,通过修改系统时间来测试是个直接、却很糟糕的主意。skynet 的定时器也不依赖系统时间驱动,修改系统时间自然也不会生效。

日程服务是个普遍的需求。在国内网游里,你要不做什么节日任务、每周副本,基本不可能上线。这篇 blog 就谈谈这类需求应该在 skynet 中如何实现。

最好的方法是实现一个单独的服务,用来控制日程。这样、如果你有测试的需求,也可以通过预留的接口让这个服务模拟时间快进,快速触发定时任务了。

通常,日程任务不需要特别高的时间精度,精确到分钟就够了。我们一般不会精确到秒来设定任务开启的时间。日程设置也多半和具体日期、星期几有关。常见的需求类似这样:每周六晚上 8 点开启;每个月的第二个周四中午 12 点;6 月 1 日儿童节活动;等等。

如果要设计一个这样的日程表服务,其实只需要一个订阅接口,类似 skynet timer 那样单次触发的就够了。触发接口就是传入一个时间点,可以描述上面例子中描述的日程。我们在具体活动实现的服务中用 skynet.call 这个日程安排服务,当 skynet.call 返回时,就是日程时间触发点。例如,我们需要每周 6 晚上 8 点固定开启一个活动,可以用一个 while 循环:

while true do
  skynet.call(schedule_service, "lua", { wday = 7 , hour = 20 } )
  -- 执行活动
end

这个日程表服务每次接到订阅请求,就按照参数计算出下一个符合要求的触发时间点,然后用 skynet.sleep 等到触发时间即可。

如果出于调试需要改动当前时间,直接通知这个服务,调整其内部时间和真实时间的时间差,wakeup 所有正在等待的请求,重新计算等待时间就好了。

这样一个日程表服务并不复杂,我花了一点时间随手实现了一个,供大家参考。它应该有很大的改进空间,明白了其设计之后,应该不难完善它:

local skynet = require "skynet"
local service = require "skynet.service"

local schedule = {}
local service_addr

-- { month=, day=, wday=, hour= , min= }
function schedule.submit(ti)
    return skynet.call(service_addr, "lua", ti)
end

function schedule.changetime(ti)
    local tmp = {}
    for k,v in pairs(ti) do
        tmp[k] = v
    end
    tmp.changetime = true
    return skynet.call(service_addr, "lua", tmp)
end

skynet.init(function()
    local schedule_service = function()
-- schedule service

local skynet = require "skynet"

local task = { session = 0, difftime = 0 }

local function next_time(now, ti)
    local nt = {
        year = now.year ,
        month = now.month ,
        day = now.day,
        hour = ti.hour or 0,
        min = ti.min or 0,
        sec = ti.sec,
    }
    if ti.wday then
        -- set week
        assert(ti.day == nil and ti.month == nil)
        nt.day = nt.day + ti.wday - now.wday
        local t = os.time(nt)
        if t 

用 schedule.submit 可以申请一个时间点,到时后会返回。使用的时候只需要用 skynet.fork 开一个独立线程,循环调用 schedule.submit 即可。

schedule.changetime 支持修改当前时间,供调试用。

原文链接: https://blog.codingnow.com/2017/09/schedule_service.html

0     0

评价列表(0)