leaf源码分析（二）----skeleton

版权声明：本文为作者原创，如需转载请通知本人，并标明出处和作者。擅自转载的，保留追究其侵权的权利。golang群：570992072。qq 29185807 个人公众号：月牙寂道长 公众号微信号yueyajidaozhang https://cloud.tencent.com/developer/article/1454434

本文公众号文章链接为：https://mp.weixin.qq.com/s/UXxJx9bhE6DJQk12ozFF9Q

Leaf 是一个由 Go 语言（golang）编写的开发效率和执行效率并重的开源游戏服务器框架。Leaf 适用于各类游戏服务器的开发，包括 H5（HTML5）游戏服务器。

skeleton是其中最重要的骨架。其封装了异步操作。包括chanrpc，time，go。

将其分为层次的话，就见下图

leaf源码分析（一）----chanrpc 已经讲解了chanrpc的用法

下面一个一个分析

g

Go模块是对golang中go提供一些额外功能。Go提供回调功能，LinearContext提供顺序调用功能。

github.com/name5566/leaf/go/go.go

1、Go

chancb：用于传送call back函数

pendingGo：用于记录正在处理go的计数器

初始化，其中l为容量值，关乎到chancb的容量

1、pengdingo：加1，记录调用计数

2、开了一个协程，执行了f

3、defer中，将回调函数cb发送到了chancb中

那是在哪里从chancb中取出cb的呢？

看下skeleton中的处理部分

在skeleton中，会详细再介绍。

继续看源码

执行cb，并将pengdingo减1，说明整个过程完成了。pengdingo记录的就是整个过程。

close的时候，会等待所有的go得cb，并执行。

2、LinearContext

LinearContext提供顺序调用功能。其中利用list来顺序保存执行函数和回调函数

初始化，是从Go中生成的。就是必须先有Go，才能从Go中生成LinearContext

1、将需要执行的f函数和cb回调函数，防到list的最后

2、开协程，有锁，这里每次只能执行一个。执行的时候从list最前面取出来执行

3、执行完成之后，在defer中将cb发送给chancb。

过程和Go是类似的，但这里加了锁和list，所以能够保证执行顺序。

timer

Timer主要是提供一个Cron功能的定时器服务，其中Timer是time.AfterFunc的封装，是为了方便聚合到Skeleton中。

github.com/name5566/leaf/timer/timer.go

数据结构Timer，封装了标准库中的Timer，加上一个回调函数cb

Stop接口，将t停掉，并将cb赋为nil

这里封装的只是调用cb

关键还是在这个

这里面封装了一个chan

其中l为chan的缓存容量。

定时功能还是用的标准库中的timer，但定时完之后的处理则是，将处理发送给Dispathcher的chan中

依旧看看在哪里会接收这个

在skeleton中，接收这个cb回调，并进行处理cb回调

再看看cron

上面的代码很简单

这里的主要地方在cb，cb里面嵌套了cb，这个就是实现cron的关键。

skeleton

终于到了skeleton了

github.com/name5566/leaf/module/skeleton.go

再看看skeleton的图

底层的chanrpc，go，time都讲过了

1、g：对应的是g.Go

2、dispatcher：对应的是timer.Dispatcher

3、ChanRPCServer，server，commandServer 对应的是chanrpc server

4、client：对应的是chanrpc client

初始化

各自有各自的容量参数

运行时候：从各自的chan中接收信息，并处理。这就是一个集中异步处理中心。

另外skeleton提供了一些对外的接口

time的AfterFunc

time的CronFunc

Go接口

LinearContext接口

异步的client调用，参数中有server，这个很重要

提供了chanrpc server的注册rpc函数接口

这里的console以后再分析

小结

skeleton是leaf中很重要的模块，担负着异步处理的功能。其分层封装也非常的到位。代码简洁不啰嗦。很赞。

龚浩华

月牙寂道长

QQ 29185807

2018年04月18日