sysbench是一款比較流行的測試工具，主要用于測試fileio、cpu、memory、threads、mutex等的性能測試，但是最主要的還是做數據庫的性能測試，經常用來測試MySQL、Drizzle、AttachSQL、Oracle、PostgreSQL等相關的數據庫，也可以擴展支持其他的數據庫以及測試用例，本文主要介紹sysbench的代碼邏輯、代碼調試、lua腳本以及相關擴展功能。

本文的介紹主要基于sysbench 1.0的代碼：
repo：https://github.com/akopytov/sysbench
branch：1.0

1. 代碼邏輯

sysbench的代碼邏輯如下（已經過濾掉一些不需要額外說明的代碼文件）：

sysbench/ ├── src │ ├── db_driver.c // db驅動測試功能接口，主要串聯sysbench測試框架和具體的db-driver │ ├── db_driver.h // db驅動接口申明，具體的實現見下面的drivers目錄 │ ├── drivers // 具體的driver驅動實現 │ │ ├── attachsql │ │ ├── drizzle │ │ ├── mysql │ │ ├── oracle │ │ └── pgsql │ ├── lua // 內置的oltp測試工具實現 │ │ ├── bulk_insert.lua │ │ ├── internal │ │ ├── oltp_common.lua │ │ ├── oltp_delete.lua │ │ ├── oltp_insert.lua │ │ ├── oltp_point_select.lua │ │ ├── oltp_read_only.lua │ │ ├── oltp_read_write.lua │ │ ├── oltp_update_index.lua │ │ ├── oltp_update_non_index.lua │ │ ├── oltp_write_only.lua │ │ ├── select_random_points.lua │ │ └── select_random_ranges.lua │ ├── sb_barrier.h // 線程屏障，用于線程的同步 │ ├── sb_ck_pr.h // 原子操作，具體的在../third_party/concurrency_kit中實現 │ ├── sb_counter.h // 計數器程序，由于統計 │ ├── sb_global.h │ ├── sb_histogram.h // todo │ ├── sb_list.h // List的C語言實現 │ ├── sb_logger.h // logger實現 │ ├── sb_lua.c │ ├── sb_lua.h // 串聯C和Lua程序，目標：1. Lua可以調用C中的db-driver-api；2. C可以調用Lua程序 │ ├── sb_options.h // 參數解析實現 │ ├── sb_rand.h // 隨機數、字符串實現 │ ├── sb_thread.h // 線程函數實現 │ ├── sb_timer.h // 定時器實現 │ ├── sb_util.h // 功能函數，主要是對齊（align）相關的宏 │ ├── sb_win.h // 跨平臺代碼，windows支持 │ ├── sysbench.c // sysbench的main函數 │ ├── sysbench.h │ ├── tests // 其他的測試模型程序，包括cpu、fileio等 │ │ ├── cpu │ │ ├── fileio │ │ ├── memory │ │ ├── mutex │ │ ├── sb_cpu.h │ │ ├── sb_fileio.h │ │ ├── sb_memory.h │ │ ├── sb_mutex.h │ │ ├── sb_threads.h │ │ └── threads │ └── xoroshiro128plus.h ├── tests // db-driver的測試用例 │ ├── include │ │ ├── api_sql_common.sh │ │ ├── config.sh.in │ │ ├── drv_common.sh │ │ ├── inspect.lua │ │ ├── mysql_common.sh │ │ ├── oltp_legacy │ │ ├── pgsql_common.sh │ │ ├── script_bulk_insert_common.sh │ │ ├── script_oltp_common.sh │ │ ├── script_oltp_legacy_common.sh │ │ ├── script_select_random_common.sh │ │ └── script_select_random_legacy_common.sh │ ├── t // sysbench單元測試程序 │ └── test_run.sh └── third_party // sysbench的第三方依賴庫├── concurrency_kit // 并發控制模塊├── cram // 命令后程序測試框架└── luajit // lua的jit編譯器

閱讀代碼從sysbench.c中的main函數開始，流程邏輯還是比較清晰的：

