V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 558 天前的主题，其中的信息可能已经有所发展或是发生改变。

博主给大家推荐一套全部开源的 H5 电商项目waynboot-mall。由博主在 2020 年开发至今，已有三年之久。那时候网上很多的 H5 商城项目都是半开源版本，要么没有 H5 前端代码，要么需要加群咨询，属实恶心。于是博主决定自己开发一套完整的移动端 H5 商城，包含一个管理后台、一个前台 H5 商城、一套后端接口。项目地址如下：

H5 商城前端代码： https://github.com/wayn111/waynboot-mobile
运营后台前端代码： https://github.com/wayn111/waynboot-admin
后端接口代码： https://github.com/wayn111/waynboot-mall

欢迎大家关注这个项目，点个 Star 让更多的人了解到这个项目。

一、简介

waynboot-mall是一套全部开源的微商城项目，实现了一个商城所需的首页展示、商品分类、商品详情、sku 组合、商品搜索、购物车、结算下单、订单状态流转、商品评论等一系列功能。技术上基于最新得 Spring Boot3.0 、Jdk17 ，整合了 Redis 、RabbitMQ 、ElasticSearch 等常用中间件，贴近生产环境实际经验开发而来。

二、技术特点

订单金额计算使用 BigDecimal 类型，支持小数点后两位
支持微信内 JsApi 支付、H5 网页支付
商城接口代码清晰、注释完善、模块拆分合理
使用 Spring-Security 进行访问权限控制
使用 jwt 进行接口授权验证
ORM 层使用 Mybatis Plus 提升开发效率
添加全局异常处理器，统一异常处理
使用 Spring Boot admin 进行服务监控
集成七牛云存储配置，支持上传文件至七牛获取 cdn 下载链接
集成常用邮箱配置，方便发送邮件
添加策略模式使用示例，优化首页金刚区跳转逻辑
拆分出通用的数据访问模块，统一 Redis & Elastic 配置与访问
使用 Elasticsearch 高级客户端依赖对 Elasticsearch 进行操作
支持商品数据同步 Elasticsearch 操作以及中文分词搜索
RabbitMQ 生产者发送消息采用异步 confirm 模式，消费者消费消息时需手动确认确保消息不丢失
下单处理过程引入 RabbitMQ ，异步生成订单记录，提高系统下单处理能力

三、商城设计

文项目目录

|-- waynboot-monitor               // 监控模块
|-- waynboot-admin-api             // 运营后台 api 模块，提供后台项目 api 接口
|-- waynboot-common                // 通用模块，包含项目核心基础类
|-- waynboot-data                  // 数据模块，通用中间件数据访问
|   |-- waynboot-data-redis        // redis 访问配置模块
|   |-- waynboot-data-elastic      // elastic 访问配置模块
|-- waynboot-generator             // 代码生成模块
|-- waynboot-message-consumer      // 消费者模块，处理订单消息和邮件消息
|-- waynboot-message-core          // 消费者核心模块，队列、交换机配置
|-- waynboot-mobile-api            // h5 商城 api 模块，提供 h5 商城 api 接口
|-- pom.xml                        // maven 父项目依赖，定义子项目依赖版本
|-- ...

技术亮点

2.1 库存扣减

库存扣减操作是在下单操作扣减还是在支付成功时扣减？（ ps：扣减库存使用乐观锁机制 where goods_num - num >= 0）

下单时扣减，这个方案属于实时扣减，当有大量下单请求时，由于订单数小于请求数，会发生下单失败，但是无法防止短时间大量恶意请求占用库存，造成普通用户无法下单
支付成功扣减，这个方案可以预防恶意请求占用库存，但是会存在多个请求同时下单后，在支付回调中扣减库存失败，导致订单还是下单失败并且还要退还订单金额（这种请求就是订单数超过了库存数，无法发货，影响用户体验）
还是下单时扣减，但是对于未支付订单设置一个超时过期机制，比如下单时库存减一，生成订单后，对于未在 15 分钟内完成支付的订单，自动取消超期未支付订单并将库存加一，该方案基本满足了大部分使用场景
针对大流量下单场景，比如一分钟内五十万次下单请求，可以通过设置虚拟库存的方式减少下单接口对数据库的访问。具体来说就是把商品库存缓存到 redis 中，下单时配合 lua 脚本原子的 get 和 decr 商品库存数量（这一步就拦截了大部分请求），执行成功后在扣减实际库存

2.2 首页查询

首页商品展示接口利用多线程技术进行查询优化，将多个 sql 语句的排队查询变成异步查询，接口时长只跟查询时长最大的 sql 查询挂钩

