通过js fetch() 模拟后台接口的并发测试

小灰灰 2023-10-10 10:30 23阅读 0赞

业务需求：今天开发人员向我反馈，说之前的旧系统存在，在高并发的情况下，会产生流水发号重新的现象。

说是迟，写是快。快速写完高并发情况下的流水号生成服务。核心代码如下：

@Controller
    @RequestMapping("/api/sys/pip/record")
    @Api(value = "流水号记录Controlle", tags = "流水号记录操作服务")
    public class SysPipNumberRecordController extends AbstractController {
    	
    	@Autowired
    	private SysPipNumberRecordService service;
    	
    	@ApiOperation(httpMethod = "POST", value = "流水号记录信息保存")
    	@RequestMapping(value = "/insert", method = { RequestMethod.POST }, produces = "application/json;charset=UTF-8")
    	@ResponseBody
    	public Result insert(
    			@RequestBody @ApiParam(name = "流水号规则对象", value = "json格式对象", required = true) SysPipNumberRecord entity) {
    		
    		// 判断流水规则是否为空
    		if(!StringUtils.isEmpty(entity.getRuleSid())){
    			service.insertSelective(entity);
    			return Result.ok();
    		} else {
    			return Result.error("流水规则不存在");
    		}
    
    	}

@Override
    	public int insertSelective(SysPipNumberRecord record) {
    		// TODO Auto-generated method stub
    		// 解决并发请求，发号重复问题：锁定当前代码块
    		synchronized(this){
    			// 分布式sid 生成
    			SnowflakeIdGenerator snowflake = new SnowflakeIdGenerator(0,2);
    			record.setSid(Long.toBinaryString(snowflake.nextId()));
    			
    			// 判断流水规则 是否在流水记录中生成
    			Map<String, Object> parame = new HashMap<String, Object>();
    			parame.put("ruleSid", record.getRuleSid());
    			
    			// 公共属性
    			SysPipNumberRule rule = ruleMapper.selectByPrimaryKey(record.getRuleSid());
    			record.setCategory(rule.getCategory());
    			record.setZoneOrgCode(rule.getZoneOrgCode());
    			
    			List<SysPipNumberRecord> list = mapper.selectAll(parame);
    			if (list != null && list.size() > 0) {
    				// 获取流水记录最大值
    				List<Integer> num = list.stream().map(SysPipNumberRecord::getInitValue).collect(Collectors.toList());
    				Integer number = Collections.max(num) + 1;
    				
    				record.setInitValue(number);
    				// 序列号
    				String serialNumber = StringFormatUtil.addZeroForNum(String.valueOf(number),
    						rule.getLength());
    				
    				StringBuilder builder = new StringBuilder();
    				// 判断是否启动分类
    				if(rule.getIsCategory().equalsIgnoreCase("1")){
    					// 判断是否截取分类
    					if(rule.getCutLength() != null && rule.getCutLength() > 0){
    						// 判断截取长度与分类key 长度问题
    						if(rule.getCategory().length() >= rule.getCutLength()){
    							builder.append(rule.getCategory().substring(0, rule.getCutLength()));							
    						} else {
    							builder.append(rule.getCategory());
    						}
    					} else {
    						builder.append(rule.getCategory());
    					}
    					// 判断连接符是否配置
    					if(!StringUtils.isEmpty(rule.getConnector())){
    						builder.append(rule.getConnector());
    					}
    				} 
    				// 判断是否启动日期
    				if (rule.getIsDate().equalsIgnoreCase("1")) {
    					SimpleDateFormat format = new SimpleDateFormat(rule.getDateFormat());
    					builder.append(format.format(new Date()));
    					if(!StringUtils.isEmpty(rule.getConnector())){
    						builder.append(rule.getConnector());
    					}
    				}
    				// 添加流水号
    				builder.append(serialNumber);
    				record.setPipNumberValue(builder.toString());
    				
    			} else {
    				record.setInitValue(rule.getStartValue());
    				// 序列号
    				String serialNumber = StringFormatUtil.addZeroForNum(String.valueOf(rule.getStartValue()),
    						rule.getLength());
    				StringBuilder builder = new StringBuilder();
    				// 判断是否启动分类
    				if(rule.getIsCategory().equalsIgnoreCase("1")){
    					// 判读是否截取分类
    					if(rule.getCutLength() != null && rule.getCutLength() > 0){
    						// 判断截取长度与分类key 长度问题
    						if(rule.getCategory().length() >= rule.getCutLength()){
    							builder.append(rule.getCategory().substring(0, rule.getCutLength()));							
    						} else {
    							builder.append(rule.getCategory());
    						}
    					} else {
    						builder.append(rule.getCategory());
    					}
    					
    					
    					if(!StringUtils.isEmpty(rule.getConnector())){
    						builder.append(rule.getConnector());
    					}
    				} 
    				// 判断是否启动日期
    				if (rule.getIsDate().equalsIgnoreCase("1")) {
    					SimpleDateFormat format = new SimpleDateFormat(rule.getDateFormat());
    					builder.append(format.format(new Date()));
    					if(!StringUtils.isEmpty(rule.getConnector())){
    						builder.append(rule.getConnector());
    					}
    				}
    				// 添加流水号
    				builder.append(serialNumber);
    				record.setPipNumberValue(builder.toString());
    			}
    			
    			// 数据入库
    			return mapper.insertSelective(record);
    		}
    	}

核心代码已经写完，如何验证我写的代码，让我很纠结，测试人员提示我，可以使用ab 测试工具 模拟高并发的情况，但是我从我们公司的前端学到一手，通过HTML5 新特性fetch 函数模拟高并发.

前端js 代码如下：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70][]

通过模拟2次，每次都是100 个请求，查看数据库结果，没有重复。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191011142433490.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3pob3V6aGl3ZW5nYW5n,size_16,color_FFFFFF,t_70