我要评论
ue4 c++联网rpc教程笔记（一）（第1~4集）
前言
本系列笔记将会对梁迪老师的《ue4c++联网rpc框架开发吃鸡》教程进行个人的知识点梳理与总结，此课程也像全反射零耦合框架的课程那样，已经超过报名截止时间了，无法通过正常方法观看。
笔者依旧是采取神奇的方法，通过手机浏览器（不同浏览器的效果有差别，有的会直接要求你登录，遇到这样的就换一个；还有可能点开网页会发现没有播放按钮，遇到这样的就换一个网页）搜索该课程后可以在课程预览界面观看，也可以在目录进行跳转，不过没有字幕。建议是在 pc 端的手机模拟器观看。
本课程集数不多，可以通过目录跳转看完，就不需要复制一串数字到 url 来切换集数了。
笔者用的引擎版本是 4.26.2，老师推荐的引擎版本是 4.20，不同的版本可能在代码上有所区别，笔者会通过注释标明。
本系列文章不允许转载。
本系列笔记可供读者学习后用于复习回顾或参考代码来解决一些敲错了代码导致的 bug。并且笔者只会贴出对应集数修改的代码内容，已经有了的部分代码基本都不会贴出来，以免笔记篇幅过长。
1. 教程介绍与资源
此处列出本课程需要翻阅的网址：虚幻文档关于 rpc 的讲解 >>【】
rpc 的全称是 remote procedure calls 远程过程调用。
本课程篇幅较短，分两步走：1. rpc 基础 2. 分别用蓝图和 c++ 实现监听服务器。
2. 自定义 debug 功能
打开 ue4，创建一个新的 c++ 第三人称游戏项目，需带有初学者内容包，命名为 rpccourse。
如果学过梁迪老师另一个课程《ue4全反射零耦合框架开发坦克游戏》的读者可能会有印象，因为这个自定义 debug 功能也在那个课程里面实现了，学过的读者可自行决定是否再看一遍。
创建以下 c++ 类：
创建一个 object，命名为 rpchelper，路径为默认。
要实现自定义 debug 功能，我们需要用到单例模式
rpchelper.h
#include "coreminimal.h"
// 引入头文件
#include "engine/gameengine.h"
class rpccourse_api ddrecord
{
private:
// 自身单例
static tsharedptr<ddrecord> recordinst;
// 最终输出的字符串
fstring recordinfo;
// 显示时长
float showtime;
// 显示的颜色
fcolor showcolor;
public:
// 构造和析构函数不写内容，并且由于可能会被大量调用所以写成内联函数
inline ddrecord() {}
~ddrecord() {}
static tsharedptr<ddrecord> get();
// 初始化显示时长和颜色
inline void initparam(float intime, fcolor incolor)
{
showtime = intime;
showcolor = incolor;
}
// 实际依赖引擎自带输出逻辑
inline void output()
{
if (gengine)
gengine->addonscreendebugmessage(-1, showtime, showcolor, recordinfo);
// 清空最终输出字符串
recordinfo.empty();
}
// 移位操作符重写，将传入的各种类型数据都转换成 fstring 然后加入最终输出字符串
inline ddrecord &operator<<(fstring info) { recordinfo.append(info); return *this; }
inline ddrecord &operator<<(fname info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(ftext info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(const char* info) { recordinfo += info; return *this; }
inline ddrecord &operator<<(const char info) { recordinfo.appendchar(info); return *this; }
inline ddrecord &operator<<(int32 info) { recordinfo.append(fstring::fromint(info)); return *this; }
inline ddrecord &operator<<(float info) { recordinfo.append(fstring::sanitizefloat(info)); return *this; }
inline ddrecord &operator<<(double info) { recordinfo.append(fstring::sanitizefloat(info)); return *this; }
inline ddrecord &operator<<(bool info) { recordinfo.append(info ? fstring("true") : fstring("false")); return *this; }
inline ddrecord &operator<<(fvector2d info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(fvector info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(frotator info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(fquat info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(ftransform info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(fmatrix info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(fcolor info) { recordinfo.append(info.tostring()); return *this; }
inline ddrecord &operator<<(flinearcolor info) { recordinfo.append(info.tostring()); return *this; }
// 在遇到 ddrecord 对象时（即下文的 endl）输出，即调用 output()
inline void operator<<(ddrecord& record) { record.output(); }
};
namespace ddh
{
forceinline ddrecord& debug(float intime = 3000.f, fcolor incolor = fcolor::yellow)
{
ddrecord::get()->initparam(intime, incolor);
return *ddrecord::get();
}
forceinline ddrecord& endl()
{
return *ddrecord::get();
}
}
rpchelper.cpp
tsharedptr<ddrecord> ddrecord::recordinst = null;
tsharedptr<ddrecord> ddrecord::get()
{
if (!recordinst.isvalid())
recordinst = makeshareable(new ddrecord());
return recordinst;
}
接下来到第三人称项目自带的这个 rpccoursecharacter，重写它的 beginplay() 方法来测试一下我们的自定义 debug 功能。
rpccoursecharacter.h
protected:
void beginplay() override;
rpccoursecharacter.cpp
// 引入头文件
#include "rpchelper.h"
void arpccoursecharacter::beginplay()
{
super::beginplay();
// 输出 debug
ddh::debug(20.f, fcolor::red) << "hello ue4 " << 123 << 0.888 << fvector(30, 40, 50) << fcolor::red << ddh::endl();
}
编译后运行游戏，左上角输出红色的 debug 语句，20 秒后消失。
继续改进下，让 debug 支持更多输出方式，比如输出到 output log 控制台里，并且有日志记录、警告、报错模式。
rpchelper.h
class rpccourse_api ddrecord
{
public:
// 状态模式，0：debug，1：log，2：warning，3：error
uint8 patternid;
public:
inline void output()
{
switch (patternid) {
case 0:
{
if (gengine)
gengine->addonscreendebugmessage(-1, showtime, showcolor, recordinfo);
}
break;
case 1:
{
ue_log(logtemp, log, text("%s"), *recordinfo);
}
break;
case 2:
{
ue_log(logtemp, warning, text("%s"), *recordinfo);
}
break;
case 3:
{
ue_log(logtemp, error, text("%s"), *recordinfo);
}
break;
}
recordinfo.empty();
}
};
namespace ddh
{
forceinline ddrecord& debug(float intime = 3000.f, fcolor incolor = fcolor::yellow)
{
ddrecord::get()->patternid = 0; // 初始化
ddrecord::get()->initparam(intime, incolor);
return *ddrecord::get();
}
// 只改变输出颜色，不管显示时间
forceinline ddrecord& debug(fcolor incolor)
{
return debug(3000.f, incolor);
}
forceinline ddrecord& log()
{
ddrecord::get()->patternid = 1;
return *ddrecord::get();
}
forceinline ddrecord& warning()
{
ddrecord::get()->patternid = 2;
return *ddrecord::get();
}
forceinline ddrecord& error()
{
ddrecord::get()->patternid = 3;
return *ddrecord::get();
}
}
最后测试一下日志记录模式。
rpccoursecharacter.cpp
void arpccoursecharacter::beginplay()
{
super::beginplay();
ddh::log() << "hello ue4 " << 123 << 0.888 << fvector(30, 40, 50) << fcolor::red << ddh::endl();
}
编译后，打开 window -> develop tools -> output log，运行游戏，可以看到日志输出了 debug 语句。
最后将 beginplay() 里的 debug 语句删除掉。
3. actor 的复制
以下知识点内容截取自梁迪老师准备的 rpc 联网文档：
（1）bool 变量 bnetloadonclient
这个变量是给一开始就放置在场景中的对象使用的。
如果bnetloadonclient 设置为 true，当客户端连接上服务端时，客户端也会存在这个对象。
如果 bnetloadonclient 设置为 false，当客户端连接上服务端时，客户端不会存在这个对象。
setreplicates 无论是否为 true 都不会影响这个变量的作用。（关于 setreplicates 下面会讲解）
在默认路径下新建 3 个 c++ 的 actor 类，分别命名为 rpcactor、cubereplicate 和 cubenoreplicate。
我们先用 rpcactor 来测试 bnetloadonclient。
rpcactor.cpp
arpcactor::arpcactor()
{
bnetloadonclient = false; // 设置为 不网络同步到客户端
}
来到角色类，在 beginplay() 里输出场上 rpcactor 实例的数量。
rpccoursecharacter.cpp
// 引入头文件
#include "kismet/gameplaystatics.h"
#include "rpcactor.h"
void arpccoursecharacter::beginplay()
{
super::beginplay();
// 寻找场景中的 rpcactor
tarray<aactor*> actarray;
ugameplaystatics::getallactorsofclass(getworld(), arpcactor::staticclass(), actarray);
ddh::debug() << "rpcactor num --> " << actarray.num() << ddh::endl();
}
编译后，将 c++ 类的 rpcactor 拖进场景，随后作以下设置（对于 4.26 版本会多出第 2 步）。运行后结果如图所示。
输出场景内 rpcactor 的数量为 1 的语句是服务端发出来的，输出数量为 0 的语句则是客户端发出来的。至于为何会分别输出了两遍，是因为在编辑器中，调用引擎自带的屏幕输出方法，会使语句在每个端都输出一次。
同时因为 rpcactor 设置了 bnetloadonclient 为 false，所以 rpcactor 只存在于服务端。
rpcactor.cpp
arpcactor::arpcactor()
{
// 重新设置为 网络同步到客户端
bnetloadonclient = true;
}
编译后，将原本场景里的 rpcactor 删除，重新放置一个 rpcactor。运行游戏，结果如图所示：
这时服务端和客户端的场景里都存在这个 rpcactor 的实例。
（2）setreplicates(bool)
调用 setreplicates(true) 设置 actor 可以复制。
调用 setreplicates(false) 设置 actor 不可以复制。
当在服务端 spawn 可复制的 actor 时，客户端会生成。
当在客户端 spawn 可复制的 actor 时，其他端不会生成。
测试下 setreplicates(bool) 和 bnetloadonclient 共同作用是什么样的效果。
rpcactor.cpp
arpcactor::arpcactor()
{
// bnetloadonclient 设置为 true 时，如果该对象是一开始就在场景中的对象，
// 客户端连接到服务端时该对象也会存在，与 setreplicates 是否为 true 没有关系
setreplicates(true);
bnetloadonclient = false;
}
编译后，将原本场景里的 rpcactor 删除，重新放置一个 rpcactor。运行游戏，结果如图所示：
又变成了客户端没有 rpcactor，服务端有。说明确实 bnetloadonclient 的优先级比 setreplicates(bool) 更高。
接下来单独测试一下 setreplicates(bool)。我们给 cubereplicate 和 cubenoreplicate 添加一些组件方便观察，前者设置可复制，后者设置不可复制。
cubereplicate.h
protected:
ustaticmeshcomponent* cubemesh;
cubereplicate.cpp
// 引入头文件
#include "components/staticmeshcomponent.h"
#include "uobject/constructorhelpers.h"
#include "rpchelper.h"
acubereplicate::acubereplicate()
{
primaryactortick.bcanevertick = true;
// 设置复制
setreplicates(true);
rootcomponent = createdefaultsubobject<uscenecomponent>(text("rootscene"));
cubemesh = createdefaultsubobject<ustaticmeshcomponent>(text("cubemesh"));
cubemesh->setupattachment(rootcomponent);
// 附加模型
constructorhelpers::fobjectfinder<ustaticmesh> staticcubemesh(text("staticmesh'/game/startercontent/shapes/shape_cylinder.shape_cylinder'"));
cubemesh->setstaticmesh(staticcubemesh.object);
}
cubenoreplicate.h
protected:
ustaticmeshcomponent* cubemesh;
cubenoreplicate.cpp
// 引入头文件
#include "components/staticmeshcomponent.h"
#include "uobject/constructorhelpers.h"
#include "rpchelper.h"
acubenoreplicate::acubenoreplicate()
{
primaryactortick.bcanevertick = true;
// 设置不复制
setreplicates(false);
rootcomponent = createdefaultsubobject<uscenecomponent>(text("rootscene"));
cubemesh = createdefaultsubobject<ustaticmeshcomponent>(text("cubemesh"));
cubemesh->setupattachment(rootcomponent);
// 附加模型
constructorhelpers::fobjectfinder<ustaticmesh> staticcubemesh(text("staticmesh'/game/startercontent/shapes/shape_widecapsule.shape_widecapsule'"));
cubemesh->setstaticmesh(staticcubemesh.object);
}
来到 rpcactor，让前面的两个 cube 只在服务端生成。
rpcactor.cpp
// 引入头文件
#include "cubereplicate.h"
#include "cubenoreplicate.h"
#include "rpchelper.h"
arpcactor::arpcactor()
{
//setreplicates(true);
bnetloadonclient = true; // 设置为 网络同步到客户端
}
void arpcactor::beginplay()
{
super::beginplay();
// 判断是不是服务端
if (getworld()->isserver()) {
getworld()->spawnactor<acubereplicate>(acubereplicate::staticclass(), getactorlocation() + fvector::rightvector * 300.f, fquat::identity.rotator());
getworld()->spawnactor<acubenoreplicate>(acubenoreplicate::staticclass(), getactorlocation() - fvector::rightvector * 300.f, fquat::identity.rotator());
}
}
编译后，将场景内的 rpcactor 删除。
新建一个 blueprint 文件夹，在里面创建一个基于 rpcactor 的蓝图，命名为 rpcactor_bp，然后将其拖进场景内。
运行游戏，得到效果如图。可以看到服务端出现了 cubereplicate 和 cubenoreplicate 的实例，但是客户端没有 cubenoreplicate 的实例。说明 setreplicates(bool) 生效了。
再试一下只在客户端生成，只需要在判断条件前面加个 ! 取反就可以了。
rpcactor.cpp
void arpcactor::beginplay()
{
super::beginplay();
// 判断是不是客户端
if (!getworld()->isserver()) {
getworld()->spawnactor<acubereplicate>(acubereplicate::staticclass(), getactorlocation() + fvector::rightvector * 300.f, fquat::identity.rotator());
getworld()->spawnactor<acubenoreplicate>(acubenoreplicate::staticclass(), getactorlocation() - fvector::rightvector * 300.f, fquat::identity.rotator());
}
}
编译后再次运行，可以看到这回服务端场景内没有生成两个 actor 的实例，而客户端出现了 cubereplicate 和 cubenoreplicate 的实例。说明客户端内生成对象时，即便这个对象是可复制的，它也不会生成到服务端。
最后将 rpccoursecharacter.cpp 的 beginplay() 方法里的 debug 语句注释掉。
4. 联网状态判断
本节课需要看的官方参考文档：网络概述 >>【】
以下知识点内容截取自梁迪老师准备的 rpc 联网文档：
（1）aactor 的 hasauthority()，返回 true 是说明 actor 是该端创建的角色。
在关卡蓝图或者是 gamemode 以及默认放在场景中的 actor 等对象使用这个函数可以用来判断是否是服务端，因为关卡蓝图和 gamemode 与默认放在场景中的对象可以看做是由服务端生成的。
不推荐用 hasauthority() 来判断当前端是不是服务端。梁迪老师推荐的用法是用来它来做下面这个 actor 的角色判断。
（2）actor 的角色判断
aactor 里的 enetrole role 枚举是用来识别角色的 actor 的身份的。enetrole 的几个值：
role_none：该 actor 在网络游戏中无角色，不会复制。
role_simulatedproxy：这个 actor 是其他客户端在本机客户端的一个模拟代理
role_autonomousproxy：这个 actor 是本机客户端的自己控制的角色
role_authority：这个 actor 是服务器上的 actor
role_max：官方没有解释，笔者个人猜测应该是代表该枚举的最大枚举值。
（3）是否是服务端判断，不推荐使用 hasauthority() 来判断
推荐使用 getworld()->isserver() 或者 getnetmode() 判断
（4）端的判断
使用 getnetmode() 函数可以获取端的属性 enetmode，分类如下：
nm_standalone：单独端，单机游戏
nm_dedicatedserver：专用服务器
nm_listenserver：监听服务器
nm_client：客户端
nm_max：官方没有解释，笔者个人猜测应该是代表该枚举的最大枚举值。
接下来我们打算测试一下 isserver() 和 hasauthority() 在 “判断当前端是不是服务端” 的需求上表现如何。
在复制 cube 和不复制 cube 的 beginplay() 函数输出一下调用上面两个方法后返回的结果。
cubereplicate.cpp
void acubereplicate::beginplay()
{
super::beginplay();
ddh::debug() << "isserver --> " << getworld()->isserver() << " ; hasauthority() --> " << hasauthority() << " acubereplicate beginplay" << ddh::endl();
}
cubenoreplicate.cpp
void acubenoreplicate::beginplay()
{
super::beginplay();
ddh::debug() << "isserver --> " << getworld()->isserver() << " ; hasauthority() --> " << hasauthority() << " acubenoreplicate beginplay" << ddh::endl();
}
接上一节课结尾的代码，此时两个 cube 的生成逻辑是在客户端上运行的，所以只有在客户端才会生成这两个 cube，服务端不会生成。
编译后运行，可以看到左上角客户端输出的两句 debug 信息，isserver() 返回的结果是 false，符合预期；而 hasauthority() 返回的结果是 true，说明这个方法不一定能判断当前端是服务端还是客户端。
重新调整下，让两个 cube 在服务端生成。
rpcactor.cpp
void arpcactor::beginplay()
{
super::beginplay();
// 将判断表达式的 ! 去掉
if (getworld()->isserver()) {
getworld()->spawnactor<acubereplicate>(acubereplicate::staticclass(), getactorlocation() + fvector::rightvector * 300.f, fquat::identity.rotator());
getworld()->spawnactor<acubenoreplicate>(acubenoreplicate::staticclass(), getactorlocation() - fvector::rightvector * 300.f, fquat::identity.rotator());
}
}
编译后运行，下面和中间的 debug 语句是服务端打印的，上面的 debug 语句是客户端打印的。此时 hasauthority() 确实在服务端则输出了 true，在客户端输出了 false。两次测试结果相比之下还是 isserver() 更适合用于判断当前端的性质。
随后将 cubereplicate 和 cubenoreplicate 的 beginplay() 内的 debug 语句注释掉。
接下来我们测试一下 aactor 的 getnetmode() 方法，用于获取当前端类型 enetmode 的值。
rpcactor.h
protected:
// 获取端类型的枚举后以文本形式输出
void echonetmode();
rpcactor.cpp
void arpcactor::beginplay()
{
// 测试完毕后记得注释掉
echonetmode();
}
void arpcactor::echonetmode()
{
enetmode netmode = getnetmode();
switch (netmode)
{
case nm_standalone:
ddh::debug() << "nm_standalone" << ddh::endl();
break;
case nm_dedicatedserver:
ddh::debug() << "nm_dedicatedserver" << ddh::endl();
break;
case nm_listenserver:
ddh::debug() << "nm_listenserver" << ddh::endl();
break;
case nm_client:
ddh::debug() << "nm_client" << ddh::endl();
break;
case nm_max:
ddh::debug() << "nm_max" << ddh::endl();
break;
}
}
编译后运行游戏，很明显 client 是客户端输出的，listenserver 是服务端输出的。
如果将运行模式调整如下后运行游戏，则会显示 nm_standalone。
发表评论