// 使用 CompletableFuture 异步查询
List<CompletableFuture<Void>> list = new ArrayList<>();
CompletableFuture<Void> f1 = CompletableFuture.supplyAsync(() -> iBannerService.list(Wrappers.lambdaQuery(Banner.class).eq(Banner::getStatus, 0).orderByAsc(Banner::getSort)), homeThreadPoolTaskExecutor).thenAccept(data -> {
    String key = "bannerList";
    redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, key, data);
    success.add(key, data);
});
CompletableFuture<Void> f2 = CompletableFuture.supplyAsync(() -> iDiamondService.list(Wrappers.lambdaQuery(Diamond.class).orderByAsc(Diamond::getSort).last("limit 10")), homeThreadPoolTaskExecutor).thenAccept(data -> {
    String key = "categoryList";
    redisCache.setCacheMapValue(SHOP_HOME_INDEX_HASH, key, data);
    success.add(key, data);
});
list.add(f1);
list.add(f2);
// 主线程等待子线程执行完毕
CompletableFuture.allOf(list.toArray(new CompletableFuture[0])).join();

2.3 中文分词搜索

ElasticSearch搜索查询，查询包含搜索关键字并且是上架中的商品，在根据指定字段进行排序，最后分页返回

SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
BoolQueryBuilder boolQueryBuilder = QueryBuilders.boolQuery();
MatchQueryBuilder matchFiler = QueryBuilders.matchQuery("isOnSale", true);
MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("name", keyword);
MatchPhraseQueryBuilder matchPhraseQueryBuilder = QueryBuilders.matchPhraseQuery("keyword", keyword);
boolQueryBuilder.filter(matchFiler).should(matchQuery).should(matchPhraseQueryBuilder).minimumShouldMatch(1);
searchSourceBuilder.timeout(new TimeValue(10, TimeUnit.SECONDS));
// 按是否新品排序
if (isNew) { 
    searchSourceBuilder.sort(new FieldSortBuilder("isNew").order(SortOrder.DESC));
}
// 按是否热品排序
if (isHot) {
    searchSourceBuilder.sort(new FieldSortBuilder("isHot").order(SortOrder.DESC));
}
// 按价格高低排序
if (isPrice) {
    searchSourceBuilder.sort(new FieldSortBuilder("retailPrice").order("asc".equals(orderBy) ? SortOrder.ASC : SortOrder.DESC));
}
// 按销量排序
if (isSales) {
    searchSourceBuilder.sort(new FieldSortBuilder("sales").order(SortOrder.DESC));
}
// 筛选新品
if (filterNew) {
    MatchQueryBuilder filterQuery = QueryBuilders.matchQuery("isNew", true);
    boolQueryBuilder.filter(filterQuery);
}
// 筛选热品
if (filterHot) {
    MatchQueryBuilder filterQuery = QueryBuilders.matchQuery("isHot", true);
    boolQueryBuilder.filter(filterQuery);
}

searchSourceBuilder.query(boolQueryBuilder);
searchSourceBuilder.from((int) (page.getCurrent() - 1) * (int) page.getSize());
searchSourceBuilder.size((int) page.getSize());
List<JSONObject> list = elasticDocument.search("goods", searchSourceBuilder, JSONObject.class);

2.4 订单编号

订单编号生成规则：秒级时间戳 + 加密用户 ID + 今日第几次下单

秒级时间戳：时间递增保证唯一性
加密用户 ID：加密处理，返回用户 ID6 位数字，可以防并发访问，同一秒用户不会产生 2 个订单
今日第几次下单：便于运营查询处理用户当日订单

/**
 * 返回订单编号，生成规则：秒级时间戳 + 加密用户 ID + 今日第几次下单
 *
 * @param userId 用户 ID
 * @return 订单编号
 */
public static String generateOrderSn(Long userId) {
        long now = LocalDateTime.now().toEpochSecond(ZoneOffset.of("+8"));
        return now + encryptUserId(String.valueOf(userId), 6) + countByOrderSn(userId);
}

/**
 * 计算该用户今日内第几次下单
 *
 * @param userId 用户 ID
 * @return 该用户今日第几次下单
 */
public static int countByOrderSn(Long userId) {
        IOrderService orderService = SpringContextUtil.getBean(IOrderService.class);
        return orderService.count(new QueryWrapper<Order>().eq("user_id", userId)
        .gt("create_time", LocalDate.now())
        .lt("create_time", LocalDate.now().plusDays(1)));
}

/**
 * 加密用户 ID ，返回 num 位字符串
 *
 * @param userId 用户 ID
 * @param num    长度
 * @return num 位加密字符串
 */
