package controller import ( "blazing/cool" "blazing/logic/service/common" "strings" "bytes" "context" "reflect" "github.com/gogf/gf/v2/os/gcmd" "github.com/gogf/gf/v2/os/glog" "github.com/gogf/gf/v2/util/gconv" "github.com/lunixbochs/struc" ) var Maincontroller = NewController() //注入service func NewController() *Controller { return &Controller{} } // 分发cmd逻辑实现Controller type Controller struct { Port uint16 RPCClient struct { Kick func(uint32) error RegisterLogic func(uint16, uint16) error } } func ParseCmd[T any](a T, data []byte) T { // := info.NewLoginSidInfo() struc.Unpack(bytes.NewBuffer(data), &a) return a //fmt.Println(pinfo) //login.OnData_1001(pinfo, player) //fmt.Println(data) } func init() { //默认初始化扫描 // 解析命令行参数 cool.Config.PortBL = gcmd.GetOpt("port", "1").Uint16() // 获取对象的反射值和类型 value := reflect.ValueOf(Maincontroller) // 获取类型 typ := value.Type() for i := 0; i < typ.NumMethod(); i++ { method := typ.Method(i) methodValue := value.MethodByName(method.Name) //fmt.Println("找到注册方法", method.Name) methodValue.Type().NumIn() for _, func_cmd := range getcmd(methodValue.Type().In(0)) { if func_cmd == 0 { //说明不是注册方法 glog.Warning(context.Background(), "方法参数必须包含CMD参数", method.Name, "跳过注册") continue } if cool.Config.PortBL == 0 && func_cmd > 1000 { //判断login服务器 continue } if cool.Config.PortBL != 0 && func_cmd < 1000 { //判断login服务器 continue } glog.Debug(context.Background(), "注册方法", func_cmd, method.Name) // fmt.Println(methodValue.Interface().(func(gnet.Conn, player.TomeeHeader))) _, ok := cool.CmdCache.LoadOrStore(func_cmd, methodValue) //TODO 待实现对不同用户初始化方法以取消全局cmdcache if ok { //方法已存在init glog.Error(context.Background(), "方法已存在init,不会初始化后面的方法", func_cmd) } } } } func getcmd(t reflect.Type) []uint32 { // 处理指针类型 if t.Kind() == reflect.Ptr { t = t.Elem() // 获取指针指向的类型 } // 确保是结构体 if t.Kind() != reflect.Struct { return []uint32{0} } // 遍历结构体字段 // fmt.Printf("结构体 %s 的字段信息:\n", t.Name()) for i := 0; i < t.NumField(); i++ { field := t.Field(i) //fmt.Printf("- 字段名: %s\n", field.Name) //fmt.Printf(" 类型: %v\n", field.Type) if field.Type == reflect.TypeOf(common.TomeeHeader{}) { // fmt.Println(reflect.ValueOf(field)) return gconv.SliceUint32(strings.Split(field.Tag.Get("cmd"), "|")) } if field.Type.Kind() == reflect.Struct || (field.Type.Kind() == reflect.Ptr && field.Type.Elem().Kind() == reflect.Struct) { nestedType := field.Type if nestedType.Kind() == reflect.Ptr { nestedType = nestedType.Elem() } getcmd(nestedType) } // fmt.Println() } return []uint32{0} }