ngl_server 1.0
基于 Actor 模型的 C++ 服务器框架
ngl::actor_robot Class Reference

机器人Actor类 More...

#include <actor_robot.h>

Inheritance diagram for ngl::actor_robot:
ngl::actor ngl::actor_base

Public Member Functions

 actor_robot (const actor_robot &)=delete
actor_robot & operator= (const actor_robot &)=delete
 actor_robot (i16_area aarea, i32_actordataid arobotid, void *)
 构造函数
virtual void init ()
 初始化机器人Actor,加载行为树配置并设置tick定时器
virtual void loaddb_finish (pbdb::ENUM_DB atype, enum_dbstat astat)
 数据库加载完成回调
bool timer_handle (const message< np_timerparm > &adata)
 定时器回调,驱动行为树tick
void ukcp_connect (pbnet::ENUM_KCP akcpenum)
 发起KCP连接
bool handle (const message< np_thruput_test > &adata)
 处理吞吐量测试消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO01_INIT > &adata)
 处理Demo01场景初始化消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO01_MAP_LIST_RESPONSE > &adata)
 处理Demo01地图列表响应
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO01_SHAPE_INFO > &adata)
 处理Demo01形状信息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_BULLET_REMOVE > &adata)
 Handle Demo03 bullet removal.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_BULLET_SPAWN > &adata)
 Handle Demo03 bullet spawn.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_COMBAT_EVENT > &adata)
 Handle Demo03 combat event.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_INIT > &adata)
 Handle Demo03 battlefield init.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_LOADOUT > &adata)
 Handle Demo03 loadout and skill state sync.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_MAP_LIST_RESPONSE > &adata)
 Handle Demo03 map list response.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_PLAYER_STATE > &adata)
 Handle Demo03 player state sync.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_SUPPLY_REMOVE > &adata)
 Handle Demo03 supply remove.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_DEMO03_SUPPLY_SPAWN > &adata)
 Handle Demo03 supply spawn.
bool handle (const message< pbexample::PROBUFF_EXAMPLE_GUESS_NUMBER_BOMB > &adata)
 处理猜数字炸弹消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_GUESS_NUMBER_ERROR > &adata)
 处理猜数字错误消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_GUESS_NUMBER_INFO > &adata)
 处理猜数字信息消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_PLAY_CREATE > &adata)
 处理玩法创建消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_PLAY_ENTER_EXAMPLE_RESPONSE > &adata)
 处理进入玩法响应
bool handle (const message< pbexample::PROBUFF_EXAMPLE_PLAY_JOIN_RESPONSE > &adata)
 处理加入玩法响应
bool handle (const message< pbexample::PROBUFF_EXAMPLE_PLAY_MATCHING > &adata)
 处理匹配消息
bool handle (const message< pbexample::PROBUFF_EXAMPLE_PLAY_MATCHING_RESULT > &adata)
 处理匹配结果消息
bool handle (const message< pbnet::PROBUFF_NET_AOI_ENTER_MAP > &adata)
 处理AOI进入地图消息
bool handle (const message< pbnet::PROBUFF_NET_AOI_GRID_CHANGE > &adata)
 处理AOI网格变化消息
bool handle (const message< pbnet::PROBUFF_NET_BAG_SYNC_RESPONSE > &adata)
 处理背包同步响应
bool handle (const message< pbnet::PROBUFF_NET_BAG_UPDATE > &adata)
 处理背包更新消息
bool handle (const message< pbnet::PROBUFF_NET_CHAT_RESPONSE > &adata)
 处理聊天响应
bool handle (const message< pbnet::PROBUFF_NET_DELIVER_GOODS_RECHARGE > &adata)
 处理充值发货消息
bool handle (const message< pbnet::PROBUFF_NET_ENTER_LEAVE_VIEW > &adata)
 处理视野进出消息
