## waynboot-mall项目 waynboot-mall是一套全部开源的微商城项目,包含一个运营后台、h5商城和后台接口。 实现了一个商城所需的首页展示、商品分类、商品详情、sku详情、商品搜索、加入购物车、结算下单、订单状态流转、商品评论等一系列功能。 技术上基于Springboot2.0,整合了Redis、RabbitMQ、ElasticSearch等常用中间件, 贴近生产环境实际经验开发而来不断完善、优化、改进中。 [后台接口项目](https://github.com/wayn111/waynboot-mall) [运营后台项目](https://github.com/wayn111/waynboot-admin) [h5商城项目](https://github.com/wayn111/waynboot-mobile) ## waynboot-mall接口项目 1. 商城接口代码清晰、注释完善、模块拆分合理 2. 使用Spring-Security进行访问权限控制 3. 使用jwt进行接口授权验证 4. ORM层使用Mybatis Plus提升开发效率 5. 添加全局异常处理器,统一异常处理 6. 添加https配置代码,支持https访问 7. 集成七牛云存储配置,上传文件至七牛 8. 集成常用邮箱配置,方便发送邮件 9. 集成druid连接池,进行sql监控 10. 集成swagger,管理接口文档 11. 添加策略模式使用示例,优化首页金刚区跳转逻辑 12. 拆分出通用的数据访问模块,统一redis & elastic配置与访问 13. 使用elasticsearch-rest-high-level-client客户端对elasticsearch进行操作 14. 支持商品数据同步elasticsearch操作以及elasticsearch商品搜索 15. RabbitMQ生产者发送消息采用异步confirm模式,消费者消费消息时需手动确认 16. 下单处理过程引入rabbitMQ,异步生成订单记录,提高系统下单处理能力 17. ... ## 商城难点整理 #### 1. 库存扣减操作是在下单操作扣减还是在支付成功时扣减?(ps:扣减库存使用乐观锁机制 `where goods_num - num >= 0`) 1. 下单时扣减,这个方案属于实时扣减,当有大量下单请求时,由于订单数小于请求数,会发生下单失败,但是无法防止短时间大量恶意请求占用库存, 造成普通用户无法下单 2. 支付成功扣减,这个方案可以预防恶意请求占用库存,但是会存在多个请求同时下单后,在支付回调中扣减库存失败,导致订单还是下单失败并且还要退还订单金额(这种请求就是订单数超过了库存数,无法发货,影响用户体验) 3. 还是下单时扣减,但是对于未支付订单设置一个超时过期机制,比如下单时库存减一,生成订单后,对于未在15分钟内完成支付的订单, 自动取消超期未支付订单并将库存加一,该方案基本满足了大部分使用场景 4. 针对大流量下单场景,比如一分钟内五十万次下单请求,可以通过设置虚拟库存的方式减少下单接口对数据库的访问。具体来说就是把商品实际库存保存到redis中, 下单时配合lua脚本原子的get和decr商品库存数量(这一步就拦截了大部分请求),执行成功后在扣减实际库存 #### 2. 首页商品展示接口利用多线程技术进行查询优化,将多个sql语句的排队查询变成异步查询,接口时长只跟查询时长最大的sql查询挂钩 ```java # 1. 通过创建子线程继承Callable接口 Callable> bannerCall = () -> iBannerService.list(new QueryWrapper().eq("status", 0).orderByAsc("sort")); # 2. 传入Callable的任务给FutureTask FutureTask> bannerTask = new FutureTask<>(bannerCall); # 3. 放入线程池执行 threadPoolTaskExecutor.submit(bannerTask); # 4. 最后可以在外部通过FutureTask的get方法异步获取执行结果 List list = bannerTask.get() ``` #### 3. `ElasticSearch`查询操作,查询包含搜索关键字并且是上架中的商品,在根据指定字段进行排序,最后分页返回 ```java 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 list = elasticDocument.search("goods", searchSourceBuilder, JSONObject.class); ``` #### 4. 订单编号生成规则:秒级时间戳 + 加密用户ID + 今日第几次下单 1. 秒级时间戳:时间递增保证唯一性 2. 加密用户ID:加密处理,返回用户ID6位数字,可以防并发访问,同一秒用户不会产生2个订单 3. 今日第几次下单:便于运营查询处理用户当日订单 #### 5. 下单流程处理过程,通过rabbitMQ异步生成订单,提高系统下单处理能力 1. 用户点击提交订单按钮,后台生成订单编号和订单金额跳转到订单支付页面,并发送rabbitMQ消息(包含订单编号等信息) 2. 订单消费者接受到订单消息后生成订单记录(未支付) 3. 用户点击支付按钮时,前端根据订单编号轮询订单信息查询接口,如果订单编号记录已经入库则进行后续支付操作,如果订单编号未入库则返回错误信息(订单异常) 4. 用户支付完成后在回调通知里更新订单状态为已支付 - todo ## 文件目录 ```java |-- 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父项目依赖,定义子项目依赖版本 |-- ... ``` ## 开发部署 ``` # 1. 克隆项目 git clone git@github.com:wayn111/waynboot-mall.git # 2. 导入项目依赖 将waynboot-mall目录用idea打开,导入maven依赖 # 3. 安装Mysql8.0+、Redis3.0+、RabbitMQ3.0+、ElasticSearch7.0+到本地 # 4. 导入sql文件 在项目根目录下,找到`wayn_shop_*.sql`文件,新建mysql数据库wayn_shop,导入其中 # 5. 修改Mysql、Redis、RabbitMQ、Elasticsearch连接配置 修改`application-dev.yml`以及`application.yml`文件中数据连接配置相关信息 # 6. 启动项目 后台api: 进入waynboot-admin-api子项目,找到AdminApplication文件,右键`run AdminApplication`,启动后台项目 h5商城api: 进入waynboot-mobile-api子项目,找到MobileApplication文件,右键`run MobileApplication`,启动h5商城项目 ``` ## 在线体验 - 注册一个账号 - 然后登陆 演示地址:http://www.wayn.ltd ## 演示图
商城登陆 商城注册
商城首页 商城搜索
搜索结果展示 金刚位跳转
商品分类 商品详情
商品sku选择 购物车查看
确认下单 选择支付方式
商城我的页面 我的订单列表
添加商品评论 查看商品评论
后台登陆 后台首页
后台会员管理 后台评论管理
后台地址管理 后台添加商品
后台商品管理 后台banner管理
后台订单管理 后台分类管理
后台金刚区管理 后台栏目管理
## waynboot-mall交流群 QQ群:waynboot-mall交流群 有问题可以先提issue😁 ## todo - [ ] 支持多店铺 - [ ] 订单详情页面 - [ ] 秒杀专区 - [ ] 优惠卷使用 - [ ] 团购下单 - [ ] ... ## 感谢 - [panda-mall](https://github.com/Ewall1106/vue-h5-template) - [litemall](https://github.com/linlinjava/litemall) - [vant-ui](https://github.com/youzan/vant)