{"id":7501,"date":"2026-07-24T21:29:08","date_gmt":"2026-07-24T13:29:08","guid":{"rendered":"https:\/\/i007.cc\/wordpress\/?p=7501"},"modified":"2026-07-24T21:29:08","modified_gmt":"2026-07-24T13:29:08","slug":"%e4%bd%bf%e7%94%a8asio%e8%ae%bf%e9%97%ae%e7%bd%91%e7%bb%9c%ef%bc%8c%e6%95%b0%e6%8d%ae%e5%ba%93%ef%bc%8c%e4%bd%bf%e7%94%a8%e5%ae%9a%e6%97%b6%e5%99%a8%e5%bc%80%e5%8f%91%e6%b8%b8%e6%88%8f%e6%9c%8d","status":"publish","type":"post","link":"https:\/\/i007.cc\/wordpress\/archives\/7501","title":{"rendered":"\u4f7f\u7528asio\u8bbf\u95ee\u7f51\u7edc\uff0c\u6570\u636e\u5e93\uff0c\u4f7f\u7528\u5b9a\u65f6\u5668\u5f00\u53d1\u6e38\u620f\u670d\u52a1\u5668\u7684\u6700\u4f73\u5b9e\u8df5"},"content":{"rendered":"
\n
\n
\n
\n
\n
\n
\n
\n
<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
\n

\u8fd9\u662f\u4e00\u4e2a\u5b8c\u6574\u7684\u5b9e\u6218\u6307\u5357\uff0c\u628a\u524d\u9762\u6240\u6709\u8ba8\u8bba\u843d\u5730\u6210\u53ef\u7528\u7684\u4ee3\u7801\u7ed3\u6784\u3002<\/p>\n

\n

\u4e00\u3001\u9879\u76ee\u7ed3\u6784\u4e0e\u7ebf\u7a0b\u6a21\u578b<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
\n
game_server\/\r\n\u251c\u2500\u2500 main.cpp\r\n\u251c\u2500\u2500 net\/\r\n\u2502   \u251c\u2500\u2500 server.hpp          # TCP \u63a5\u5165\uff0caccept \u5faa\u73af\r\n\u2502   \u2514\u2500\u2500 session.hpp         # \u5355\u4e2a\u8fde\u63a5\uff0c\u8bfb\u5199\u534f\u7a0b\r\n\u251c\u2500\u2500 game\/\r\n\u2502   \u251c\u2500\u2500 room.hpp            # Actor \u6a21\u578b\uff0cstrand \u4fdd\u62a4\r\n\u2502   \u251c\u2500\u2500 player.hpp          # \u73a9\u5bb6\u5185\u5b58\u72b6\u6001\r\n\u2502   \u2514\u2500\u2500 game_loop.hpp       # Tick \u4e3b\u5faa\u73af\r\n\u251c\u2500\u2500 db\/\r\n\u2502   \u251c\u2500\u2500 redis_client.hpp    # aedis \u5c01\u88c5\r\n\u2502   \u2514\u2500\u2500 mysql_client.hpp    # MySQL \u5f02\u6b65\u5c01\u88c5\r\n\u251c\u2500\u2500 proto\/\r\n\u2502   \u2514\u2500\u2500 messages.proto      # Protobuf \u6d88\u606f\u5b9a\u4e49\r\n\u2514\u2500\u2500 util\/\r\n    \u251c\u2500\u2500 timer_wheel.hpp     # \u65f6\u95f4\u8f6e\uff08\u5927\u91cf\u5b9a\u65f6\u5668\u65f6\u7528\uff09\r\n    \u2514\u2500\u2500 object_pool.hpp     # \u51cf\u5c11\u5185\u5b58\u5206\u914d<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ main.cpp \u2014\u2014 \u7ebf\u7a0b\u6a21\u578b\u7684\u6838\u5fc3\u51b3\u7b56\r\n\r\nint main() {\r\n    \/\/ io_context \u6570\u91cf = CPU \u6838\u5fc3\u6570\r\n    \/\/ \u6bcf\u4e2a io_context \u8dd1\u4e00\u4e2a\u7ebf\u7a0b\uff0c\u51cf\u5c11\u8de8\u7ebf\u7a0b\u7ade\u4e89\r\n    const int THREAD_COUNT = std::thread::hardware_concurrency();\r\n    \r\n    std::vector<std::unique_ptr<asio::io_context>> io_ctxs;\r\n    std::vector<std::thread> threads;\r\n    \r\n    for (int i = 0; i < THREAD_COUNT; i++) {\r\n        io_ctxs.push_back(std::make_unique<asio::io_context>());\r\n    }\r\n    \r\n    \/\/ \u6bcf\u4e2a Room \u7ed1\u5b9a\u5230\u4e00\u4e2a io_context\uff08\u901a\u8fc7 strand\uff09\r\n    \/\/ \u540c\u4e00 Room \u7684\u6240\u6709\u64cd\u4f5c\u5929\u7136\u4e32\u884c\uff0c\u4e0d\u9700\u8981\u9501\r\n    auto& room_ctx = *io_ctxs[0];  \/\/ Room \u4e13\u7528\r\n    auto& net_ctx  = *io_ctxs[1];  \/\/ \u7f51\u7edc I\/O \u4e13\u7528\r\n    auto& db_ctx   = *io_ctxs[2];  \/\/ \u6570\u636e\u5e93 I\/O \u4e13\u7528\r\n    \r\n    for (auto& ctx : io_ctxs) {\r\n        \/\/ work_guard \u9632\u6b62 io_context \u5728\u6ca1\u6709\u4efb\u52a1\u65f6\u9000\u51fa\r\n        auto guard = asio::make_work_guard(*ctx);\r\n        threads.emplace_back([&ctx, g = std::move(guard)] {\r\n            ctx.run();\r\n        });\r\n    }\r\n    \r\n    \/\/ \u542f\u52a8\u670d\u52a1\r\n    GameServer server(net_ctx, room_ctx, db_ctx);\r\n    server.start(8888);\r\n    \r\n    for (auto& t : threads) t.join();\r\n    return 0;\r\n}<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u4e8c\u3001\u7f51\u7edc\u5c42\uff1aSession \u751f\u547d\u5468\u671f\u7ba1\u7406<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ net\/session.hpp\r\n\r\nclass GameSession : public std::enable_shared_from_this<GameSession> {\r\npublic:\r\n    \/\/ \u6d88\u606f\u5305\u5934\uff1a4\u5b57\u8282\u957f\u5ea6 + 2\u5b57\u8282\u547d\u4ee4ID + 2\u5b57\u8282\u5e8f\u5217\u53f7\r\n    struct Header {\r\n        uint32_t length;   \/\/ body \u957f\u5ea6\uff08\u7f51\u7edc\u5b57\u8282\u5e8f\uff09\r\n        uint16_t cmd_id;\r\n        uint16_t seq;\r\n    };\r\n    static constexpr size_t HEADER_SIZE = sizeof(Header);\r\n    static constexpr size_t MAX_BODY_SIZE = 64 * 1024;  \/\/ 64KB\r\n\r\n    explicit GameSession(tcp::socket socket)\r\n        : socket_(std::move(socket))\r\n        , heartbeat_timer_(socket_.get_executor())\r\n        , session_id_(generate_session_id())\r\n        , send_strand_(socket_.get_executor()) {}\r\n\r\n    void start() {\r\n        \/\/ \u540c\u65f6\u542f\u52a8\u8bfb\u534f\u7a0b\u548c\u5fc3\u8df3\u68c0\u6d4b\r\n        co_spawn(socket_.get_executor(),\r\n            [self = shared_from_this()]() { return self->read_loop(); },\r\n            asio::detached);\r\n        \r\n        schedule_heartbeat();\r\n    }\r\n\r\n    \/\/ \u7ebf\u7a0b\u5b89\u5168\u7684\u53d1\u9001\uff1a\u901a\u8fc7 strand \u5e8f\u5217\u5316\u5199\u64cd\u4f5c\r\n    void send(std::vector<uint8_t> data) {\r\n        asio::post(send_strand_, [self = shared_from_this(),\r\n                                  data = std::move(data)]() mutable {\r\n            self->send_queue_.push(std::move(data));\r\n            if (!self->writing_) {\r\n                self->do_write();\r\n            }\r\n        });\r\n    }\r\n\r\n    \/\/ \u6ce8\u518c\u6d88\u606f\u5904\u7406\u5668\uff08\u7531 Room \u8bbe\u7f6e\uff09\r\n    void set_message_handler(\r\n        std::function<void(uint16_t, uint16_t, std::span<const uint8_t>)> handler) {\r\n        message_handler_ = std::move(handler);\r\n    }\r\n\r\n    void disconnect(std::string_view reason) {\r\n        if (!connected_.exchange(false)) return;  \/\/ \u9632\u6b62\u91cd\u590d\u65ad\u5f00\r\n        LOG_INFO(\"session {} disconnect: {}\", session_id_, reason);\r\n        heartbeat_timer_.cancel();\r\n        socket_.close();\r\n        if (disconnect_handler_) disconnect_handler_(session_id_);\r\n    }\r\n\r\n    uint64_t session_id() const { return session_id_; }\r\n\r\nprivate:\r\n    awaitable<void> read_loop() {\r\n        try {\r\n            while (connected_) {\r\n                \/\/ \u8bfb\u5305\u5934\r\n                Header header;\r\n                co_await async_read(socket_,\r\n                    asio::buffer(&header, HEADER_SIZE),\r\n                    use_awaitable);\r\n                \r\n                \/\/ \u5b57\u8282\u5e8f\u8f6c\u6362\r\n                uint32_t body_len = ntohl(header.length);\r\n                uint16_t cmd_id   = ntohs(header.cmd_id);\r\n                uint16_t seq      = ntohs(header.seq);\r\n                \r\n                if (body_len > MAX_BODY_SIZE) {\r\n                    disconnect(\"oversized packet\");\r\n                    co_return;\r\n                }\r\n                \r\n                \/\/ \u8bfb\u6d88\u606f\u4f53\r\n                std::vector<uint8_t> body(body_len);\r\n                if (body_len > 0) {\r\n                    co_await async_read(socket_,\r\n                        asio::buffer(body),\r\n                        use_awaitable);\r\n                }\r\n                \r\n                on_message(cmd_id, seq, body);\r\n            }\r\n        } catch (const std::exception& e) {\r\n            disconnect(e.what());\r\n        }\r\n    }\r\n\r\n    void on_message(uint16_t cmd, uint16_t seq,\r\n                    const std::vector<uint8_t>& body) {\r\n        reset_heartbeat();\r\n        if (message_handler_) {\r\n            message_handler_(cmd, seq, std::span{body});\r\n        }\r\n    }\r\n\r\n    void do_write() {\r\n        if (send_queue_.empty()) {\r\n            writing_ = false;\r\n            return;\r\n        }\r\n\r\n        \/\/ \u6279\u91cf\u53d1\u9001\uff1a\u628a\u961f\u5217\u91cc\u6240\u6709\u6d88\u606f\u5408\u5e76\u6210\u4e00\u6b21 writev\r\n        std::vector<asio::const_buffer> buffers;\r\n        while (!send_queue_.empty()) {\r\n            write_batch_.push_back(std::move(send_queue_.front()));\r\n            send_queue_.pop();\r\n            buffers.push_back(asio::buffer(write_batch_.back()));\r\n            \r\n            if (buffers.size() > 64) break;  \/\/ \u5355\u6279\u6b21\u4e0a\u9650\r\n        }\r\n\r\n        writing_ = true;\r\n        async_write(socket_, buffers,\r\n            asio::bind_executor(send_strand_,\r\n                [self = shared_from_this()](auto ec, auto) {\r\n                    self->write_batch_.clear();\r\n                    if (ec) {\r\n                        self->disconnect(ec.message());\r\n                        return;\r\n                    }\r\n                    self->do_write();  \/\/ \u7ee7\u7eed\u53d1\u5269\u4f59\r\n                }));\r\n    }\r\n\r\n    void schedule_heartbeat() {\r\n        heartbeat_timer_.expires_after(std::chrono::seconds(30));\r\n        heartbeat_timer_.async_wait([self = shared_from_this()](auto ec) {\r\n            if (!ec) self->disconnect(\"heartbeat timeout\");\r\n        });\r\n    }\r\n\r\n    void reset_heartbeat() {\r\n        heartbeat_timer_.cancel();\r\n        schedule_heartbeat();\r\n    }\r\n\r\n    tcp::socket socket_;\r\n    steady_timer heartbeat_timer_;\r\n    uint64_t session_id_;\r\n    \r\n    \/\/ \u5199\u64cd\u4f5c\u5fc5\u987b\u901a\u8fc7 strand \u4e32\u884c\u5316\uff0c\u5426\u5219\u5e76\u53d1\u5199 socket \u4f1a\u5d29\r\n    asio::strand<asio::any_io_executor> send_strand_;\r\n    std::queue<std::vector<uint8_t>> send_queue_;\r\n    std::vector<std::vector<uint8_t>> write_batch_;\r\n    bool writing_ = false;\r\n    \r\n    std::atomic<bool> connected_{true};\r\n    std::function<void(uint16_t, uint16_t, std::span<const uint8_t>)> message_handler_;\r\n    std::function<void(uint64_t)> disconnect_handler_;\r\n};<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u4e09\u3001Room\uff1aActor \u6a21\u578b + Strand<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ game\/room.hpp\r\n\r\nclass Room : public std::enable_shared_from_this<Room> {\r\npublic:\r\n    explicit Room(asio::io_context& ctx, uint64_t room_id)\r\n        : strand_(asio::make_strand(ctx))  \/\/ \u6240\u6709 Room \u64cd\u4f5c\u5728\u540c\u4e00\u4e2a strand \u4e0a\r\n        , tick_timer_(strand_)\r\n        , save_timer_(strand_)\r\n        , room_id_(room_id) {}\r\n\r\n    \/\/ \u73a9\u5bb6\u52a0\u5165\uff1a\u5728 strand \u4e0a\u6267\u884c\uff0c\u4fdd\u8bc1\u7ebf\u7a0b\u5b89\u5168\r\n    awaitable<void> add_player(std::shared_ptr<GameSession> session,\r\n                               uint64_t player_id) {\r\n        \/\/ co_spawn \u5230 strand\uff0c\u4fdd\u8bc1\u540e\u7eed\u64cd\u4f5c\u4e32\u884c\r\n        co_await asio::post(strand_, use_awaitable);\r\n        \r\n        \/\/ \u52a0\u8f7d\u73a9\u5bb6\u6570\u636e\uff08\u8fd9\u662f\u51b7\u8def\u5f84\uff0c\u53ef\u4ee5\u7b49 DB\uff09\r\n        auto player_data = co_await load_player_data(player_id);\r\n        \r\n        auto player = std::make_shared<Player>(player_id, player_data);\r\n        player->set_session(session);\r\n        players_[player_id] = player;\r\n        \r\n        \/\/ \u8bbe\u7f6e\u6d88\u606f\u8def\u7531\uff1a\u7f51\u7edc\u6d88\u606f\u6295\u9012\u5230 strand \u4e0a\u5904\u7406\r\n        session->set_message_handler(\r\n            [self = shared_from_this(), player_id]\r\n            (uint16_t cmd, uint16_t seq, std::span<const uint8_t> body) {\r\n                \/\/ \u628a\u6d88\u606f post \u5230 strand\uff0c\u4fdd\u8bc1\u6e38\u620f\u903b\u8f91\u4e32\u884c\r\n                asio::post(self->strand_,\r\n                    [self, player_id, cmd, seq,\r\n                     body_vec = std::vector<uint8_t>(body.begin(), body.end())]() {\r\n                        self->on_player_message(player_id, cmd, seq, body_vec);\r\n                    });\r\n            });\r\n        \r\n        \/\/ \u901a\u77e5\u623f\u95f4\u5185\u5176\u4ed6\u73a9\u5bb6\u6709\u4eba\u52a0\u5165\r\n        broadcast_player_joined(player_id);\r\n        \r\n        LOG_INFO(\"player {} joined room {}\", player_id, room_id_);\r\n    }\r\n\r\n    void start() {\r\n        start_tick();\r\n        start_periodic_save();\r\n    }\r\n\r\nprivate:\r\n    \/\/ \u2500\u2500\u2500 \u6e38\u620f\u4e3b\u5faa\u73af \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\r\n\r\n    void start_tick() {\r\n        tick_timer_.expires_after(TICK_INTERVAL);\r\n        tick_timer_.async_wait(\r\n            asio::bind_executor(strand_, [self = shared_from_this()](auto ec) {\r\n                if (!ec) self->do_tick();\r\n            }));\r\n    }\r\n\r\n    void do_tick() {\r\n        auto now = Clock::now();\r\n        auto dt = std::chrono::duration<float>(now - last_tick_).count();\r\n        last_tick_ = now;\r\n\r\n        \/\/ \u76d1\u63a7 Tick \u8017\u65f6\uff0c\u8d85\u51fa\u9884\u7b97\u7acb\u5373\u544a\u8b66\r\n        auto tick_start = Clock::now();\r\n\r\n        \/\/ \u2500\u2500 \u70ed\u8def\u5f84\uff1a\u7eaf\u5185\u5b58\u64cd\u4f5c\uff0c\u7edd\u4e0d\u8bbf\u95ee DB \u2500\u2500\r\n        process_pending_inputs();   \/\/ \u6d88\u8d39\u672c\u5e27\u79ef\u7d2f\u7684\u8f93\u5165\r\n        update_physics(dt);\r\n        update_skills(dt);\r\n        check_collisions();\r\n        broadcast_delta_state();    \/\/ \u53ea\u5e7f\u64ad\u53d8\u5316\u91cf\r\n        \/\/ \u2500\u2500 \u70ed\u8def\u5f84\u7ed3\u675f \u2500\u2500\r\n\r\n        auto tick_cost = Clock::now() - tick_start;\r\n        if (tick_cost > TICK_INTERVAL * 0.8f) {\r\n            LOG_WARN(\"room {} tick overtime: {}ms\", room_id_,\r\n                std::chrono::duration_cast<std::chrono::milliseconds>(tick_cost).count());\r\n        }\r\n\r\n        \/\/ \u8c03\u5ea6\u4e0b\u4e00\u5e27\uff08\u7528 expires_at \u800c\u975e expires_after\uff0c\u9632\u6b62\u65f6\u95f4\u6f02\u79fb\uff09\r\n        tick_timer_.expires_at(tick_timer_.expiry() + TICK_INTERVAL);\r\n        tick_timer_.async_wait(\r\n            asio::bind_executor(strand_, [self = shared_from_this()](auto ec) {\r\n                if (!ec) self->do_tick();\r\n            }));\r\n    }\r\n\r\n    void process_pending_inputs() {\r\n        \/\/ Tick \u5f00\u59cb\u65f6\u4e00\u6b21\u6027\u6d88\u8d39\u6240\u6709\u5f85\u5904\u7406\u8f93\u5165\r\n        \/\/ \u8f93\u5165\u5df2\u7ecf\u5728 strand \u4e0a\u6295\u9012\u8fc7\u6765\u4e86\uff0c\u8fd9\u91cc\u76f4\u63a5\u5904\u7406\r\n        for (auto& [pid, player] : players_) {\r\n            while (auto input = player->pop_input()) {\r\n                apply_player_input(pid, *input);\r\n            }\r\n        }\r\n    }\r\n\r\n    \/\/ \u2500\u2500\u2500 \u6570\u636e\u5e93\u8bbf\u95ee\uff1a\u51b7\u8def\u5f84 \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\r\n\r\n    awaitable<PlayerData> load_player_data(uint64_t player_id) {\r\n        \/\/ \u5e76\u53d1\u52a0\u8f7d\u4e0d\u540c\u6570\u636e\u6e90\r\n        using namespace asio::experimental::awaitable_operators;\r\n        \r\n        auto [base, inventory, skills] = co_await (\r\n            redis_client_->hgetall(\"player:\" + std::to_string(player_id)) &&\r\n            redis_client_->lrange(\"inventory:\" + std::to_string(player_id), 0, -1) &&\r\n            mysql_client_->query_async<SkillRow>(\r\n                \"SELECT * FROM player_skills WHERE player_id = ?\", player_id)\r\n        );\r\n        \r\n        co_return PlayerData{\r\n            .base      = parse_base_data(base),\r\n            .inventory = parse_inventory(inventory),\r\n            .skills    = skills\r\n        };\r\n    }\r\n\r\n    \/\/ \u2500\u2500\u2500 \u5b9a\u65f6\u5b58\u6863\uff1a\u5ef6\u8fdf\u5199\u56de \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\r\n\r\n    void start_periodic_save() {\r\n        save_timer_.expires_after(std::chrono::seconds(30));\r\n        save_timer_.async_wait(\r\n            asio::bind_executor(strand_, [self = shared_from_this()](auto ec) {\r\n                if (!ec) {\r\n                    co_spawn(self->strand_,\r\n                        [self]() { return self->flush_dirty_players(); },\r\n                        asio::detached);\r\n                    self->start_periodic_save();  \/\/ \u91cd\u65b0\u8c03\u5ea6\r\n                }\r\n            }));\r\n    }\r\n\r\n    awaitable<void> flush_dirty_players() {\r\n        \/\/ \u627e\u51fa\u6240\u6709\u810f\u6570\u636e\u73a9\u5bb6\uff0c\u5e76\u53d1\u5199\u56de\r\n        std::vector<awaitable<void>> tasks;\r\n        for (auto& [pid, player] : players_) {\r\n            if (player->is_dirty()) {\r\n                tasks.push_back(save_player(pid, player));\r\n            }\r\n        }\r\n        \r\n        \/\/ \u5e76\u53d1\u6267\u884c\u6240\u6709\u5b58\u6863\u4efb\u52a1\r\n        for (auto& task : tasks) {\r\n            co_await std::move(task);\r\n        }\r\n    }\r\n\r\n    awaitable<void> save_player(uint64_t pid, std::shared_ptr<Player> player) {\r\n        try {\r\n            auto snapshot = player->take_snapshot();  \/\/ \u5feb\u7167\uff0c\u4e0d\u963b\u585e\u6e38\u620f\u903b\u8f91\r\n            \r\n            co_await redis_client_->hmset(\r\n                \"player:\" + std::to_string(pid),\r\n                snapshot.to_redis_fields());\r\n            \r\n            \/\/ \u5173\u952e\u6570\u636e\u540c\u6b65\u5199 MySQL\r\n            if (snapshot.has_currency_change()) {\r\n                co_await mysql_client_->execute_async(\r\n                    \"UPDATE player_currency SET gold=?, diamond=? WHERE id=?\",\r\n                    snapshot.gold, snapshot.diamond, pid);\r\n            }\r\n            \r\n            player->clear_dirty();\r\n        } catch (const std::exception& e) {\r\n            LOG_ERROR(\"save player {} failed: {}\", pid, e.what());\r\n            \/\/ \u5b58\u6863\u5931\u8d25\u4e0d\u5f71\u54cd\u6e38\u620f\uff0c\u4e0b\u6b21 Tick \u7ee7\u7eed\u6807\u8bb0 dirty\r\n        }\r\n    }\r\n\r\n    \/\/ \u2500\u2500\u2500 \u6d88\u606f\u5206\u53d1 \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\r\n\r\n    void on_player_message(uint64_t player_id, uint16_t cmd,\r\n                           uint16_t seq, const std::vector<uint8_t>& body) {\r\n        \/\/ \u6b64\u65f6\u5df2\u7ecf\u5728 strand \u4e0a\uff0c\u53ef\u4ee5\u5b89\u5168\u8bbf\u95ee players_\r\n        auto it = players_.find(player_id);\r\n        if (it == players_.end()) return;\r\n        \r\n        \/\/ \u628a\u6d88\u606f\u653e\u5165\u73a9\u5bb6\u8f93\u5165\u961f\u5217\uff0c\u7b49\u4e0b\u4e00\u4e2a Tick \u5904\u7406\r\n        \/\/ \u8fd9\u6837\u4fdd\u8bc1\u8f93\u5165\u5904\u7406\u5728 Tick \u7684\u56fa\u5b9a\u65f6\u95f4\u70b9\u53d1\u751f\r\n        it->second->push_input(cmd, seq, body);\r\n    }\r\n\r\n    void broadcast_delta_state() {\r\n        auto delta = world_state_.compute_delta(last_broadcast_);\r\n        if (delta.empty()) return;\r\n        \r\n        auto packet = serialize_delta(delta);\r\n        for (auto& [pid, player] : players_) {\r\n            if (auto session = player->session()) {\r\n                session->send(packet);\r\n            }\r\n        }\r\n        last_broadcast_ = world_state_.snapshot();\r\n    }\r\n\r\n    static constexpr auto TICK_INTERVAL = std::chrono::milliseconds(66);\r\n    \r\n    asio::strand<asio::io_context::executor_type> strand_;\r\n    steady_timer tick_timer_;\r\n    steady_timer save_timer_;\r\n    \r\n    uint64_t room_id_;\r\n    std::unordered_map<uint64_t, std::shared_ptr<Player>> players_;\r\n    \r\n    std::shared_ptr<RedisClient>  redis_client_;\r\n    std::shared_ptr<MysqlClient>  mysql_client_;\r\n    \r\n    WorldState world_state_;\r\n    WorldState last_broadcast_;\r\n    Clock::time_point last_tick_ = Clock::now();\r\n};<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u56db\u3001Redis \u5ba2\u6237\u7aef\u5c01\u88c5<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ db\/redis_client.hpp\r\n\r\nclass RedisClient {\r\npublic:\r\n    explicit RedisClient(asio::io_context& ctx, const RedisConfig& cfg)\r\n        : ctx_(ctx), config_(cfg) {}\r\n\r\n    awaitable<void> connect() {\r\n        conn_ = std::make_shared<aedis::connection>(ctx_);\r\n        \r\n        aedis::connection::config aedis_cfg;\r\n        aedis_cfg.addr.host = config_.host;\r\n        aedis_cfg.addr.port = config_.port;\r\n        \r\n        co_await conn_->async_run(aedis_cfg, {}, use_awaitable);\r\n    }\r\n\r\n    \/\/ HGETALL\uff1a\u8fd4\u56de hash \u7684\u6240\u6709\u5b57\u6bb5\r\n    awaitable<std::unordered_map<std::string, std::string>>\r\n    hgetall(const std::string& key) {\r\n        aedis::request req;\r\n        req.push(\"HGETALL\", key);\r\n        \r\n        aedis::response<std::vector<std::string>> resp;\r\n        co_await conn_->async_exec(req, resp, use_awaitable);\r\n        \r\n        auto& vec = std::get<0>(resp).value();\r\n        std::unordered_map<std::string, std::string> result;\r\n        for (size_t i = 0; i + 1 < vec.size(); i += 2) {\r\n            result[vec[i]] = vec[i + 1];\r\n        }\r\n        co_return result;\r\n    }\r\n\r\n    \/\/ HMSET\uff1a\u6279\u91cf\u8bbe\u7f6e hash \u5b57\u6bb5\r\n    awaitable<void> hmset(const std::string& key,\r\n                          const std::vector<std::pair<std::string, std::string>>& fields) {\r\n        aedis::request req;\r\n        req.push_range(\"HMSET\", key, fields);\r\n        \r\n        aedis::ignore_response resp;\r\n        co_await conn_->async_exec(req, resp, use_awaitable);\r\n    }\r\n\r\n    \/\/ \u539f\u5b50\u6263\u51cf\uff08\u9632\u6b62\u8d85\u5356\/\u5237\u91d1\u5e01\uff09\r\n    awaitable<bool> deduct_if_enough(const std::string& key,\r\n                                     const std::string& field,\r\n                                     int64_t amount) {\r\n        \/\/ Lua \u811a\u672c\u4fdd\u8bc1\u539f\u5b50\u6027\r\n        static const std::string SCRIPT = R\"(\r\n            local val = tonumber(redis.call('HGET', KEYS[1], ARGV[1]))\r\n            if val == nil or val < tonumber(ARGV[2]) then\r\n                return 0\r\n            end\r\n            redis.call('HDECRBY', KEYS[1], ARGV[1], ARGV[2])\r\n            return 1\r\n        )\";\r\n        \r\n        aedis::request req;\r\n        req.push(\"EVAL\", SCRIPT, 1, key, field, std::to_string(amount));\r\n        \r\n        aedis::response<int64_t> resp;\r\n        co_await conn_->async_exec(req, resp, use_awaitable);\r\n        co_return std::get<0>(resp).value() == 1;\r\n    }\r\n\r\n    \/\/ \u5e26\u91cd\u8bd5\u7684\u6267\u884c\r\n    template<typename Request, typename Response>\r\n    awaitable<void> exec_with_retry(Request& req, Response& resp,\r\n                                    int max_retries = 3) {\r\n        for (int i = 0; i < max_retries; i++) {\r\n            try {\r\n                co_await conn_->async_exec(req, resp, use_awaitable);\r\n                co_return;\r\n            } catch (const std::exception& e) {\r\n                if (i == max_retries - 1) throw;\r\n                \r\n                \/\/ \u6307\u6570\u9000\u907f\r\n                steady_timer backoff(ctx_);\r\n                backoff.expires_after(std::chrono::milliseconds(100 * (1 << i)));\r\n                co_await backoff.async_wait(use_awaitable);\r\n                \r\n                \/\/ \u91cd\u8fde\r\n                co_await connect();\r\n            }\r\n        }\r\n    }\r\n\r\nprivate:\r\n    asio::io_context& ctx_;\r\n    RedisConfig config_;\r\n    std::shared_ptr<aedis::connection> conn_;\r\n};<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u4e94\u3001MySQL \u5ba2\u6237\u7aef\u5c01\u88c5<\/h3>\n
MySQL \u5b98\u65b9\u5f02\u6b65 API \u4e0d\u5b8c\u5584\uff0c\u6700\u5b9e\u7528\u7684\u65b9\u6848\u662f\u7528\u7ebf\u7a0b\u6c60\u6865\u63a5\uff1a<\/p>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ db\/mysql_client.hpp\r\n\r\nclass MysqlClient {\r\npublic:\r\n    explicit MysqlClient(asio::io_context& ctx, const MysqlConfig& cfg)\r\n        : ctx_(ctx)\r\n        , pool_(std::make_unique<ConnectionPool>(cfg, POOL_SIZE)) {}\r\n\r\n    \/\/ \u628a\u540c\u6b65 MySQL \u64cd\u4f5c\u5305\u88c5\u6210 awaitable\r\n    \/\/ \u5728\u7ebf\u7a0b\u6c60\u91cc\u6267\u884c\uff0c\u4e0d\u963b\u585e io_context \u7ebf\u7a0b\r\n    template<typename Row>\r\n    awaitable<std::vector<Row>> query_async(std::string_view sql, auto&&... args) {\r\n        co_return co_await asio::async_compose\r\n            decltype(use_awaitable),\r\n            void(std::exception_ptr, std::vector<Row>)>(\r\n            \r\n            [this, sql = std::string(sql),\r\n             args_tuple = std::make_tuple(std::forward<decltype(args)>(args)...)]\r\n            (auto& self) mutable {\r\n                \/\/ \u63d0\u4ea4\u5230\u7ebf\u7a0b\u6c60\u6267\u884c\r\n                asio::post(thread_pool_,\r\n                    [this, sql, args_tuple, &self]() mutable {\r\n                        try {\r\n                            auto conn = pool_->acquire();\r\n                            auto result = std::apply(\r\n                                [&](auto&&... a) {\r\n                                    return execute_query<Row>(conn, sql, a...);\r\n                                }, args_tuple);\r\n                            \r\n                            \/\/ \u7ed3\u679c\u6295\u9012\u56de io_context\r\n                            asio::post(ctx_,\r\n                                [result = std::move(result), &self]() mutable {\r\n                                    self.complete(nullptr, std::move(result));\r\n                                });\r\n                        } catch (...) {\r\n                            auto eptr = std::current_exception();\r\n                            asio::post(ctx_,\r\n                                [eptr, &self]() mutable {\r\n                                    self.complete(eptr, {});\r\n                                });\r\n                        }\r\n                    });\r\n            },\r\n            use_awaitable, ctx_);\r\n    }\r\n\r\n    awaitable<void> execute_async(std::string_view sql, auto&&... args) {\r\n        \/\/ \u7c7b\u4f3c\u4e0a\u9762\uff0c\u7701\u7565\r\n    }\r\n\r\n    \/\/ \u4e8b\u52a1\uff1a\u5fc5\u987b\u5728\u540c\u4e00\u4e2a\u8fde\u63a5\u4e0a\u6267\u884c\u6240\u6709\u8bed\u53e5\r\n    awaitable<void> transaction(\r\n        std::function<void(MysqlConnection&)> operations) {\r\n        \r\n        co_return co_await asio::async_compose\r\n            decltype(use_awaitable), void(std::exception_ptr)>(\r\n            \r\n            [this, operations = std::move(operations)](auto& self) mutable {\r\n                asio::post(thread_pool_,\r\n                    [this, operations, &self]() mutable {\r\n                        try {\r\n                            auto conn = pool_->acquire();\r\n                            conn->execute(\"BEGIN\");\r\n                            try {\r\n                                operations(*conn);\r\n                                conn->execute(\"COMMIT\");\r\n                            } catch (...) {\r\n                                conn->execute(\"ROLLBACK\");\r\n                                throw;\r\n                            }\r\n                            asio::post(ctx_, [&self] { self.complete(nullptr); });\r\n                        } catch (...) {\r\n                            auto eptr = std::current_exception();\r\n                            asio::post(ctx_, [eptr, &self] { self.complete(eptr); });\r\n                        }\r\n                    });\r\n            },\r\n            use_awaitable, ctx_);\r\n    }\r\n\r\nprivate:\r\n    static constexpr int POOL_SIZE = 8;\r\n    \r\n    asio::io_context& ctx_;\r\n    asio::thread_pool thread_pool_{4};  \/\/ MySQL \u64cd\u4f5c\u4e13\u7528\u7ebf\u7a0b\u6c60\r\n    std::unique_ptr<ConnectionPool> pool_;\r\n};<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u516d\u3001\u5b9a\u65f6\u5668\u7684\u6b63\u786e\u4f7f\u7528<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ \u4e09\u79cd\u5e38\u89c1\u5b9a\u65f6\u5668\u6a21\u5f0f\r\n\r\n\/\/ \u2500\u2500\u2500 \u6a21\u5f0f1\uff1a\u56fa\u5b9a\u95f4\u9694\uff08Tick\uff09\u2500\u2500\u2500 \u7528 expires_at \u9632\u6b62\u6f02\u79fb\r\nvoid schedule_next_tick() {\r\n    tick_timer_.expires_at(tick_timer_.expiry() + TICK_INTERVAL);\r\n    \/\/          ^^^^^^^^^^^^^^^^^^^^^^^^^^^\r\n    \/\/ \u5173\u952e\uff1a\u57fa\u4e8e\u4e0a\u6b21\u8fc7\u671f\u65f6\u95f4\u800c\u975e\u5f53\u524d\u65f6\u95f4\r\n    \/\/ \u7528 expires_after \u4f1a\u5bfc\u81f4\u6bcf\u6b21\u5ef6\u8fdf\u53e0\u52a0\uff0c\u65f6\u95f4\u6f02\u79fb\r\n    tick_timer_.async_wait(...);\r\n}\r\n\r\n\/\/ \u2500\u2500\u2500 \u6a21\u5f0f2\uff1a\u4e00\u6b21\u6027\u5ef6\u8fdf \u2500\u2500\u2500\r\nawaitable<void> skill_cooldown(uint64_t player_id, uint32_t skill_id,\r\n                               std::chrono::milliseconds duration) {\r\n    steady_timer timer(co_await this_coro::executor);\r\n    timer.expires_after(duration);\r\n    co_await timer.async_wait(use_awaitable);\r\n    \r\n    \/\/ \u51b7\u5374\u7ed3\u675f\uff0c\u901a\u77e5\u5ba2\u6237\u7aef\r\n    notify_skill_ready(player_id, skill_id);\r\n}\r\n\r\n\/\/ \u2500\u2500\u2500 \u6a21\u5f0f3\uff1a\u8d85\u65f6\u7ade\u4e89 \u2500\u2500\u2500 \u6700\u91cd\u8981\u7684\u6a21\u5f0f\r\nawaitable<std::optional<PlayerData>>\r\nload_with_timeout(uint64_t player_id,\r\n                  std::chrono::milliseconds timeout) {\r\n    using namespace asio::experimental::awaitable_operators;\r\n    \r\n    steady_timer timer(co_await this_coro::executor);\r\n    timer.expires_after(timeout);\r\n    \r\n    \/\/ \u4e24\u4e2a awaitable \u7ade\u4e89\uff0c\u8c01\u5148\u5b8c\u6210\u7528\u8c01\r\n    auto result = co_await (\r\n        load_player_data(player_id) ||\r\n        timer.async_wait(use_awaitable)\r\n    );\r\n    \r\n    if (result.index() == 0) {\r\n        co_return std::get<0>(result);  \/\/ \u6b63\u5e38\u52a0\u8f7d\u5b8c\u6210\r\n    } else {\r\n        LOG_WARN(\"load player {} timeout\", player_id);\r\n        co_return std::nullopt;         \/\/ \u8d85\u65f6\r\n    }\r\n}\r\n\r\n\/\/ \u2500\u2500\u2500 \u5927\u91cf\u5b9a\u65f6\u5668\uff1a\u65f6\u95f4\u8f6e \u2500\u2500\u2500\r\n\/\/ \u4e0a\u4e07\u4e2a\u6280\u80fd CD \u7528 asio::steady_timer \u4f1a\u4ea7\u751f\u5927\u91cf timer \u5bf9\u8c61\r\n\/\/ \u65f6\u95f4\u8f6e\u66f4\u9ad8\u6548\uff1aO(1) \u6dfb\u52a0\/\u5220\u9664\uff0cO(1) \u89e6\u53d1\u68c0\u67e5\r\nclass TimerWheel {\r\n    static constexpr int SLOTS = 256;          \/\/ 256 \u683c\r\n    static constexpr auto SLOT_DURATION = 10ms; \/\/ \u6bcf\u683c 10ms\uff0c\u8986\u76d6 2.56 \u79d2\r\n    \r\n    std::array<std::vector<TimerCallback>, SLOTS> slots_;\r\n    int current_slot_ = 0;\r\n    steady_timer wheel_timer_;\r\n\r\npublic:\r\n    void add_timer(std::chrono::milliseconds delay, TimerCallback cb) {\r\n        int slot_count = delay \/ SLOT_DURATION;\r\n        int target_slot = (current_slot_ + slot_count) % SLOTS;\r\n        slots_[target_slot].push_back(std::move(cb));\r\n    }\r\n\r\n    awaitable<void> run() {\r\n        while (true) {\r\n            wheel_timer_.expires_after(SLOT_DURATION);\r\n            co_await wheel_timer_.async_wait(use_awaitable);\r\n            \r\n            current_slot_ = (current_slot_ + 1) % SLOTS;\r\n            for (auto& cb : slots_[current_slot_]) cb();\r\n            slots_[current_slot_].clear();\r\n        }\r\n    }\r\n};<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u4e03\u3001\u9519\u8bef\u5904\u7406\u4e0e\u4f18\u96c5\u5173\u95ed<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
cpp<\/div>\n
\n
\/\/ \u7edf\u4e00\u7684\u9519\u8bef\u5904\u7406\u7b56\u7565\r\n\r\n\/\/ \u534f\u7a0b\u5185\u90e8\uff1atry\/catch\uff0c\u5c40\u90e8\u6062\u590d\r\nawaitable<void> safe_save_player(uint64_t pid) {\r\n    try {\r\n        co_await save_player(pid);\r\n    } catch (const RedisException& e) {\r\n        \/\/ Redis \u5931\u8d25\uff1a\u6807\u8bb0 dirty\uff0c\u4e0b\u6b21\u91cd\u8bd5\r\n        LOG_ERROR(\"redis save failed: {}\", e.what());\r\n        players_[pid]->mark_dirty();\r\n    } catch (const MysqlException& e) {\r\n        \/\/ MySQL \u5931\u8d25\uff1a\u62a5\u8b66\uff0c\u4eba\u5de5\u4ecb\u5165\r\n        LOG_CRITICAL(\"mysql save failed for player {}: {}\", pid, e.what());\r\n        alert_oncall(\"mysql_save_failure\", pid, e.what());\r\n    }\r\n}\r\n\r\n\/\/ \u9876\u5c42\u534f\u7a0b\uff1a\u7528 co_spawn \u7684\u7b2c\u4e09\u4e2a\u53c2\u6570\u6355\u83b7\u672a\u5904\u7406\u5f02\u5e38\r\nco_spawn(ctx,\r\n    room->game_loop(),\r\n    [room_id](std::exception_ptr eptr) {\r\n        if (eptr) {\r\n            try {\r\n                std::rethrow_exception(eptr);\r\n            } catch (const std::exception& e) {\r\n                LOG_CRITICAL(\"room {} crashed: {}\", room_id, e.what());\r\n                \/\/ \u91cd\u542f Room \u6216\u901a\u77e5\u6240\u6709\u73a9\u5bb6\u56de\u5230\u5927\u5385\r\n                recover_room(room_id);\r\n            }\r\n        }\r\n    });\r\n\r\n\/\/ \u4f18\u96c5\u5173\u95ed\r\nawaitable<void> graceful_shutdown() {\r\n    LOG_INFO(\"shutting down...\");\r\n    \r\n    \/\/ 1. \u505c\u6b62\u63a5\u53d7\u65b0\u8fde\u63a5\r\n    acceptor_.close();\r\n    \r\n    \/\/ 2. \u7ed9\u6240\u6709\u73a9\u5bb6\u53d1\u5173\u670d\u901a\u77e5\uff0c\u7ed9 5 \u79d2\u65f6\u95f4\r\n    broadcast_server_shutdown(5);\r\n    steady_timer wait(ctx_);\r\n    wait.expires_after(5s);\r\n    co_await wait.async_wait(use_awaitable);\r\n    \r\n    \/\/ 3. \u5f3a\u5236\u4fdd\u5b58\u6240\u6709\u73a9\u5bb6\u6570\u636e\r\n    std::vector<awaitable<void>> save_tasks;\r\n    for (auto& [rid, room] : rooms_) {\r\n        save_tasks.push_back(room->force_save_all());\r\n    }\r\n    for (auto& task : save_tasks) {\r\n        co_await std::move(task);\r\n    }\r\n    \r\n    \/\/ 4. \u65ad\u5f00\u6240\u6709\u8fde\u63a5\r\n    for (auto& [sid, session] : sessions_) {\r\n        session->disconnect(\"server shutdown\");\r\n    }\r\n    \r\n    LOG_INFO(\"shutdown complete\");\r\n    ctx_.stop();\r\n}<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\n
\u516b\u3001\u4e00\u5f20\u67b6\u6784\u603b\u89c8<\/h3>\n
\n
\n
<\/div>\n<\/div>\n
\n
io_context(net)          io_context(room)       io_context(db)\r\n                    \u2502                        \u2502                       \u2502\r\n              \u250c\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2510           \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2500\u2510        \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2500\u2510\r\n              \u2502  Server   \u2502           \u2502    Room     \u2502        \u2502  DB Clients \u2502\r\n              \u2502  accept   \u2502           \u2502  (strand)   \u2502        \u2502Redis\/MySQL  \u2502\r\n              \u2514\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2518           \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2518        \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518\r\n                    \u2502                        \u2502\r\n              \u250c\u2500\u2500\u2500\u2500\u2500\u25bc\u2500\u2500\u2500\u2500\u2500\u2510    \u6d88\u606f          \u2502  co_await\uff08\u51b7\u8def\u5f84\uff09\r\n              \u2502  Session  \u2502  post\u5230strand \u2500\u2500\u25ba\u2502\r\n              \u2502 read_loop \u2502                  \u2502  Tick \u7eaf\u5185\u5b58\uff08\u70ed\u8def\u5f84\uff09\r\n              \u2502 send()    \u2502\u25c4\u2500\u2500 \u5e7f\u64ad \u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2524\r\n              \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518                  \u2502  \u5b9a\u65f6\u5b58\u6863\uff08co_await DB\uff09\r\n                                            \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500<\/pre>\n
 <\/p>\n<\/div>\n<\/div>\n
\u6838\u5fc3\u539f\u5219\u53ea\u6709\u4e00\u6761\uff1a\u51b7\u8def\u5f84\u7528\u534f\u7a0b\u7b49 DB\uff0c\u70ed\u8def\u5f84\uff08Tick\uff09\u53ea\u6478\u5185\u5b58<\/strong>\uff0c\u6240\u6709\u7ebf\u7a0b\u5b89\u5168\u9760 Strand \u800c\u4e0d\u662f\u9501\u3002\u8fd9\u5957\u7ed3\u6784\u80fd\u7a33\u5b9a\u652f\u6491\u5355\u8282\u70b9\u6570\u4e07\u5e76\u53d1\uff0c\u6a2a\u5411\u6269\u5c55\u53ea\u9700\u8981\u52a0 Room \u8282\u70b9\u3002<\/p>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n<\/div>\n","protected":false},"excerpt":{"rendered":"
\u8fd9\u662f\u4e00\u4e2a\u5b8c\u6574\u7684\u5b9e\u6218\u6307\u5357\uff0c\u628a\u524d\u9762\u6240\u6709\u8ba8\u8bba\u843d<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"colormag_page_container_layout":"default_layout","colormag_page_sidebar_layout":"default_layout","footnotes":""},"categories":[24],"tags":[],"class_list":["post-7501","post","type-post","status-publish","format-standard","hentry","category-value_docs"],"_links":{"self":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/7501","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/comments?post=7501"}],"version-history":[{"count":1,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/7501\/revisions"}],"predecessor-version":[{"id":7502,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/posts\/7501\/revisions\/7502"}],"wp:attachment":[{"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/media?parent=7501"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/categories?post=7501"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/i007.cc\/wordpress\/wp-json\/wp\/v2\/tags?post=7501"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}