bool handle (const message< pbnet::PROBUFF_NET_ERROR > &adata)
 处理错误消息
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_CEDE_RESPONSE > &adata)
 处理家族转让响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_CHANGENAME_RESPONSE > &adata)
 处理家族改名响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_CREATE_RESPONSE > &adata)
 处理家族创建响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_INFO_RESPONSE > &adata)
 处理家族信息响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_JOIN_RESPONSE > &adata)
 处理家族加入响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_LEAVE_RESPONSE > &adata)
 处理家族离开响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_LIST_RESPONSE > &adata)
 处理家族列表响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_RATIFY_JOIN_RESPONSE > &adata)
 处理家族批准加入响应
bool handle (const message< pbnet::PROBUFF_NET_FAMIL_SIGN_RESPONSE > &adata)
 处理家族签到响应
bool handle (const message< pbnet::PROBUFF_NET_FRIEND_ADD_RESPONSE > &adata)
 处理好友添加响应
bool handle (const message< pbnet::PROBUFF_NET_FRIEND_ERASE_RESPONSE > &adata)
 处理好友删除响应
bool handle (const message< pbnet::PROBUFF_NET_FRIEND_RATIFY_ADD_RESPONSE > &adata)
 处理好友批准添加响应
bool handle (const message< pbnet::PROBUFF_NET_FRIEND_RESPONSE > &adata)
 处理好友列表响应
bool handle (const message< pbnet::PROBUFF_NET_GET_TIME_RESPONSE > &adata)
 处理获取时间响应
bool handle (const message< pbnet::PROBUFF_NET_KCPSESSION_RESPONSE > &adata)
 处理KCP会话响应
bool handle (const message< pbnet::PROBUFF_NET_MAIL_DEL_RESPONSE > &adata)
 处理邮件删除响应
bool handle (const message< pbnet::PROBUFF_NET_MAIL_DRAW_RESPONSE > &adata)
 处理邮件领取响应
bool handle (const message< pbnet::PROBUFF_NET_MAIL_LIST_RESPONSE > &adata)
 处理邮件列表响应
bool handle (const message< pbnet::PROBUFF_NET_MAIL_READ_RESPONSE > &adata)
 处理邮件已读响应
bool handle (const message< pbnet::PROBUFF_NET_MSG_RESPONSE > &adata)
 处理消息响应
bool handle (const message< pbnet::PROBUFF_NET_NOTICE_RESPONSE > &adata)
 处理公告响应
bool handle (const message< pbnet::PROBUFF_NET_RANKLIST_RESPONSE > &adata)
 处理排行榜响应
bool handle (const message< pbnet::PROBUFF_NET_RECHARGE_RESPONSE > &adata)
 处理充值响应
bool handle (const message< pbnet::PROBUFF_NET_REWARD_ITEM_RESPONSE > &adata)
 处理奖励物品响应
bool handle (const message< pbnet::PROBUFF_NET_ROLESTAT > &adata)
 处理角色状态消息
bool handle (const message< pbnet::PROBUFF_NET_ROLE_SYNC_RESPONSE > &adata)
 处理角色数据同步响应
bool handle (const message< pbnet::PROBUFF_NET_SWITCH_LINE_RESPONSE > &adata)
 处理切换线路响应
bool handle (const message< pbnet::PROBUFF_NET_SYNC_ATTRIBUTE > &adata)
 处理属性同步消息
bool handle (const message< pbnet::PROBUFF_NET_SYNC_POSITION > &adata)
 处理位置同步消息
bool handle (const message< pbnet::PROBUFF_NET_SYNC_UNIT > &adata)
 处理单元同步消息
bool handle (const message< pbnet::PROBUFF_NET_TASK_RECEIVE_AWARD_RESPONSE > &adata)
 处理任务领奖响应
Public Member Functions inherited from ngl::actor
template<typename TDerived>
void init_rfun ()
 初始化消息分发器。
 actor (const actorparm &aparm)
 构造函数。
