游戏编程系列[1]--游戏编程中RPC协议的使用

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

RPC（Remote Procedure Call Protocol）——远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层。RPC使得开发包括网络分布式多程序在内的应用程序更加容易。RPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。

首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。

以上摘自，百度百科。

第一个问题是Why？通过一个特定协议定义，我们可以脱离常规的协议定义。使用一个通用协议来达到远程调用的过程。
第二个问题协议？我们选择的是Json协议，好处就是灵活多变，可以使用一个字符串表示所有对象。
坏处就是解析略慢，因为没有长度标识，所以不能搜索，只能一次性解析。不过在于交换场景，这个一点问题都没。

这里是协议定义：

请求定义：

public partial class RequestObj
{
/// <summary>
/// 命令（一般为方法名称）
/// </summary>
public string cmd { get; set; } /// <summary>
/// 名字空间
/// </summary>
public string ns { get; set; } /// <summary>
/// 参数
/// </summary>
public object[] args { get; set; } /// <summary>
/// 请求序号
/// </summary>
public int cid { get; set; } /// <summary>
/// 如果WebSocket才使用
/// </summary>
public string tk { get; set; } /// <summary>
/// 主动版本同步,0则忽略
/// </summary>
public int ver { get; set; }}

响应定位：

/// <summary>
/// 返回数据
/// </summary>
public partial class ResponseObj
{
/// <summary>
/// 返回数据对象
/// </summary>
public object result { get; set; } /// <summary>
/// 是否出错信息
/// 默认0 无出错信息
/// </summary>
public int error { get; set; } /// <summary>
/// 请求序号
/// </summary>
public int cid { get; set; } /// <summary>
/// 差异数据
/// </summary>
public OpChangeItem[] opstr{ get; set; } }

疑问：
object，这是一个不科学的设定？这边待保留。
OpChangeItem，这个是什么鬼？依然保留。

这里我们尝试来进行一次调用构造。

特定方法：

public class LocalTest
{
/// <summary>
/// 添加一个消息
/// </summary>
public static void AddMessage(string topic, string messageBody)
{
//这里什么都不干
}
}

发送消息:

{"args":["Test","Message"],"cid":"1","cmd":"AddMessage","ns":"LocalTest","tk":null}

从以上我们可以解析出来

类名：LocalTest, 调用方法名:AddMessage,参数[topic : Test , messageBody:Message]

通过反射调用，我们就完成了执行的目的。

然后是返回值：

调用完成后，返回消息:

{"result": null , "error" : 0 ,"cid" : 1, "opstr":[] }

注:cid的设定是为了区分调用的请求源，如果你有多个调用同时发起，那么cid拿来区分你的来源，从而达到返回值的匹配。

从以上例子看出，我们调用了一个AddMessage方法，服务端进行了响应，然后什么事情都没发生。

我们这里的协议，抛开Opstr字段已经可以完整的描述一整个调用，因为返回值，和参数都用的object，
所以只要知道类型，那么可以通过json转换成对应的参数和类型，所以我们无需特别约定协议即可以得到特定的类型。

然后我们进行修改

public void AddMessage(string topic, string messageBody,Action callback)
{
try
{
//这边进行一次封装，直接把当前的方法调用包装成请求，然后通过标记，判是否是本地执行，
//如果是本地执行，则执行本地
var __cid = WindNet.RemoteCall.Instance.DoCall(callback, this, "LocalTest.AddMessage", topic,messageBody);
if (WindNet.RemoteCall.Instance.IsLocal || __cid.isLocal)
{
//原本执行的事情
//这里什么都不干
if(callback!=null)
callback();
}
//如果是远程调用，则什么都不干。
}
catch (Exception)
{
WindNet.RemoteCall.Instance.DoError(e);
throw;
}
}

首先我们加了个callback参数，当执行完毕之后，我们调用一下callback
因为网络是一个不稳定的玩意，如果你一直在等待，则可能卡住主线程，在游戏中你的渲染就无法进行，那么我们使用callback来进行流程处理。
以及返回值的处理。
流程就是这样，你调用函数-》构造请求-》发起请求-》服务器返回后-》调用callbak
如果我们把IsLocal 设为true
流程就是
你调用函数-》构造请求（不发出）-》执行本地方法-》执行callback

经过我们的设计，我们在执行函数前进行了一次简单的拦截，然后通过通用协议和cid进行callback的匹配，然后达到正确的回调过程。