• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

go语言游戏服务端开发(四)——RPC机制

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

五邑隐侠,本名关健昌,12年游戏生涯。 本教程以Go语言为例。

 

RPC指远程方法调用,游戏里引入RPC目的是降低跨进程交互的复杂度。
游戏业务设计为多go routine,一个玩家一个go routine。游戏里RPC客户端阻塞式调用远程(服务进程)方法,这样处理的好处是跨进程交互的业务也可以按照单线程顺序执行的思路实现。
RPC请求包由以下几部分组成:标记(字符串,用于区分是哪类调用)、序列号(一次调用的唯一标记)、方法编号(用于映射调用的方法)、参数。
RPC响应包由以下几部分组成:标记、序列号、方法编号、返回值。
type RpcRequest struct {
    Mark      []byte
    FuncNo    uint16
    SerialNo  uint16
    Params    []byte
}

type RpcResponse struct {
    Mark      []byte
    FuncNo    uint16
    SerialNo  uint16
    ReturnVal    []byte
}

 

RPC建立在P2P网络之上,在 P2pListener interface 的 OnP2pCall(p2p *P2pNet, pack *P2pPack) 实现方法,根据包头前几个字节与 Mark 对比,如果一致则调用对应的RPC客户端/服务端进行处理。
对于RPC服务,可以参考http服务,建立方法编号到处理方法的映射。
type RpcHandler func(params []byte) ([]byte, error)

type RpcServ struct {
    p2p               *P2pNet
    mark              []byte
    mapFuncNo2Handler map[uint16]RpcHandler
}

func (s *RpcServ) HandleFunc(funcNo uint16, handler func(params []byte) ([]byte, error)) {
    if handler == nil {
        return
    }
    s.mapFuncNo2Handler[funcNo] 
= handler }

 

当收到请求后,解析出funcNo和参数Params,调用对应的处理器进行处理。
handler, ok := s.mapFuncNo2Handler[rpc.FuncNo]
if !ok {
    return fmt.Errorf("no handler for funcNo %d", rpc.FuncNo)
}
returnVal, err :
= handler(rpc.Params)

 

RPC服务对请求的处理可以是非阻塞的。
一般只对RPC客户端做成阻塞的,这样在客户端调用远程方法时,客户端会一直等待服务端返回才继续往下执行,整个逻辑流程跟单线程执行一样。
通过序列号SerialNo、方法号 FuncNo 双重确认响应包对应于当前请求。
在go语言里,可以通过定义一个长度为1的 chan byte,请求发出后,读取通道,如果还没有收到响应就会阻塞,响应返回时往通道里写个1,唤醒调用流程继续执行。
func Wait(e chan byte) {
    <-e
}
func Signal(e chan byte) {
    e <- 1
}

 

调用方法的参数和返回值都是二进制,业务可以根据自己的需要用json或 protobuff 进行序列化/反序列化。
func (c *RpcClient) invoke(params []byte) ([]byte, error)

 

RPC调用介绍到这里。接下来介绍下游戏业务进程的实现。
 

鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
【Go】使用Go调用Rest接口发布时间:2022-07-10
下一篇:
windows搭建go开发环境发布时间:2022-07-10
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap