TDEngine 压力测试思路

TDEngine 压测思路

消息分发复用TDEngine底层的逻辑，包括链接创建，消息读取，消息发送，消息执行，定时器执行

压测控制stress_testd

加载时操做

1.加载压测文件夹模块，目录stress_test

2.注册玩家登录成功回调事件，并注册玩家心跳回调

3.帐号名起始字段

4.注册压测定时器

启动压测模块

调用STRESS_TEST_D.start(500, "CHAT_TESTD")，第一个参数是须要登录的人数，第二个参数是须要测试的模块，模块名以逗号隔开，若是有设置登录的人数，则进行登录，若是没有设置登录人数则对在线的玩家设置测试模块

-- 有则新登录number玩家再进行操做
if number then
	local arg = {
		number     = number,
		extra_data = {test_modules = test_modules}
	}
	login(arg)
-- 没有 则对已登录的玩家进行操做
else
	local player_list = child_objects(PLAYER_TDCLS)
	for _, player in ipairs(player_list) do
		player:set("test_modules", test_modules)
	end
end

玩家登录

一次调用函数只登录一个，若是还有须要登录的用户，则启动定时器，间隔必定时间后登录

-- 批量登录(number个玩家)
function login(arg)
    -- 统计登录数
    login_number = login_number + 1
    arg.number   = arg.number - 1
    -- 构造帐号名(命名规则 "时间戳_编号")
    local account = string.format("%d_%d", start_time, login_number)
    -- 登录一个玩家
    LOGIN_D.login(account, "default_password", arg.extra_data)
    if arg.number > 0 then
        -- 间隔一段时间后再登录下一玩家
        set_timer(TIME_LOGIN, login, arg)
    end
end

登录成功处理

function func_login_ok(player)

登录成功主要设置玩家的测试模块及模块的测试间隔

心跳函数处理

-- 玩家心跳函数(负责玩家全部测试子模块的操做)
function heartbeat_handler(player)

心跳函数主要负责定时调用相应的测试模块，每一个模块都有本身的独立计时，若是累计时间超过执行一次须要的时间则进的一次调用，并把累计时间清0

-- 每一个玩家的子模块的时间间隔
local interval = player:query("interval")
if not interval then
	return 
end
-- 每一个玩家的子模块的累计时间
local accumulate = player:query("accumulate") or {}
-- 每一个玩家须要测试的子模块
local test_modules = player:query("test_modules") or {}
-- 循环执行须要测试的子模块
for test_module, _ in pairs(test_modules) do
	if interval[test_module] then
		-- 初始化累加时间
		if not accumulate[test_module] then
			accumulate[test_module] = 0
		end
		-- 累加时间
		accumulate[test_module] = accumulate[test_module] + HEARTBEAT_INTERVAL
		-- 累计时间 >= 间隔时间，则执行子模块操做
		if accumulate[test_module] >= interval[test_module] then
			local child_module = _G[test_module]
			if child_module and type(child_module.operation) == "function" then
				-- 调用子模块的统一接口
				child_module.operation(player)
			else
				trace("找不到压力测试子模块(%o) 或者 该子模块未定义'operation'接口!", test_module)
				test_modules[test_module] = nil
			end
			-- 累计时间清零，从新计算
			accumulate[test_module] = 0
		end
	else
		trace("要求测试的压力子模块(%o)并未定义!", test_module)
		test_modules[test_module] = nil
	end
end
-- 保存累计时间
player:set("accumulate", accumulate)

测试模块要求

测试模块需实现下面两个方法

-- 达到每一个玩家的该模块间隔时间，则调用该函数
function operation(player)
--操做的时间间隔，毫秒
function random_interval()

总结

经过丰富测试模块，及丰富PLAYER_CLASS的数据，能够达模拟一个玩家正常的操做流程，能够达到更真实的测试效果。

项目

TDEngine