有时候,通过合理的业务代码的设计,避免频繁的数据库的交互,也能很大程度提升吞吐量
这里是我们之前吞吐量测试的表,可以看到三级分类数据获取的吞吐量慢的一批
这是之前的代码,仔细看可以看到每次获取子分类都是从数据库获取,不断的与数据库交互,而且父分类数据量越大交互次数越多,现在看显然及其不合理
@Override
public Map<String, List<Catelog2Vo>> getCatalogJson() {
List<CategoryEntity> category1EntityList = findCatelog1s();
Map<String, List<Catelog2Vo>> catelog2Vos = category1EntityList.stream().collect(Collectors.toMap(k -> k.getCatId().toString(), v -> {
//1.查到一级分类的所有二级分类
List<CategoryEntity> category2EntityList = this.list(new QueryWrapper<CategoryEntity>().eq("parent_cid", v.getCatId()));
//2.获取二级分类vo集合
List<Catelog2Vo> catelog2VoList = category2EntityList.stream().map(catelog2 -> {
List<CategoryEntity> category3EntityList = this.list(new QueryWrapper<CategoryEntity>().eq("parent_cid", catelog2.getCatId()));
//3.获取三级分类vo集合
List<Catelog2Vo.Catelog3Vo> catelog3Vos = null;
if(category3EntityList !=null && category3EntityList.size() > 0){
catelog3Vos = category3EntityList.stream().map(catelog3 -> {
//获取三级分类vo
Catelog2Vo.Catelog3Vo catelog3Vo = new Catelog2Vo.Catelog3Vo(catelog3.getParentCid().toString(), catelog3.getCatId().toString(), catelog3.getName());
return catelog3Vo;
}).collect(Collectors.toList());
}
//2.获取二级分类vo
Catelog2Vo catelog2Vo = new Catelog2Vo(v.getCatId().toString(), catelog3Vos, catelog2.getCatId().toString(), catelog2.getName());
return catelog2Vo;
}).collect(Collectors.toList());
return catelog2VoList;
}));
return catelog2Vos;
}
动手
思路:先一次性查询出所有分类数据,然后每次再从里面获取对应子分类,改造后代码如下
@Override
public Map<String, List<Catelog2Vo>> getCatalogJson() {
List<CategoryEntity> categoryEntities = this.list(null);
List<CategoryEntity> category1EntityList = getParent_cid(categoryEntities,0l);
Map<String, List<Catelog2Vo>> catelog2Vos = category1EntityList.stream().collect(Collectors.toMap(k -> k.getCatId().toString(), v -> {
//1.查到一级分类的所有二级分类
List<CategoryEntity> category2EntityList = getParent_cid(categoryEntities,v.getCatId());
//2.获取二级分类vo集合
List<Catelog2Vo> catelog2VoList = category2EntityList.stream().map(catelog2 -> {
List<CategoryEntity> category3EntityList = getParent_cid(categoryEntities,catelog2.getCatId());
//3.获取三级分类vo集合
List<Catelog2Vo.Catelog3Vo> catelog3Vos = null;
if(category3EntityList !=null && category3EntityList.size() > 0){
catelog3Vos = category3EntityList.stream().map(catelog3 -> {
//获取三级分类vo
Catelog2Vo.Catelog3Vo catelog3Vo = new Catelog2Vo.Catelog3Vo(catelog3.getParentCid().toString(), catelog3.getCatId().toString(), catelog3.getName());
return catelog3Vo;
}).collect(Collectors.toList());
}
//2.获取二级分类vo
Catelog2Vo catelog2Vo = new Catelog2Vo(v.getCatId().toString(), catelog3Vos, catelog2.getCatId().toString(), catelog2.getName());
return catelog2Vo;
}).collect(Collectors.toList());
return catelog2VoList;
}));
return catelog2Vos;
}
private List<CategoryEntity> getParent_cid( List<CategoryEntity> categoryEntities,Long parent_cid) {
List<CategoryEntity> collect = categoryEntities.stream().filter(categoryEntity -> categoryEntity.getParentCid() == parent_cid).collect(Collectors.toList());
return collect;
}
再次进行压测
查看聚合报告发现吞吐量比之前多了几十倍,虽然还是不太高
填表
还要优化的话就需要进入下一篇了,使用缓存继续优化