private static String encryptUserId(String userId, int num) {
        return String.format("%0" + num + "d", Integer.parseInt(userId) + 1);
}

2.5 异步下单

下单流程处理过程，通过 rabbitMQ 异步生成订单，提高系统下单处理能力

用户点击提交订单按钮，后台生成订单编号和订单金额跳转到订单支付页面，并将订单编号等信息发送 rabbitMQ 消息（生成订单编号，还未生成订单）
订单消费者接受到订单消息后，获取订单编号生成订单记录（订单创建成功，用户待支付）
下单页面，前端根据订单编号轮询订单接口，订单已创建则跳转支付页面，否则提示下单失败（订单创建失败）
支付页面，用户点击支付按钮时，后台调用微信 /支付宝下单接口后，前端唤醒微信 /支付宝支付，用户输入密码
用户支付完成后在微信 /支付宝下回调通知里更新订单状态为已支付（订单已支付）
用户支付完成后，返回支付状态查看页面。

2.6 设计模式

金刚区跳转使用策略模式进行代码编写

1.定义金刚位跳转策略接口以及跳转枚举类

public interface DiamondJumpType {

    List<Goods> getGoods(Page<Goods> page, Diamond diamond);

    Integer getType();
}

// 金刚位跳转类型枚举
public enum JumpTypeEnum {
    COLUMN(0),
    CATEGORY(1);

    private Integer type;

    JumpTypeEnum(Integer type) {
        this.type = type;
    }

    public Integer getType() {
        return type;
    }

    public JumpTypeEnum setType(Integer type) {
        this.type = type;
        return this;
    }
}

2.定义策略实现类，并使用 @Component 注解注入 spring

// 分类策略实现
@Component
public class CategoryStrategy implements DiamondJumpType {

    @Autowired
    private GoodsMapper goodsMapper;

    @Override
    public List<Goods> getGoods(Page<Goods> page, Diamond diamond) {
        List<Long> cateList = Arrays.asList(diamond.getValueId());
        return goodsMapper.selectGoodsListPageByl2CateId(page, cateList).getRecords();
    }

    @Override
    public Integer getType() {
        return JumpTypeEnum.CATEGORY.getType();
    }
}

// 栏目策略实现
@Component
public class ColumnStrategy implements DiamondJumpType {

    @Autowired
    private IColumnGoodsRelationService iColumnGoodsRelationService;

    @Autowired
    private IGoodsService iGoodsService;

    @Override
    public List<Goods> getGoods(Page<Goods> page, Diamond diamond) {
        List<ColumnGoodsRelation> goodsRelationList = iColumnGoodsRelationService.list(new QueryWrapper<ColumnGoodsRelation>()
                .eq("column_id", diamond.getValueId()));
        List<Long> goodsIdList = goodsRelationList.stream().map(ColumnGoodsRelation::getGoodsId).collect(Collectors.toList());
        Page<Goods> goodsPage = iGoodsService.page(page, new QueryWrapper<Goods>().in("id", goodsIdList).eq("is_on_sale", true));
        return goodsPage.getRecords();
    }

    @Override
    public Integer getType() {
        return JumpTypeEnum.COLUMN.getType();
    }
}

3.定义策略上下文，通过构造器注入 spring ，定义 map 属性，通过 key 获取对应策略实现类

@Component
public class DiamondJumpContext {

    private final Map<Integer, DiamondJumpType> map = new HashMap<>();

    /**
     * 由 spring 自动注入 DiamondJumpType 子类
     *
     * @param diamondJumpTypes 金刚位跳转类型集合
     */
    public DiamondJumpContext(List<DiamondJumpType> diamondJumpTypes) {
        for (DiamondJumpType diamondJumpType : diamondJumpTypes) {
            map.put(diamondJumpType.getType(), diamondJumpType);
        }
    }

    public DiamondJumpType getInstance(Integer jumpType) {
        return map.get(jumpType);
    }
}

4.使用，注入 DiamondJumpContext 对象，调用 getInstance 方法传入枚举类型

@Autowired
private DiamondJumpContext diamondJumpContext;

@Test
public void test(){
    DiamondJumpType diamondJumpType=diamondJumpContext.getInstance(JumpTypeEnum.COLUMN.getType());
}

四、演示图

商城登陆	商城注册
商城首页	商城搜索
搜索结果展示	金刚位跳转
商品分类	商品详情
商品 sku 选择	购物车查看
确认下单	选择支付方式
商城我的页面	我的订单列表
添加商品评论	查看商品评论
后台登陆	后台首页
后台会员管理	后台评论管理
后台地址管理	后台添加商品
后台商品管理	后台 banner 管理
后台订单管理	后台分类管理
后台金刚区管理	后台栏目管理