actor_stat activity_stat () final
 获取调度器可见的生命周期状态。
void set_activity_stat (actor_stat astat) final
 更新调度器可见的生命周期状态。
void release () final
 停止actor,排空队列中的工作,并持久化DB支持的状态。
bool list_empty () final
 检查普通队列和优先级队列是否都为空。
bool pending_empty () final
 检查高优先级队列是否为空
bool high_empty () final
 检查优先级队列是否为空。
std::optional< int32_t > hight_value ()
 获取当前最高优先级值。
bool push (handle_pram &apram) final
 将传入任务入队到相应的优先级队列。
bool actor_handle (i32_threadid athreadid) final
 在指定的工作线程上运行一个调度切片。
template<typename T>
bool ahandle (const std::shared_ptr< T > &aparm)
 处理类型化消息。
bool ahandle (i32_threadid athreadid, handle_pram &aparm)
 处理消息队列中的消息。
virtual void broadcast ()
 广播消息处理钩子。
bool handle_broadcast (const message< np_actor_broadcast > &adata)
 合成广播消息的内部入口点。
bool handle_close (const message< np_actor_close > &)
 合成关闭消息的内部入口点。
template<typename TMESSAGE>
bool handle_script (const message< TMESSAGE > &adata)
 将类型化消息转发到附加的脚本运行时。
Public Member Functions inherited from ngl::actor_base
 actor_base (const actorparmbase &aparm)
 Actor基类构造函数
nreadyready ()
std::unique_ptr< nmanage_dbclient > & manage_dbclient ()
void set_db_component (ndb_component *acomponent)
void db_component_init_data ()
void init_db_component (bool acreate)
void add_dbclient (ndbclient_base *adbclient, i64_actorid aid)
template<pbdb::ENUM_DB DBTYPE, typename TDBTAB, typename TACTOR>
bool handle_db (const message< np_actordb_load_response< DBTYPE, TDBTAB > > &adata)
virtual void handle_after (handle_pram &)
virtual void erase_actor_before ()
virtual void save ()
bool is_single () const
const nguidguid () const
i64_actorid id_guid () const
i32_actordataid id () const
i16_area area () const
ENUM_ACTOR type () const
virtual void erase_actor ()
 从actor_manage中注销并销毁此Actor
bool nscript_using () const
bool nscript_db_loadfinish () const
template<typename T>
bool nscript_data_push (const char *asource, const T &adata, bool aedit)
template<typename T>
bool nscript_data_del (int64_t adataid)
template<typename T>
bool nscript_data_checkout (int64_t adataid, T &adata)
template<typename T>
bool nscript_data_checkout (std::map< int64_t, T > &adata)
template<typename T>
bool nscript_data_checkdel (int64_t adataid)
template<typename T>
bool nscript_data_checkdel (std::vector< int64_t > &adeldata)
template<typename T>
bool nscript_handle (const T &adata)
void kcp_setindex (i32_serverid aserverid, pbnet::ENUM_KCP aenum, i16_port akcpindex)
std::optional< i16_portkcp_index (i32_serverid aserverid, pbnet::ENUM_KCP aenum)
std::optional< i16_portkcp_index (int16_t aservertid, int16_t atcount, pbnet::ENUM_KCP aenum)
bool kcp_connect (i16_port auport, const std::string &aip, i16_port aprot, i64_actorid aactoridserver, std::string &akcpsession) const
int64_t set_timer (const np_timerparm &aparm)
 为当前Actor设置定时器
bool isbroadcast () const
void set_broadcast (bool aisbroadcast)
template<typename T>
void handle_print (const message< T > &adata) const

Static Public Member Functions

static ENUM_ACTOR actor_type ()
 返回Actor类型 ACTOR_ROBOT
static i64_actorid actorid (int32_t adataid)
 根据数据ID生成完整的机器人ActorID
