#include #include int main() { // Connect to the Redis server redisContext* context = redisConnect("127.0.0.1", 6379); if (context == nullptr || context->err) { if (context) { std::cerr << "Connection error: " << context->errstr << std::endl; } else { std::cerr << "Connection error: can't allocate Redis context" << std::endl; } return 1; } // Add events to a Redis stream redisReply* reply = (redisReply*)redisCommand(context, "XADD mystream * event login user Alice"); freeReplyObject(reply); reply = (redisReply*)redisCommand(context, "XADD mystream * event purchase user Bob amount 100"); freeReplyObject(reply); reply = (redisReply*)redisCommand(context, "XADD mystream * event add_to_cart user Alice product laptop"); freeReplyObject(reply); // Read the first two events from the stream reply = (redisReply*)redisCommand(context, "XREAD COUNT 2 STREAMS mystream 0"); if (reply->type == REDIS_REPLY_ARRAY) { std::cout << "Stream messages:" << std::endl; for (size_t i = 0; i < reply->elements; ++i) { redisReply* stream = reply->element[i]; if (stream->type == REDIS_REPLY_ARRAY && stream->elements == 2) { std::cout << "Stream: " << stream->element[0]->str << std::endl; // Stream name redisReply* messages = stream->element[1]; for (size_t j = 0; j < messages->elements; ++j) { redisReply* message = messages->element[j]; if (message->type == REDIS_REPLY_ARRAY && message->elements == 2) { std::cout << " ID: " << message->element[0]->str << std::endl; redisReply* fields = message->element[1]; for (size_t k = 0; k < fields->elements; k += 2) { std::cout << " " << fields->element[k]->str << ": " << fields->element[k + 1]->str << std::endl; } } } } } } else { std::cerr << "Failed to read stream." << std::endl; } freeReplyObject(reply); // Free the context redisFree(context); return 0; } /* Output: Stream messages: Stream: mystream ID: 1737154114178-0 event: login user: Alice ID: 1737154114178-1 event: purchase user: Bob amount: 100 */