static/chunks/766-12dbb05e2adf85ab.js","4150","static/chunks/app/courses/%5BcourseSlug%5D/lessons/%5BunitSlug%5D/page-1fc213a0f4568bd8.js"],"Image"] 3b:T7b1,#include #include int main() { // Connect to Redis redisContext* context = redisConnect("127.0.0.1", 6379); if (context == NULL || context->err) { std::cerr << "Error: " << (context ? context->errstr : "Can't allocate redis context") << std::endl; if (context) redisFree(context); return 1; } // Example usage const char* stream_name = "user_activity_stream"; // Add entries to the stream redisCommand(context, "XADD %s * event login username alice", stream_name); redisCommand(context, "XADD %s * event login username bob", stream_name); // Read entries from the stream redisReply* reply = (redisReply*)redisCommand(context, "XREAD COUNT 2 STREAMS %s 0", stream_name); if (reply->type == REDIS_REPLY_ARRAY) { for (size_t i = 0; i < reply->elements; ++i) { redisReply* stream = reply->element[i]; redisReply* entries = stream->element[1]; for (size_t j = 0; j < entries->elements; ++j) { redisReply* entry = entries->element[j]; // Stream entry ID std::cout << "Stream entry ID: " << entry->element[0]->str << std::endl; // Stream entry data (key-value pairs) redisReply* entry_data = entry->element[1]; if (entry_data->type == REDIS_REPLY_ARRAY) { for (size_t k = 0; k < entry_data->elements; k += 2) { std::cout << "Key: " << entry_data->element[k]->str << ", Value: " << entry_data->element[k+1]->str << std::endl; } } } } } freeReplyObject(reply); redisFree(context); return 0; } /* Output: Stream entry ID: 1702312847534-0 Key: event, Value: login Key: username, Value: alice Stream e