core

core

基于 Actor 模型的 Go 游戏服务器框架。通过 Object 树形管理 goroutine，以命令队列替代直接 channel 通信，避免死锁和 channel 滥用。

快速开始

package main

import (
    "github.com/acoderup/core"
    "github.com/acoderup/core/module"
    "github.com/acoderup/core/schedule"
)

func main() {
    core.WritePid()
    core.LoadPackages("config.json")  // 加载配置 → Init 所有内置 Package
    waitor := module.Start()          // PreloadModule → Module Init → Run
    schedule.StartTask()              // cron 调度器
    waitor.Wait("main")               // 阻塞直到关闭
}

详细示例见 example/ 目录。

架构

main
 ├─ core.LoadPackages("config.json")  ← viperx 读取 JSON → 反序列化到各 Package → Init
 ├─ module.Start()                    ← PreloadModule(如 stdin 命令行) → Module Init → Run
 │    └─ ModuleMgr (Actor, 每 10ms tick)
 │         ├─ 按优先级遍历所有 Module.Update()
 │         └─ 统一帧时间 GetCurrTime()
 └─ waitor.Wait()                     ← 阻塞直到 Object 树全部退出

信号触发 → module.Stop() → Module.Shutdown() → Object 树销毁 → 退出

Object 树：

                        root (AppCtx)
                           │
            ┌──────────────┼──────────────┐
            │              │              │
          core           timer        executor
      (ModuleMgr)    (TimerMgr)    ┌───┴───┐
                                 worker_1 ... worker_8

模块

基础

调度与执行

基础设施

分布式

配置

{
  "core":    { "MaxProcs": 4, "GCPercent": 0 },
  "module":  { "Options": { "QueueBacklog": 1024, "MaxDone": 1024, "Interval": 100 } },
  "executor": { "Worker": { "WorkerCnt": 8 }, "Options": { ... } },
  "timer":   { "Options": { "QueueBacklog": 1024, "MaxDone": 1024, "Interval": 100 } },
  "cmdline": { "SupportCmdLine": true },
  "signal":  { "SupportSignal": true },
  "profile": { "SlowMS": 500 },
  "tx": {}
}

• GCPercent <= 0：关闭自动 GC，通过 core.TriggerGC() / core.FreeOSMemory() 手动维护
• Interval：tick 间隔（毫秒），ModuleMgr 和 TimerMgr 各自独立
• QueueBacklog：Actor 命令队列容量上限，超限 SendCommand 返回 false
• WorkerCnt：Task 执行器 Worker 数量，默认 8

自定义模块

type MyModule struct{}
func (m *MyModule) ModuleName() string { return "my-module" }
func (m *MyModule) Init()              {}
func (m *MyModule) Update()            {}
func (m *MyModule) Shutdown()          { module.UnregisteModule(m) }

func init() {
    module.RegisteModule(&MyModule{}, 100*time.Millisecond, 10)
}

自定义 Package

type MyConfig struct { Addr string }
func (c *MyConfig) Name() string  { return "my-package" }
func (c *MyConfig) Init() error   { return nil }
func (c *MyConfig) Close() error  { return nil }

func init() {
    core.RegistePackage(&MyConfig{Addr: "localhost:8080"})
}

对应的 config.json：

{ "my-package": { "Addr": "10.0.0.1:8080" } }

GC 策略

默认关闭自动 GC，由程序手动维护。可在 cron 中定时触发：

schedule.AddTask("gc", schedule.NewTask("gc", "0 0 4 * * *", func() error {
    core.FreeOSMemory()
    return nil
}))

如需恢复自动 GC，设置 config.json 中 core.GCPercent 为 100。