近期,由于某项目验收需要,需要登录接口同时满足至少400个账号同时并发登录,于是开始编写测试代码,以满足项目业务需要。首先,安装jdk,由于本机已安装jdk8:

如果你机器上没有安装jdk,请百度自行安装一下,因为JMeter由java编写,JMeter安装:

Windows 安装 jmeter-CSDN博客

安装redis,可以百度也可以参考之前发布的文章:部署.net6 到 Windows server 2008 r2 IIS_csdn_aspnet的博客-CSDN博客 

编写测试webapi登录接口代码:

1.写入redis测试账号:

///

/// 添加或移除测试账号

///

/// 0:添加账号 1:移除账号

///

[HttpPost]

public async Task AddYhzhRedis(int isDel = 0)

{

string sKey = "YH";

if (isDel == 1)

{

for (int i = 0; i < 500; i++)

{

int nId = i + 1;

string sYhm = "admin_" + nId;

await _cache.RemoveAsync(sKey + ":" + sYhm);

}

return Ok(new

{

code = 200,

success = true,

msg = "移除测试账号成功!"

});

}

Yhzh yhzh = null;

for (int i = 0; i < 500; i++)

{

int nId = i + 1;

yhzh = new Yhzh();

yhzh.id = nId;

yhzh.yhm = "admin_" + nId;

yhzh.mm = MD5Helper.MD5Encrypt32(nId + "123456");

await _cache.SetAsync(sKey + ":" + yhzh.yhm, yhzh, TimeSpan.FromHours(24));

var vId = await SqlSugarHelper.Db.Insertable(yhzh).ExecuteReturnBigIdentityAsync();

}

return Ok(new

{

code = 200,

success = true,

msg = "添加测试账号成功!"

});

}

 代码中_cache 为注入的redis缓存接口,可自行编写或使用第三方包,MD5Helper.MD5Encrypt32 你可以在网络上找一个md5加密帮助类即可。

2.登录接口实现:

///

/// 登录

///

///

///

[HttpPost]

public async Task Login([FromBody] LoginVM model)

