get_value.cpp

#include <unistd.h>
#include <iostream>
#include <string>
#include <thread>

#include "sw/redis++/redis++.h"

std::string host = "127.0.0.0";
int port = 6379;
std::string auth;
std::string cluster_node;
int cluster_port = 0;
bool benchmark = false;
int key_len = 8;
int val_len = 40;
int total_request_num = 1000;
int thread_num = 1;
int pool_size = 5;
int batch_size = 100;
int key_size = 10000000;        // keys in redis server

std::vector<uint64_t> times_us;

sw::redis::Redis *redis;

int parse_options(int argc, char **argv)
{
    int opt = 0;
    while ((opt = getopt(argc, argv, "h:p:a:n:c:k:v:r:t:b:s:")) != -1) {
        try {
            switch (opt) {
            case 'h':
                host = optarg;
                break;

            case 'p':
                port = std::stoi(optarg);
                break;

            case 'a':
                auth = optarg;
                break;

            case 'n':
                cluster_node = optarg;
                break;

            case 'c':
                cluster_port = std::stoi(optarg);
                break;

            case 'b':
                batch_size = std::stoi(optarg);
                break;

            case 'k':
                key_len = std::stoi(optarg);
                break;

            case 'v':
                val_len = std::stoi(optarg);
                break;

            case 'r':
                total_request_num = std::stoi(optarg);
                break;

            case 't':
                thread_num = std::stoi(optarg);
                break;

            case 's':
                pool_size = std::stoi(optarg);
                break;

            default:
                break;
            }
        } catch (const sw::redis::Error &e) {
            std::cerr << "Unknow option" << std::endl;
        } catch (const std::exception &e) {
            std::cerr << "Invalid command line option" << std::endl;
        }
    }

    return 0;
}

void thread_worker(int thread_id)
{
    // get values
    for (int i = 0; i < total_request_num; ++i) {
        std::vector<std::string> get_kvs;
        std::vector<std::string> get_kvs_res;

         for(int j = i * batch_size; j <  (i + 1) * batch_size; j++) {
            get_kvs.push_back(std::to_string(i % key_size));
        }
        auto start2 = std::chrono::steady_clock::now();
        redis->mget(get_kvs.begin(), get_kvs.end(), std::back_inserter(get_kvs_res));
        auto stop2 = std::chrono::steady_clock::now();
        times_us[thread_id] += std::chrono::duration_cast<std::chrono::microseconds>(stop2 - start2).count();
    }

    // Per-thread statistics
    std::cout << total_request_num << " requests, " << batch_size << " keys per req, total time us = " << times_us[thread_id] <<std::endl;
    std::cout << "Average " << times_us[thread_id] / total_request_num << "us per req" << std::endl;
    std::cout << "qps: " << (double)total_request_num / times_us[thread_id] * 1000000 << std::endl;
}

int main(int argc, char **argv)
{
    parse_options(argc, argv);

    std::string connstr = std::string("tcp://") + host + std::string(":") + std::to_string(port);
    redis = new sw::redis::Redis(connstr);

    std::vector<std::thread> workers;
    times_us.reserve(thread_num);

    for (int i = 0; i < thread_num; ++i) {
        times_us[i] = 0;
        workers.push_back(std::thread(thread_worker, i));
    }

    for (int i = 0; i < thread_num; ++i) {
        workers[i].join();
    }

    // times_total_us is average running time of each thread
    uint64_t times_total_us = 0;
    for (int i = 0; i < thread_num; ++i) {
        times_total_us += times_us[i];
    }
    times_total_us /= thread_num;
    
    // Total requests should be sum of requests sent by each thread
    total_request_num *= thread_num;

    std::cout << total_request_num << " requests, " << batch_size << " keys per req, total time us = " << times_total_us <<std::endl;
    std::cout << "Average " << times_total_us / total_request_num << "us per req" << std::endl;
    std::cout << "qps: " << (double)total_request_num / times_total_us * 1000000 << std::endl;

    return 0;
}