static void nregister ()
 注册机器人Actor的消息处理器和行为树节点
Static Public Member Functions inherited from ngl::actor
template<typename TDerived>
static void register_timer (Tfun< TDerived, np_timerparm > afun=&TDerived::timer_handle)
 注册定时器回调函数。
template<typename TDerived, typename T>
static void register_actor_s (const std::function< void(TDerived *, const message< T > &)> &afun)
 注册基于std::function的消息处理器。
template<typename TDerived, typename ... ARG>
static void register_actor (ARG... afun)
 注册一个或多个强类型消息处理器。
template<typename TDerived, typename T>
static void register_actornonet (const Tfun< TDerived, T > afun)
 注册本地专用消息处理器(不来自网络协议分发)。
template<typename TDerived, typename ... ARG>
static void register_handle ()
 注册TDerived::handle作为消息处理器。
template<typename TDerived, typename ... ARG>
static void register_script_handle ()
 注册脚本支持的消息处理器。
template<typename TDerived, typename ... ARG>
static void register_forward_c2g ()
 注册客户端到网关的转发处理器。
template<typename TDerived, typename ... ARG>
static void register_forward_g2c ()
 注册网关到客户端的转发处理器。
template<typename TDerived, ENUM_ACTOR ACTOR, typename ... ARG>
static void register_secondary_forward_c2g ()
 注册中继actor的二级转发辅助器。
Static Public Member Functions inherited from ngl::actor_base
static void erase_actor (const nguid &aguid)
static std::shared_ptr< packjsonpack (const std::string &apbname, const std::string &ajson, i64_actorid aactorid, i64_actorid arequestactorid, bool ahead=false)
template<typename T>
static std::shared_ptr< packnet_pack (T &adata, i64_actorid aactorid, i64_actorid arequestactorid, bool ahead=false)
static bool send_pack (i32_sessionid asession, std::shared_ptr< pack > &apack)
template<typename T>
static bool send (i32_sessionid asession, const T &adata, i64_actorid aactorid, i64_actorid arequestactorid)
template<typename T>
static bool send_server (i32_serverid aserverid, const T &adata, i64_actorid aactorid, i64_actorid arequestactorid)
template<typename T>
static bool send_server (const std::set< i32_serverid > &aserverids, const T &adata, i64_actorid aactorid, i64_actorid arequestactorid)
static bool send_server (i32_serverid aserverid, std::shared_ptr< pack > &apack)
static bool kcp_sendpack (i64_actorid aactorid, std::shared_ptr< pack > &adata, i16_port auport=0)
static bool kcp_sendpack (const std::set< i64_actorid > &aactorids, std::shared_ptr< pack > &adata, i16_port auport=0)
template<typename T>
static bool kcp_send (i64_actorid aactorid, const T &adata, i16_port auport=0)
 向单个Actor发送KCP数据(actor_base模板实现)。
template<typename T>
static bool kcp_send (const std::set< i64_actorid > &aactorids, const T &adata, i16_port auport=0)
 向一组Actor广播KCP数据(actor_base模板实现)。
static i64_actorid actorclient_guid ()
template<typename T>
static void send_client (const std::set< i64_actorid > &aids, const T &adata, ENET_PROTOCOL aprotocol=ENET_TCP)
template<typename T>
static void send_client (i64_actorid aid, const T &adata, ENET_PROTOCOL aprotocol=ENET_TCP)
template<typename T>
static void send_client (const std::vector< i64_actorid > &aids, const T &adata, ENET_PROTOCOL aprotocol=ENET_TCP)
template<typename T>
static void send_client (const T &adata, ENET_PROTOCOL aprotocol=ENET_TCP)
template<typename T>
static void send_clientbyarea (i16_area aarea, const T &adata, ENET_PROTOCOL aprotocol=ENET_TCP)
static void send_actor (const nguid &aguid, const std::shared_ptr< pack > &adata)
 向指定Actor发送消息包