{

string sKey = "YH:";

if (await _cache.GetAsync(sKey + model.yhm))

{

var vCacheModel = await _cache.GetAsync(sKey + model.yhm);

if (null == vCacheModel)

{

return Ok(new

{

code = 400,

success = false,

msg = "登录失败,用户不存在!"

});

}

string sAfferentPwd = MD5Helper.MD5Encrypt32(vCacheModel.id + model.mm);

if (sAfferentPwd != vCacheModel.mm)

{

return Ok(new

{

code = 400,

success = false,

msg = "登录失败,用户或密码不正确!"

});

}

//TODO:生成新的token 存储缓存信息

return Ok(new

{

code = 200,

success = true,

msg = "登录成功!"

});

}

var vUserModel = await SqlSugarHelper.Db.Queryable((zh, yh, dw) =>

new JoinQueryInfos(JoinType.Left, zh.yhid == yh.id && yh.sczt == 0, JoinType.Left, zh.dwbh == dw.dwbh && dw.sczt == 0))

.Where((zh, yh, dw) => zh.yhm == model.yhm || yh.lxdh == model.yhm || yh.jh == model.yhm)

.Where((zh, yh, dw) => zh.sczt == 0)

.Select((zh, yh, dw) => new YhzhxxVM

{

id = zh.id,

yhid = zh.yhid,

xm = yh.xm,

yhm = zh.yhm,

mm = zh.mm,

lxdh = yh.lxdh,

//yhtx = zh.yhtx,

yhtx = yh.yhtx,

dwbh = zh.dwbh,

dwmc = dw.dwmc,

qhbm = dw.qhbm,

sfxtzh = zh.sfxtzh,

zhzt = zh.zhzt,

sfkdldp = zh.sfkdldp

})

.FirstAsync();

if (null == vUserModel)

{

return Ok(new

{

code = 400,

success = false,

msg = "登录失败,用户名不存在!"

});

}

string sUserPwd = MD5Helper.MD5Encrypt32(vUserModel.id + model.mm);

if (sUserPwd != vUserModel.mm)

{

return Ok(new

{

code = 400,

success = false,

msg = "登录失败,用户名或密码错误!"

});

}

Dictionary dicUserInfo = new Dictionary

{

{ "zhid",vUserModel.id.ToString()},

{ "userid",vUserModel.yhid.ToString()},

{ "dwbh",vUserModel.dwbh??""},

{ "dwmc",vUserModel.dwmc??""},

{ "qhbm",vUserModel.qhbm??""},

{ "username",model.yhm??""},

{ "xm",vUserModel.xm??""},

{ "nickname",vUserModel.nc??""},

{ "lxdh",vUserModel.lxdh??""},

{ "yhtx",vUserModel.yhtx??""},

{ "jsmc",""},

{ "jsid",""},

{ "sfxtzh",vUserModel.sfxtzh==null?"0":vUserModel.sfxtzh.ToString()},

{ "logintime",DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss")},

{ "tokenExpire",DateTime.Now.AddSeconds(AppSettings.CustomToken.KeyTimeEffectiveTime).ToString("yyyy-MM-dd HH:mm:ss")},

};

var vUserInfo = JsonHelper.ToJson(dicUserInfo);

string sToken = Guid.NewGuid().ToString("N");

await _cache.SetAsync(sToken, vUserInfo, TimeSpan.FromMinutes(10));

return Ok(new

{

code = 200,

success = true,

msg = "登录成功!"

});

}

代码中 SqlSugarHelper使用的第三方 SqlSugar包实现,此类代码如下:

///

/// 不能是泛型类

///

public class SqlSugarHelper

{

//多库情况下使用说明:

//如果是固定多库可以传 new SqlSugarScope(List,db=>{}) 文档:多租户

//如果是不固定多库 可以看文档Saas分库

//用单例模式

public static SqlSugarScope Db = new SqlSugarScope(new ConnectionConfig()

{

ConnectionString = "server=127.0.0.1;Database=db;Port=3306;Uid=mysqladmin;Pwd=20231024;Persist Security Info=True;SslMode=None;charset=utf8mb4;",//连接符字串

DbType = DbType.MySql,//数据库类型

IsAutoCloseConnection = true //不设成true要手动close

},

db =>

{

//(A)全局生效配置点,一般AOP和程序启动的配置扔这里面 ,所有上下文生效

//调试SQL事件,可以删掉

db.Aop.OnLogExecuting = (sql, pars) =>

{

Console.WriteLine(sql);//输出sql,查看执行sql 性能无影响

//5.0.8.2 获取无参数化 SQL 对性能有影响,特别大的SQL参数多的,调试使用

//UtilMethods.GetSqlString(DbType.SqlServer,sql,pars)

};

//多个配置就写下面

//db.Ado.IsDisableMasterSlaveSeparation=true;

//注意多租户 有几个设置几个

//db.GetConnection(i).Aop

var vIsConnection = db.Ado.IsValidConnection(); //如果时间长,可以在连接字符串配置 连接超时时间

Console.WriteLine("vIsConnection:"+ vIsConnection);

});

}

打开swagger开始写入账号数据:

redis写入成功:

数据库写入成功:

启动JMeter,进入JMeter的bin目录,右键使用管理员身份运行jmeter.bat文件即可:

启动成功如下图:

修改名称,你可以使用默认名称,本测试修改为登录并发测试,在左侧登录并发测试节点右键添加线程组,如下图:

在左侧登录并发测试节点右键分别添加HTTP信息头管理器,HTTP请求默认值,CSV Data Set Config,如下图:

HTTP信息头管理,没有你可以不添加,点击添加后双击名称列单元格即可输入:

HTTP请求默认值,本次测试只填写红框内参数,IP和端口换成你自己的即可,其余默认:

CSV Data Set Config,如下图:

以上截图中 变量名称 后续会用到,csv文件内容其实就是上面代码中创建的账号信息,使用sql在数据库执行拼接登录名:

SELECT yhm FROM jc_yhzh1;

在查询结果中全选、右键- 复制为- 制表符分隔值(数据),粘贴到txt中,将txt扩展名修改为csv即可。 

修改完成后,打开csv文件如下:

在左侧线程组节点右键添加HTTP请求,如下图:

配置信息如下:

请求报文中,${name}为变量,上面选择csv设置的,要一致。

在登录并发测试节点,右键添加查看结果树和聚合报告,添加即可不需要配置:

添加完成后,在线程组右键-启动:

启动后开始执行,绿色的三角变为灰色: 

点击查看结果树:

两个截图请求明显登录账号不一样,说明一次600请求是正常的,返回结果如下:

点击聚合报告,异常0.00%,符合预期结果:

至此测试任务完成,将业务过程搬到正式环境代码,改写相关业务接口。

好文阅读

评论可见,请评论后查看内容,谢谢!!!
 您阅读本篇文章共花了: