近期,由于某项目验收需要,需要登录接口同时满足至少400个账号同时并发登录,于是开始编写测试代码,以满足项目业务需要。首先,安装jdk,由于本机已安装jdk8:
如果你机器上没有安装jdk,请百度自行安装一下,因为JMeter由java编写,JMeter安装:
Windows 安装 jmeter-CSDN博客
安装redis,可以百度也可以参考之前发布的文章:部署.net6 到 Windows server 2008 r2 IIS_csdn_aspnet的博客-CSDN博客
编写测试webapi登录接口代码:
1.写入redis测试账号:
/// <summary>/// 添加或移除测试账号/// </summary>/// <param name="isDel">0:添加账号 1:移除账号</param>/// <returns></returns>[HttpPost]public async Task<ActionResult> 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.登录接口实现:
/// <summary>
/// 登录
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
[HttpPost]
public async Task<ActionResult> Login([FromBody] LoginVM model)
{string sKey = "YH:";if (await _cache.GetAsync(sKey + model.yhm)){var vCacheModel = await _cache.GetAsync<Yhzh>(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<Yhzh, Yhxx, Dwxx>((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<string, string> dicUserInfo = new Dictionary<string, string>{{ "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包实现,此类代码如下:
/// <summary>
/// 不能是泛型类
/// </summary>
public class SqlSugarHelper
{//多库情况下使用说明://如果是固定多库可以传 new SqlSugarScope(List<ConnectionConfig>,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).Aopvar 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%,符合预期结果:
至此测试任务完成,将业务过程搬到正式环境代码,改写相关业务接口。