框架结构优化

This commit is contained in:
hahwu 2025-02-20 12:19:26 +08:00
parent f8ce894ab6
commit 357d1b468f
3 changed files with 131 additions and 260 deletions

View File

@ -49,7 +49,8 @@ func RegisterMsgProcessFunc(key string, value1 interface{}) {
func RunNetProcessByKey(key string, param []interface{}) error {
fun, ok := RegisterNetWorkFunc[key]
if ok {
err := fun.(func([]interface{}) error)(param)
_, player, buf := ParseArgs(param)
err := fun.(func(*Player, []byte) error)(player, buf)
return err
}
return fmt.Errorf("cant find network func %s", key)
@ -822,6 +823,7 @@ func (ad *GameLogic) RegisterNetWorkFunc() {
RegisterMsgProcessFunc("ReqKafkaLog", ReqKafkaLog) // 客户端日志
RegisterMsgProcessFunc("ReqCreateOrderSn", ReqCreateOrderSn) // 创建订单号
RegisterMsgProcessFunc("ReqShippingOrder", ReqShippingOrder) // 获取订单号
}
func (ad *GameLogic) CreateHttpManager() {

File diff suppressed because it is too large Load Diff

View File

@ -176,6 +176,7 @@ func HandleClientReq(args []interface{}) {
}()
p.(*Player).args = make(map[string]interface{})
p.(*Player).args["func"] = m
p.(*Player).args["agent"] = a
err := RunNetProcessByKey(m.GetFunc(), []interface{}{a, buf})
if err != nil {
log.Debug("uid : %d, func : %s, err : %s", p.(*Player).M_DwUin, m.GetFunc(), err)