跳到主要内容

消息流与线程模型

快速上手​

按RPC 上手编写业务 action，并用框架 RPC_AWAIT_*、 RPC_RETURN_* 接口读写异步结果。标准服务保留已有 main 装配； 切换协程后端见构建。

详细设计​

事件循环​

每个服务进程的 main（如 src/lobbysvr/service/app/lobbysvr_main.cpp）执行：

  1. 构造 atfw::atapp::app；
  2. logic_server_setup_common（src/server_frame/logic/logic_server_setup.cpp）装配公共模块、事件回调与 service discovery 索引；
  3. 分别调用 app.add_module(...) 挂载 CS、SS、DB dispatcher 和业务 module；
  4. app.run(uv_default_loop(), argc, argv, nullptr)。

服务侧的 atbus、Redis、定时器和 DNS 完成回调在主 libuv loop 上交给业务任务。 异步等待通过协程挂起并由 dispatcher 按 task_id + sequence 唤醒； 同步计算不会因包装为协程而自动移到后台线程。依赖或专用运行时可包含独立线程。

客户端消息流（CS）​

cs_msg_dispatcher 处理 gateway::server_message 四类：kAddSession（创建 session）、kPost（上行消息， 启动 CS task action）、kRemoveSession（登出）、kSetRouterRsp。下行由 session::send_msg_to_client / cs_msg_dispatcher::send_data / broadcast_data / send_kickoff / send_set_router 回传 atgateway。

服务间消息流（SS）​

  • 调用端代码由 rpc_call_api_for_ss.*.mako 生成：组装 SSMsg → ss_msg_dispatcher::send_to_proc（按 bus id / 名字 / discovery node）→ app::send_message → atbus；跨服务组可经 atproxy 转发。
  • 支持 unary / stream / no-wait / broadcast / metadata / user / router 变体；broadcast 可按 type、zone、 metadata 索引寻址。
  • 响应经 internal::wait_and_unpack_ss_response 按 destination_task_id + sequence 唤醒等待中的 task。
  • ss_msg_dispatcher 内嵌 DNS lookup（uv_getaddrinfo + custom_resume），供按需解析对端地址。

数据库消息流​

db_msg_dispatcher 基于 hiredis-happ 管理 Redis cluster 与 raw（sentinel）双通道连接，支持 SCRIPT LOAD 与 内嵌 Lua（CAS、KL 索引裁剪）；回复解包后唤醒对应 task。详见数据层。

挂起/唤醒原语​

原语位置用途
rpc::waitrpc/rpc_utils.h等待 SSMsg / db_message（可带 timeout），支持多 waiter
rpc::custom_wait / rpc::custom_resumerpc/rpc_utils.h按 type 地址 + sequence 挂起/唤醒（DNS、router 等自定义唤醒）
rpc::async_invokerpc/rpc_async_invoke.h把任意 callable 包装为真实 task 启动
RPC_AWAIT_* / RPC_RETURN_*rpc/rpc_common_types.h屏蔽 std-coroutine / libcopp 双实现差异的宏