template<typename T, bool IS_SEND = true>
static void send_actor (ENUM_ACTOR atype, const std::shared_ptr< T > &adata)
template<typename T, bool IS_SEND = true>
static void send_actor (const nguid &aguid, const nguid &arequestguid, const std::shared_ptr< T > &adata)
template<typename T, bool IS_SEND = true>
static void send_actor (const nguid &aguid, const nguid &arequestguid, const std::shared_ptr< T > &adata, const std::function< void()> &afailfun)
template<typename T, bool IS_SEND = true>
static void send_actor (const std::set< i64_actorid > &asetguid, const nguid &arequestguid, const std::shared_ptr< T > &adata)
static void start_broadcast ()
 启动全局广播定时器
template<typename TDerived>
static void first_nregister (ENUM_ACTOR atype)
template<typename TACTOR, typename ... ARG>
static std::shared_ptr< actor_basecreate (i16_area aarea, i32_actordataid aid, ARG &&... args)
 actor工厂方法(编译期类型)
template<typename ... ARG>
static std::map< ENUM_ACTOR, create_fun< ARG... > > & creators ()
template<ENUM_ACTOR EACTOR, typename TACTOR, typename ... ARG>
static void cregister ()
template<typename ... ARG>
static std::shared_ptr< actor_basecreate (ENUM_ACTOR atype, i16_area aarea, i32_actordataid aid, ARG &&... args)
 actor工厂方法(运行时类型,查分桶表转调编译期create<TACTOR>)

Public Attributes

i32_session m_session = 0
_robotm_robot = nullptr
bool m_firstsync = false
bool m_demo01_active = false
int32_t m_demo01_mapid = 0
float m_demo01_move_angle = 0.0f
int64_t m_demo01_next_change_ms = 0

Additional Inherited Members

Public Types inherited from ngl::actor_base
template<typename ... ARG>
using create_fun = std::function<std::shared_ptr<actor_base>(i16_area, i32_actordataid, ARG...)>

Detailed Description

机器人Actor类

继承自actor基类,通过行为树驱动AI决策,模拟玩家客户端行为。 支持登录、KCP连接、Demo01地图随机移动等自动化测试功能。

Constructor & Destructor Documentation

◆ actor_robot()

ngl::actor_robot::actor_robot ( i16_area aarea,
i32_actordataid arobotid,
void *  )

构造函数

Parameters
aarea所属逻辑区域
arobotid区域内唯一的机器人数据ID
未使用的扩展参数

Member Function Documentation

◆ actorid()

i64_actorid ngl::actor_robot::actorid ( int32_t adataid)
static

根据数据ID生成完整的机器人ActorID

Parameters
adataid机器人数据ID
Returns
完整的ActorID(GUID)

◆ handle()

bool ngl::actor_robot::handle ( const message< np_thruput_test > & adata)

处理吞吐量测试消息

Parameters
adata吞吐量测试消息
Returns
处理结果

◆ init()

void ngl::actor_robot::init ( )
virtual

初始化机器人Actor,加载行为树配置并设置tick定时器

Reimplemented from ngl::actor_base.

◆ loaddb_finish()

void ngl::actor_robot::loaddb_finish ( pbdb::ENUM_DB atype,
enum_dbstat astat )
virtual

数据库加载完成回调

Parameters
atype加载完成的数据库表类型
astat加载状态

Reimplemented from ngl::actor_base.

◆ timer_handle()

bool ngl::actor_robot::timer_handle ( const message< np_timerparm > & adata)

定时器回调,驱动行为树tick

Parameters
adata定时器参数消息
Returns
始终返回true

◆ ukcp_connect()

void ngl::actor_robot::ukcp_connect ( pbnet::ENUM_KCP akcpenum)

发起KCP连接

Parameters
akcpenumKCP类型(GATEWAY或ROLE)

The documentation for this class was generated from the following files: