游戏服务器引擎 gRPC Lua 教程 - 开发指南 - 文档中心

游戏服务器引擎

文档中心游戏服务器引擎开发指南服务器集成 gRPC 框架 gRPC Lua 教程

gRPC Lua 教程

最近更新时间：2020-07-16 15:51:38

前往 GitHub 编辑 我的收藏

本页目录：

安装 gRPC

安装 gRPC，安装完后会生成 grpc_cpp_plugin 可执行程序，该程序在生成 gRPC 代码时需要。
安装 protocol buffers。

说明：

具体安装流程请您参考安装 gRPC Lua 的说明，安装 protocol buffers 的说明。

定义服务

gRPC 通过 protocol buffers 实现定义一个服务：一个 RPC 服务通过参数和返回类型来指定可以远程调用的方法。

说明：

我们提供定义服务的 proto 文件，请您在 proto 文件里下载使用，无需自己生成。

生成 gRPC 代码

定义好服务后，通过 protocol buffer 编译器 protoc 生成客户端和服务端的代码（任意 gRPC 支持的语言）。
生成的代码包括客户端的存根和服务端要实现的抽象接口。
生成 gRPC 代码步骤：
Lua DEMO 依赖 C++ 框架，步骤同 C++ DEMO 一样，在 proto 目录下执行：
```
protoc --cpp_out=. *.proto
```
生成 pb.cc 和 pb.h 文件。
```
protoc --grpc_out=. --plugin=protoc-gen-grpc=`which grpc_cpp_plugin` *.proto
```
生成对应的 gRPC 代码。
将生成的8个文件移到项目合适的位置。

游戏进程集成流程

服务端接口列表

接口名称	接口功能
OnHealthCheck	健康检查
OnStartGameServerSession	接收游戏服务器会话
OnProcessTerminate	结束游戏进程

客户端接口列表

接口名称	接口功能
ProcessReady	进程准备就绪
ActivateGameServerSession	激活游戏服务器会话
AcceptPlayerSession	接收玩家会话
RemovePlayerSession	移除玩家会话
DescribePlayerSessions	获取玩家会话列表
UpdatePlayerSessionCreationPolicy	更新玩家会话的创建策略
TerminateGameServerSession	结束游戏服务器会话
ProcessEnding	结束进程
ReportCustomData	上报自定义数据

其他

请求 meta，在游戏进程通过 gRPC 调用客户端接口时，需要在 gRPC 请求的 meta 里添加两个字段。

字段	含义	类型
pid	当前游戏进程的 pid	string
requestId	当前请求的 requestId，已使用唯一标记一次请求	string

一般在服务端初始化后，进程检查自身是否可对外提供服务，Game Server 调用 ProcessReady 接口，告知 GSE 进程准备就绪，已准备好托管游戏服务器会话，GSE 接收到后，将服务器实例状态更改为“活跃”。

static bool luaProcessReady(std::vector <std::string> &logPath, int clientPort, int grpcPort) {
    GseResponse reply;
    //日志路径，设置端口
    Status status = GGseManager->ProcessReady(logPath, clientPort, grpcPort, reply);
    //准备就绪，可对外提供服务
    GSESDK()->setReplyStatus(status);
    if (!status.ok()) {
        return false;
    }
    return true;
}

进程准备就绪后，GSE 调用 OnHealthCheck 接口，对 Game Server 进行健康检查，每1分钟检查1次，连续3次失败就判定该进程不健康，不会分配游戏服务器会话至该进程。

Status GameServerGrpcSdkServiceImpl::OnHealthCheck(ServerContext* context, const HealthCheckRequest* request,  HealthCheckResponse* reply)
{
    healthStatus = GSESDK()->exec("return OnHealthCheck()");
    std::cout << "healthStatus=" << healthStatus << std::endl;
    reply->set_healthstatus(healthStatus);
    return Status::OK;
}

因为 Client 调用 CreateGameServerSession 接口创建一个游戏服务器会话，将该游戏服务器会话分配给一个进程，所以触发 GSE 调用该进程的 onStartGameServerSession 接口，并且将 GameServerSession 状态更改为“激活中”。

Status GameServerGrpcSdkServiceImpl::OnStartGameServerSession(ServerContext* context, const StartGameServerSessionRequest* request,  GseResponse* reply)
{
    auto gameServerSession = request->gameserversession();
    GGseManager->SetGameServerSession(gameServerSession);

    std::ostringstream o;
    o << "return OnStartGameServerSession('" << gameServerSession.gameserversessionid() << "'," << gameServerSession.maxplayers() << ")";
    std::string luaCmd = o.str();

    bool res = GSESDK()->exec(luaCmd);

    return Status::OK;
}