// source file: src/sysbench.c int main(int argc, char *argv[]) {sb_test_t *test = NULL;int rc;sb_globals.argc = argc;sb_globals.argv = malloc(argc * sizeof(char *));memcpy(sb_globals.argv, argv, argc * sizeof(char *));/* Initialize options library */sb_options_init();/* First register the logger */if (log_register())return EXIT_FAILURE;/* Register available tests */if (register_tests()){fprintf(stderr, "Failed to register tests.\n");return EXIT_FAILURE;}/* Parse command line arguments */if (parse_general_arguments(argc, argv))return EXIT_FAILURE;/* Initialize global variables and logger */if (init() || log_init() || sb_counters_init())return EXIT_FAILURE;print_header();test = sb_load_lua(NULL);current_test = test;/* Load and parse test-specific options */if (parse_test_arguments(test, argc, argv))return EXIT_FAILURE;/* prepare, cleanup, run. */if (!strcmp(sb_globals.cmdname, "prepare")){rc = test->builtin_cmds.prepare();}else if (!strcmp(sb_globals.cmdname, "cleanup")){rc = test->builtin_cmds.cleanup();}else if (!strcmp(sb_globals.cmdname, "run")){rc = run_test(test) ? EXIT_FAILURE : EXIT_SUCCESS;}/* clean up. */ end:if (sb_lua_loaded())sb_lua_done();db_done();sb_counters_done();log_done();sb_options_done();sb_rand_done();sb_thread_done();free(timers);free(timers_copy);free(sb_globals.argv);return rc; }

2. Lua腳本

Lua和C的親和性非常好，被稱為最好的膠水語言，Lua可以調用C中定義的方法，C也可以非常方便的調用Lua，為什么要C和Lua結合使用呢：

• C的優勢是高性能，但它是編譯語言，程序發生變動，就需要重新進行編譯，相對來說不太靈活；
• Lua的優勢是靈活，它是解釋語言，無需編譯，就可以執行，一般用來寫一些經常變動的規則性代碼。

那問題來了：Lua不會拖慢C的性能嗎？那就不得不提LuaJIT了，它是Lua的虛擬機，主要功能就是將Lua程序編譯成字節碼程序去執行，LuaJIT比較輕量，在C程序里面很容易就能集成進去，這就使得Lua的性能并不會有大的影響，并且支持動態的加載Lua程序。
下面是一個Lua的簡單的代碼：

-- file: lua_test.lua function domain(num)-- call C function.local tab = gettab()-- show key and valuefor k, v in pairs(tab) doprint("key: ".. k)print("val: ".. v)print()end end

下面是和C交互的代碼：

// file: c_test.c int get_tab(lua_State *L) {// create table.lua_newtable(L);// push (key, value).int i;char value[10] = {0};for(i=0; i<5; ++i) {sprintf(value, "value%d", i+1);lua_pushnumber(L, i+1); //keylua_pushstring(L, value); //valuelua_settable(L, -3); //push key,value}// deal return.return 1; }int main() {// create a state and load standard library.lua_State* L = luaL_newstate();luaL_openlibs(L);// register function be called by lua.lua_register(L, "gettab", get_tab);// load and exec the specified lua file.int error = luaL_dofile(L, "lua_test.lua");if(error) {perror("luaL_dofile error");exit(1);}// get the domain function from lua file. lua_getglobal(L, "domain");// exec the domain function.error = lua_pcall(L, 0, 0, 0);if (error) {fprintf(stderr, "%s\n",lua_tostring(L, -1));lua_pop(L, 1);}// close lua state.lua_close(L);return 0; }

這種通過lua_State交互的方式對C代碼的侵入較大，還有一種就是ffi的方式，可以參考這個鏈接：
https://moonbingbing.gitbooks.io/openresty-best-practices/content/lua/FFI.html
sysbench以上兩種方式都用了：

• 通過lua_State進行交互：主要用在Lua調用C中定義好的db-driver api；
• ffi主要用在Lua使用C中定義好的結構體、字段類型、常規函數（sleep、隨機函數）等。

3. 擴展功能

sysbench測試db場景比較簡單，表結構如下：

CREATE TABLE `sbtest1` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT,`k` int(10) unsigned NOT NULL DEFAULT '0',`c` char(120) NOT NULL DEFAULT '',`pad` char(60) NOT NULL DEFAULT '',PRIMARY KEY (`id`),KEY `k_1` (`k`) BLOCK_SIZE 16384 GLOBAL );

在我們測試其他場景，比如寬表、大字段、小字段等，這種場景用原生的sysbench測試腳本就力不從心了。
這個時候就需要修改代碼的實現了，實現也比較簡單，就是在Lua腳本中實現這幾個函數就可以了：

// src/sb_lua.c #define EVENT_FUNC "event" // worker線程執行內容 #define PREPARE_FUNC "prepare" // prepare階段：創建表、預加載數據 #define CLEANUP_FUNC "cleanup" // cleanup階段：清理數據等 #define HELP_FUNC "help" // help函數，展示測試用例的參數用法 #define THREAD_INIT_FUNC "thread_init" // worker線程初始化：設置運行參數、生成標名稱等 #define THREAD_DONE_FUNC "thread_done" // worker線程執行完：清理線程中的資源 #define THREAD_RUN_FUNC "thread_run" // 一般無需實現，只需要關注event #define INIT_FUNC "init" // 全局init：一般無需實現 #define DONE_FUNC "done" // 全局done：一般無需實現

