From eebf050c2f604335fd0c2d3ae11d99ddc092fb4c Mon Sep 17 00:00:00 2001 From: qicosmos Date: Thu, 16 Oct 2025 11:41:21 +0800 Subject: [PATCH] update --- README.md | 23 ++++++++++++++++++----- tests/test_rest_rpc.cpp | 7 ++++--- 2 files changed, 22 insertions(+), 8 deletions(-) diff --git a/README.md b/README.md index 975c39d..5235a3b 100644 --- a/README.md +++ b/README.md @@ -59,7 +59,7 @@ int main(){ rpc_client client; auto ec = co_await client.connect("127.0.0.1:9004"); if(ec) { - REST_LOG_ERROR << ec0.message(); + REST_LOG_ERROR << ec.message(); co_return; } @@ -86,7 +86,7 @@ struct person { int age; }; -//2.提供并服务 +//2.提供rpc服务 person get_person(person p) { p.name = "jack"; return p; @@ -106,7 +106,7 @@ int main(){ rpc_client client; auto ec = co_await client.connect("127.0.0.1:9004"); if(ec) { - REST_LOG_ERROR << ec0.message(); + REST_LOG_ERROR << ec.message(); co_return; } @@ -158,7 +158,7 @@ void subscribe() { rpc_client client; co_await client.connect("127.0.0.1:9004"); while (true) { - // 订阅topic1，会自动将结果反序列化为std::string, 如果publish是一个person对象，则subscribe参数填person，内部会自动反序列化 + // 订阅topic1，库会自动将结果反序列化为std::string, 如果publish是一个person对象，则subscribe参数填person，内部会自动反序列化 auto [ec, result] = co_await client.subscribe("topic1"); if (ec != rpc_errc::ok) { REST_LOG_ERROR << "subscribe failed: " << make_error_code(ec).message(); @@ -217,11 +217,24 @@ rest_rpc 也支持用户使用自己的序列化库，只需要去实现一个 # rest_rpc的更多用法 +rest_rpc 支持零拷贝发数据，以echo函数为例： +```cpp +std::string_view echo(std::string_view str) { + return str; +} +``` +假如用户希望发送很大的一个数据，可能有数GB，如果按照常规的做法，需要先序列化，这样就存在内存拷贝，rest_rpc 针对这种场景专门做了优化，当client调用rpc函数时传入的是std::string_view 时， +rest_rpc 将不会对传入的数据做拷贝，也不会去做序列化，直接通过socket发送到服务端。 + +rpc函数的返回类型为std::string_view 时，client收到的响应数据也不会做反序列化和内存拷贝，直接返回的是收到的socket 数据。 + +这样就可以实现rpc的零拷贝数据发送了，能获得最佳的性能。 + 可以参考rest_rpc的example: https://github.com/qicosmos/rest_rpc/tree/master/examples ## 社区和群 -purecpp.cn +http://purecpp.cn qq群:546487929 diff --git a/tests/test_rest_rpc.cpp b/tests/test_rest_rpc.cpp index 1edc3a9..3b73dcf 100644 --- a/tests/test_rest_rpc.cpp +++ b/tests/test_rest_rpc.cpp @@ -101,7 +101,7 @@ asio::awaitable delay_response2(std::string_view str) { co_await ctx.response(str); auto ret = co_await ctx.response(str); CHECK(ret); - + // this return value is meaningless, because it will response later, the // return type is important for client, so just return an empty value here. co_return ""; @@ -307,7 +307,7 @@ TEST_CASE("test server start") { auto conn_ec = sync_wait(cl.get_executor(), cl.connect("127.0.0.1:9005")); CHECK(!conn_ec); - + { auto result = sync_wait(cl.get_executor(), cl.call_for(std::chrono::minutes(2), 1, 2)); @@ -502,7 +502,8 @@ TEST_CASE("test server address") { // in_user_pack = true; // msgpack::sbuffer buffer(2 * 1024); // if constexpr (sizeof...(Args) > 1) { -// msgpack::pack(buffer, std::forward_as_tuple(std::forward(args)...)); +// msgpack::pack(buffer, +// std::forward_as_tuple(std::forward(args)...)); // } else { // msgpack::pack(buffer, std::forward(args)...); // }