当 Game Server 收到 onStartGameServerSession，您自行处理一些逻辑或资源分配，准备就绪后，Game Server 就调用ActivateGameServerSession 接口，通知 GSE 游戏服务器会话已分配给一个进程，现在已准备好接收玩家请求，将服务器状态更改为“活跃”。

static bool luaActivateGameServerSession(const std::string &gameServerSessionId, int maxPlayers) {
    GseResponse reply;
    Status status = GGseManager->ActivateGameServerSession(gameServerSessionId, maxPlayers, reply);
    GSESDK()->setReplyStatus(status);
    if (!status.ok()) {
            return false;
    }
    return true;
}

当 Client 调用 JoinGameServerSession 接口玩家加入后，Game Server 调用 AcceptPlayerSession 接口验证玩家合法性，如果连接被接受，则将 PlayerSession 状态设置为“活跃”。如果 Client 调用 JoinGameServerSession 接口在60秒内未收到响应，则将 PlayerSession 状态更改为“超时”，然后重新调用 JoinGameServerSession。

static bool luaAcceptPlayerSession(const std::string &gameServerSessionId, const std::string &playerSessionId) {
    GseResponse reply;
    Status status = GGseManager->AcceptPlayerSession(gameServerSessionId, playerSessionId, reply);
    GSESDK()->setReplyStatus(status);
    if (!status.ok()) {
            return false;
    }
    return true;
}

游戏结束或者玩家退出后，Game Server 调用 RemovePlayerSession 接口移除玩家，将 playersession 状态更改为“已完成” ，并预留游戏服务器会话中的玩家位置。

static bool luaRemovePlayerSession(const std::string &gameServerSessionId, const std::string &playerSessionId) {
    GseResponse reply;
    Status status = GGseManager->RemovePlayerSession(gameServerSessionId, playerSessionId, reply);
    GSESDK()->setReplyStatus(status);
    if (!status.ok()) {
            return false;
    }
    return true;
}

当一个游戏服务器会话（一组游戏对局或一个服务）结束后，Game Server 调用 TerminateGameServerSession 接口结束 GameServerSession，将 GameServerSession 状态更改为“已终止”。

static bool luaTerminateGameServerSession(const std::string &gameServerSessionId) {
    GseResponse reply;
    Status status = GGseManager->TerminateGameServerSession(gameServerSessionId, reply);
    GSESDK()->setReplyStatus(status);
    if (!status.ok()) {
            return false;
    }
    return true;
}

当健康检查失败或缩容时，GSE 调用 OnProcessTerminate 接口结束游戏进程，缩容时依据是您在 GSE 控制台配置的保护策略。

Status GameServerGrpcSdkServiceImpl::OnProcessTerminate(ServerContext* context, const ProcessTerminateRequest* request,  GseResponse* reply)
{
    auto terminationTime = request->terminationtime();
    std::to_string(terminationTime));
    std::ostringstream o;
    o << "OnProcessTerminate(" << terminationTime << ")";
    std::string luaCmd = o.str();

    GSESDK()->execWithNilResult(luaCmd);

    return Status::OK;
}

Game Server 调用 ProcessEnding 接口会立刻结束进程，将服务器进程状态更改为“已终止”，并回收资源。

//主动调用：一局游戏对应一个进程，当一局游戏结束后主动调用ProcessEnding接口
//被动调用：当缩容或进程异常健康检查失败时，根据保护策略被动调用ProcessEnding接口，配置完全保护和时限保护策略时需要先判断游戏服务器会话上有无玩家，再被动调用
static bool luaProcessEnding() {
    GseResponse reply;
    Status status = GGseManager->ProcessEnding(reply);
    GSESDK()->setReplyStatus(status);
    if (!status.ok()) {
            return false;
    }
    return true;
}

Game Server 调用 DescribePlayerSessions 接口获取游戏服务器会话下的玩家信息（根据业务可选）。

static bool luaDescribePlayerSessions(const std::string &gameServerSessionId, 
                                       const std::string &playerId,
                                       const std::string &playerSessionId,
                                       const std::string &playerSessionStatusFilter, const std::string &nextToken,
                                       int limit) {
   DescribePlayerSessionsResponse reply;
   Status status = GGseManager->DescribePlayerSessions(gameServerSessionId,playerId, playerSessionId, playerSessionStatusFilter, nextToken, limit, reply);

   GSESDK()->setDescribePlayerSessionsResponse(reply);
   if (!status.ok()) {
           return false;
   }
   return true;
}