sysbench自帶的oltp的測試case就是這樣實現的，主要包含兩個文件：

• oltp.lua：定義了thread_init、event函數；
• common.lua：定義了prepare、cleanup函數。

下面寫一個我們自己的測試case腳本：

-- file: test_cjf.lua -- A simple test case.function prepare()db_connect()-- create table.local query = [[CREATE TABLE `sbtest_cjf` (`id` int(10) unsigned NOT NULL AUTO_INCREMENT,`k` int(10) unsigned NOT NULL DEFAULT '0',`c` char(120) NOT NULL DEFAULT '',`pad` char(60) NOT NULL DEFAULT '',PRIMARY KEY (`id`))]]db_query(query)print("create table sbtest_cjf succ.")-- insert 1000 records.local ifor i = 1, 1000 doquery = [[insert into sbtest_cjf(`id`, `k`, `c`, `pad`) values(]] .. i .. ',' .. i + 1000 .. ", 'c', 'pad')"db_query(query)endprint("insert 1000 record to sbtest_cjf succ.")return 0 endfunction cleanup()db_query('DROP TABLE IF EXISTS sbtest_cjf')print('drop table sbtest_cjf succ.')return 0 endfunction event()db_query('select * from sbtest_cjf where id = 1') end

使用sysbench對上述test_cjf.lua進行測試：

$./src/sysbench ./tests/include/oltp_legacy/test_cjf.lua --mysql-host=127.0.0.1 --mysql-port=3306 --mysql-user=root --mysql-password=xxx --mysql-db=dbtest --db-driver=mysql --report-interval=2 --threads=1 --time=10 prepare sysbench 1.0.20-6cb07f3 (using bundled LuaJIT 2.1.0-beta2)create table sbtest_cjf succ. insert 1000 record to sbtest_cjf succ.$./src/sysbench ./tests/include/oltp_legacy/test_cjf.lua --mysql-host=127.0.0.1 --mysql-port=3306 --mysql-user=root --mysql-password=xxx --mysql-db=dbtest --db-driver=mysql --report-interval=2 --threads=1 --time=10 run sysbench 1.0.20-6cb07f3 (using bundled LuaJIT 2.1.0-beta2)Running the test with following options: Number of threads: 1 Report intermediate results every 2 second(s) Initializing random number generator from current timeInitializing worker threads...Threads started![ 2s ] thds: 1 tps: 2182.39 qps: 2182.39 (r/w/o: 2182.39/0.00/0.00) lat (ms,95%): 0.55 err/s: 0.00 reconn/s: 0.00 [ 4s ] thds: 1 tps: 2323.41 qps: 2323.41 (r/w/o: 2323.41/0.00/0.00) lat (ms,95%): 0.47 err/s: 0.00 reconn/s: 0.00 [ 6s ] thds: 1 tps: 2299.49 qps: 2299.49 (r/w/o: 2299.49/0.00/0.00) lat (ms,95%): 0.47 err/s: 0.00 reconn/s: 0.00 [ 8s ] thds: 1 tps: 2304.50 qps: 2304.50 (r/w/o: 2304.50/0.00/0.00) lat (ms,95%): 0.48 err/s: 0.00 reconn/s: 0.00 SQL statistics:queries performed:read: 22804write: 0other: 0total: 22804transactions: 22804 (2279.41 per sec.)queries: 22804 (2279.41 per sec.)ignored errors: 0 (0.00 per sec.)reconnects: 0 (0.00 per sec.)General statistics:total time: 10.0024stotal number of events: 22804Latency (ms):min: 0.40avg: 0.44max: 14.6895th percentile: 0.53sum: 9974.14Threads fairness:events (avg/stddev): 22804.0000/0.00execution time (avg/stddev): 9.9741/0.00$./src/sysbench ./tests/include/oltp_legacy/test_cjf.lua --mysql-host=127.0.0.1 --mysql-port=3306 --mysql-user=root --mysql-password=xxx --mysql-db=dbtest --db-driver=mysql --report-interval=2 --threads=1 --time=10 cleanup sysbench 1.0.20-6cb07f3 (using bundled LuaJIT 2.1.0-beta2)drop table sbtest_cjf succ.

4. 參考文檔

Lua教程：https://www.w3xue.com/manual/lua/Lua-Chinese.pdf
GDB入門：https://zhuanlan.zhihu.com/p/74897601
GDB命令：https://developer.aliyun.com/article/232348

總結

以上是生活随笔為你收集整理的sysbench代码剖析和实践的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。