From 22d48542a8524e9ceed35e3653d17a5b98c2f72b Mon Sep 17 00:00:00 2001 From: "DESKTOP-V763RJ7\\Administrator" <835606593@qq.com> Date: Sun, 18 Jan 2026 00:06:58 +0800 Subject: [PATCH] =?UTF-8?q?feat=20=E6=9C=8D=E5=8A=A1=E5=8F=91=E7=8E=B0?= =?UTF-8?q?=E6=A8=A1=E5=9D=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- db/db.go | 48 ---------------------------------------------- module/discover.go | 25 ++++++++++++++++++++++++ 2 files changed, 25 insertions(+), 48 deletions(-) delete mode 100644 db/db.go create mode 100644 module/discover.go diff --git a/db/db.go b/db/db.go deleted file mode 100644 index 0e9dfed..0000000 --- a/db/db.go +++ /dev/null @@ -1,48 +0,0 @@ -package db - -import ( - "git.hlsq.asia/mmorpg/service-common/config" - "git.hlsq.asia/mmorpg/service-common/db/etcd" - "git.hlsq.asia/mmorpg/service-common/db/mysql" - "git.hlsq.asia/mmorpg/service-common/db/redis" - "git.hlsq.asia/mmorpg/service-common/log" -) - -// ModuleDB 数据库模块 -type ModuleDB struct { -} - -func (p *ModuleDB) Init(cfg *config.DBConfig) error { - // ETCD - if cfg.Etcd != nil { - if err := etcd.Init(cfg.Etcd); err != nil { - return err - } - } - // MYSQL - if cfg.MySQL != nil { - if err := mysql.Init(cfg.MySQL); err != nil { - return err - } - } - // REDIS - if cfg.Redis != nil { - if err := redis.Init(cfg.Redis); err != nil { - return err - } - } - return nil -} - -func (p *ModuleDB) Stop() error { - if err := etcd.Close(); err != nil { - log.Errorf("close etcd failed: %v", err) - } - if err := mysql.Close(); err != nil { - log.Errorf("close mysql failed: %v", err) - } - if err := redis.Close(); err != nil { - log.Errorf("close redis failed: %v", err) - } - return nil -} diff --git a/module/discover.go b/module/discover.go new file mode 100644 index 0000000..ba476a5 --- /dev/null +++ b/module/discover.go @@ -0,0 +1,25 @@ +package module + +import "git.hlsq.asia/mmorpg/service-common/discover" + +// Discover 服务发现模块 +type Discover struct { +} + +func (m *Discover) Init() error { + return nil +} + +func (m *Discover) Start() error { + discover.Listen() + return nil +} + +func (m *Discover) Stop() error { + discover.Close() + return nil +} + +func (m *Discover) Bind(_ ...any) Module { + return m +}