Game Server 调用 UpdatePlayerSessionCreationPolicy 接口更新玩家会话的创建策略，设置是否接受新玩家，即游戏会话里是否允许加入人（根据业务可选）。

static bool luaUpdatePlayerSessionCreationPolicy(const std::string &newpolicy) {
   GseResponse reply;
   Status status = GGseManager->UpdatePlayerSessionCreationPolicy(newpolicy, reply);
   GSESDK()->setReplyStatus(status);
   if (!status.ok()) {
           return false;
   }
   return true;
}

Game Server 调用 ReportCustomData 接口告知 GSE 的自定义数据（根据业务可选）。

static bool luaReportCustomData(int currentCustomCount, int maxCustomCount) {
   GseResponse reply;
   Status status = GGseManager->ReportCustomData(currentCustomCount, maxCustomCount, reply);
   GSESDK()->setReplyStatus(status);
   if (!status.ok()) {
           return false;
   }
   return true;
}

启动服务端，供 GSE 调用

服务端运行：将 GrpcServer 启动起来。

// 启动grpc server
    std::thread tGrpc(&GameServerGrpcSdkServiceImpl::StartGrpcServer, GGameServerGrpcSdkService);
    sem_wait(&(GGameServerGrpcSdkService->sem));
    auto grpcPort = GGameServerGrpcSdkService->GetGrpcPort();

客户端连接 GSE 的 gRPC 服务端

连接服务端：创建一个 gRPC 频道，指定我们要连接的主机名和服务器端口，然后用这个频道创建存根实例。

void GseManager::InitStub() {
        auto channel = grpc::CreateChannel("127.0.0.1:5758", grpc::InsecureChannelCredentials());
        stub_ = GseGrpcSdkService::NewStub(channel);
}

Lua DEMO

单击这里，您可下载 Lua DEMO 代码。
生成 gRPC 代码。
Lua DEMO 依赖 C++ 框架，已生成的 gRPC 代码在 cpp-demo/source/grpcsdk 目录下，不需要额外生成。
启动服务端，供 GSE 调用。
- 服务端实现。
  在 lua-demo/source/api 目录下的 grpcserver.cpp，实现了服务端的三个接口。
- 服务端运行。
  在 lua-demo 目录下的 main.cpp，将 GrpcServer 启动起来。
客户端连接 GSE 的 gRPC 服务端。
- 客户端实现。
  在 lua-demo/source/lua 目录下的 GSESdkHandleWrapper.cpp，实现了客户端的九个接口。
- 连接服务端。
  创建一个 gRPC 频道，指定我们要连接的主机名和服务器端口，然后用这个频道创建存根实例。
编译运行。
1. 安装 cmake。
2. 安装 gcc，版本要求4.9以上。
3. 安装 luajit 开发包和 boost 开发包：
```
yum install -y luajit-devel
yum install -y boost-devel
yum install -y cmake
```
4. 将代码下载，在 lua-demo 目录下，执行以下命令：
```
mkdir build
cd build
cmake ..
make
cp ../source/lua/gse.lua .
```
  会生成对应的 lua-demo 可执行文件，执行 ./lua-demo 启动。
5. 将可执行文件 lua-demo.cpp 打包为生成包，启动路径配置 lua-demo，无启动参数。
6. 然后创建服务器舰队，将生成包部署在服务器舰队上，后续可进行扩缩容等一系列操作。

上一篇: gRPC Java 教程下一篇: gRPC Nodejs 教程

产品动态

产品简介

购买指南

快速入门

操作指南

开发指南

API 文档

SDK 文档

常见问题

服务等级协议

联系我们

词汇表

本页目录：

安装 gRPC

定义服务

生成 gRPC 代码

游戏进程集成流程

服务端接口列表

客户端接口列表

其他

启动服务端，供 GSE 调用

客户端连接 GSE 的 gRPC 服务端

Lua DEMO

热门搜索

产品动态

产品简介

购买指南

快速入门

操作指南

开发指南

API 文档

SDK 文档

常见问题

服务等级协议

联系我们

词汇表

本页目录：

安装 gRPC

定义服务

生成 gRPC 代码

游戏进程集成流程

服务端接口列表

客户端接口列表

其他

启动服务端，供 GSE 调用

客户端连接 GSE 的 gRPC 服务端

Lua DEMO