C或C++中是否有支持流读取的redis客户端

Is there a redis client in C or C++ which supports streaming reads?

本文关键字:读取 redis 客户端 支持 C++ 是否      更新时间:2023-10-16

我们正在考虑使用redis作为大型数据集的中间计算结果的缓存系统。例如,我们可以处理一个1GB的文件,并将其转换为512MB的数据集,这些数据将流式传输到客户端。问题是,当我们从redis请求数据时,我们不想等到所有512MB都发送到服务器后再开始将其发送到客户端。我已经看了几个redis的C和C++库(氧化还原,redis3m),甚至异步库在返回整个结果时也会给你一个回调,而不是从缓存中返回部分结果。有没有什么能一次给你的值一个缓冲区?

更新:这是我希望得到的一种类型的界面。为了清楚起见,简化了示例;

Socket clientSocket;
/* some code that has accepted a connection from a client */
/*  ....... */
RedisClient cl;
cl.Connect("server");
cl.GetValueAsync(
    "largePreCalculated", // key
    [clientSocket](char *buffer, int bytesAvailable) {
         clientSocket.write(buffer, bytesAvailable);
    }, // callback when data from the value has come over the wire
    [clientSocket]() {
         clientSocket.close();
    } // callback when all data from value has been received
);

试着看看bredis。虽然它不允许您在通过有线接收到redis的回复之前获取数据(必须对其进行解析,对吧?),但它几乎返回原始(可能是碎片化的)boost::asio缓冲区,旨在实现最小的内存重新分配。

PS。Redis协议(和C++客户端)支持流水线操作,即同时读取和写入套接字。