rest_rpc
rest_rpc copied to clipboard
qicosmos
modern C++(C++11), simple, easy to use rpc framework
祁工： 嵌入式设备内存不大，所以特别关注内存消耗，还是以自带person为例，如果name的大小是10M，那么在服务端调用处理函数的时候，会瞬时消耗40M内存，原因是unpack调用msgpack::unpack时使用的默认参数，object_handle对str类型数据是复制不是引用，我看现在的流程，buffer的生命周期是大于object_handle的，能不能使用下边的接口，让unpack_reference_func固定返回true，强制使用引用模式，这样消耗的内存就是20M了。我测试了下，没有发现问题。 void unpack( object_handle& result, const char* data, std::size_t len, unpack_reference_func f = nullptr, void* user_data = nullptr, unpack_limit const& limit = unpack_limit());
祁工： 我看下了订阅发布模式的实现方式，如果发布者发布速度远大于消费者，数据会缓存在链接里的数据队列write_queue_，时间久了会把内存耗光的吧，能增加每个链接发送缓存队列的最大值限制么？
terminate called after throwing an instance of 'std::future_error' what(): std::future_error: Broken promise 求大佬指点下。
- add a function to get the size of the send queue. - add the maximum size parameter of the send queue, limit the length of the send queue, and...
void test_sub1() { rpc_client client; client.enable_auto_reconnect(); client.enable_auto_heartbeat(); bool r = client.connect("127.0.0.1", 9000); if (!r) { return; } client.subscribe( "key", "048a796c8a3c6a6b7bd1223bf2c8cee05232e927b521984ba417cb2fca6df9d1", [](string_view data) { msgpack_codec codec; person p = codec.unpack(data.data(), data.size());...
开发环境. centos 7 && gcc 8.3 操作步骤 1. 启动basic_server 2. 启动basic_client 等待3-5秒 ctrl+c关闭client. 重复这个操作 正常是2次 出现. 
