leaf源码分析(二)----skeleton

时间:2024-03-18 15:40:55

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



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


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

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


leaf源码分析(二)----skeleton

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

下面一个一个分析


g

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

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

1、Go

leaf源码分析(二)----skeleton

chancb:用于传送call back函数

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

leaf源码分析(二)----skeleton


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

leaf源码分析(二)----skeleton


1、pengdingo:加1,记录调用计数

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

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

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

看下skeleton中的处理部分

leaf源码分析(二)----skeleton


在skeleton中,会详细再介绍。


继续看源码

leaf源码分析(二)----skeleton


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

leaf源码分析(二)----skeleton


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

2、LinearContext

leaf源码分析(二)----skeleton

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

leaf源码分析(二)----skeleton


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

leaf源码分析(二)----skeleton


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

leaf源码分析(二)----skeleton



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

leaf源码分析(二)----skeleton


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

leaf源码分析(二)----skeleton


这里封装的只是调用cb


关键还是在这个

leaf源码分析(二)----skeleton


这里面封装了一个chan

leaf源码分析(二)----skeleton


其中l为chan的缓存容量。

leaf源码分析(二)----skeleton


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


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

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

leaf源码分析(二)----skeleton



再看看cron

leaf源码分析(二)----skeleton


上面的代码很简单

leaf源码分析(二)----skeleton

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


skeleton

终于到了skeleton了

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

再看看skeleton的图

leaf源码分析(二)----skeleton


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

leaf源码分析(二)----skeleton



1、g:对应的是g.Go

2、dispatcher:对应的是timer.Dispatcher

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

4、client:对应的是chanrpc client

leaf源码分析(二)----skeleton


初始化

各自有各自的容量参数

leaf源码分析(二)----skeleton


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

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


leaf源码分析(二)----skeleton

time的AfterFunc


leaf源码分析(二)----skeleton

time的CronFunc


leaf源码分析(二)----skeleton

Go接口


leaf源码分析(二)----skeleton

LinearContext接口


leaf源码分析(二)----skeleton

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



leaf源码分析(二)----skeleton

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


leaf源码分析(二)----skeleton

这里的console以后再分析


小结

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



龚浩华

月牙寂道长

QQ 29185807

2018年04月18日

如果你觉得本文对你有帮助,可以转发分享到你的朋友圈,让更多人一起学习。

第一时间获取文章,可以关注本人公众号:月牙寂道长,也可以扫码关注

leaf源码分析(二)----skeleton

最后感谢关注本人公众号。
如果想查看历史文章,可以点击公众号下方的按钮“历史文章”
或者点击公众号下方按钮“文章目录”获取所有文章的索引文件