前言:
上篇文章介绍了怎么对socket接收到的信息进行分包处理,把流水形的数据分成一块一块儿的,但是我们总不能在就只在一个接收函数里面写一个系统的逻辑吧,那画面太美我不敢想象,由此就引出了今天主题框架的路由。 已经把所有代码整合了,希望给个星星支持一下 microSocket。
技术基础:
路由通俗点说就是通过一些信息,去调用系统里的不同的函数方法
路由的两种方法:
- 第一种就是定义一个map[string]func ,然后每次就读取map去调用相应逻辑,这个方法实现起来非常简单,但是如果我们有上百个接口就要注册上百次,这未免也太蛋疼了,个人感觉不是很可取。。。
- 第二种就是定义一个map[string]struct ,然后 struct 里面有很多方法,不同的方法就对应着不同的接口,我们这样我们每次就需要注册不同的模块就好了,这样就很方便
反射:
想要达到上文第二种的效果我们需要了解到一些关于反射的知识,反射的定义就是 在计算机中表示 程序能够检查自身结构的能力。说的简单点就是一个对象我们在编写的时候不知道它内部里面有什么属性,但是可以动态的获取里面的值。go语言的反射要用到reflect这个包 。
实现:
下面我们来看具体代码怎么实现吧。
//定义一个接口每个模块必须实现此接口
type module interface {
Default()
}
//.......................全局路由.......................................
type RouterMap struct {
pools util.SafeMap//这个就是我实现的协程安全的map
}
func NewRouterMap() *RouterMap {
return &RouterMap{}
}
//注册模块函数
func (this *RouterMap) Register(name string, modules module) {
this.pools.Set(name, modules)
}
func (this *RouterMap) Hook(name string, funcName string, values map[string]string) {
modules := this.pools.Get(name)
if modules == nil {
log.Println("not find module " + name)
return
}
reModule, f := modules.(module)
if f == false {
return
}
//反射
moduleType := reflect.TypeOf(reModule)
moduleValue := reflect.ValueOf(reModule)
//如果函数存在就通过反射调用此函数
if funcs, exit := moduleType.MethodByName(funcName); exit {
moduleValue.Method(funcs.Index).Call([]reflect.Value{reflect.ValueOf(values)})
} else {
//如果函数不存在,就调用default方法
reModule.Default()
}
}
- 我们之前说到,每次都会接收到数据包,我们从数据包拿到name和function name 两个值,然后去调用 Hook
方法 传入三个参数(模块名,函数名,其余参数),首先我们通过模块名获得事先注册的struct,如果获得不了,就说明此模块不存在,则直接返回失败。 - 获得到了相应的struct后,我们就用到了 reflect 库的方法了,我简单的介绍一下 reflect 的使用,核心使用就是有两种方法,reflect.TypeOf 和 reflect.ValueOf ,第一种说简单点就是获得一个未知的对象的所有属性名和方法名,refect.ValueOf 就是获得未知的对象的所有的值和调用的方法,具体的操作就看我的代码吧
- 我们通过反射,去调用相应的方法,如果相应的方法不存在,就去调用的default 方法
总结:
我们只要在socket每次接到数据包的时候,去调用hook方法,就能去调用相应模块的方法了。
以上就是我们所有的路由内容,要是还是有什么不理解或者意见的欢迎留言提问!
下篇文章我我们会介绍到 socket框架的session管理
https://www.jianshu.com/p/72a7bf5809f7