1. 项目概述SpringBoot电商平台开发实战去年帮学弟调试毕业设计时发现市面上很多电商管理系统教程都存在代码耦合度高、权限设计简陋的问题。今天以轩辕购物商城为例分享一个基于SpringBoot的企业级电商平台开发方案。这个方案采用模块化设计包含商品管理、订单处理、支付对接等核心功能特别适合需要快速搭建高可用电商系统的开发者参考。2. 技术架构设计2.1 基础技术栈选型后端采用SpringBoot 2.7 MyBatis Plus组合相比传统SSM框架启动速度提升40%实测从8秒降至4.8秒配置文件减少60%只需application.yml内置Tomcat容器简化部署前端采用Vue3 Element Plus组件按需引入减小打包体积从2.3MB压缩至1.1MBAxios拦截器统一处理401跳转ECharts实现销售数据可视化2.2 数据库设计要点商品表设计特别注意字段CREATE TABLE product ( id bigint NOT NULL AUTO_INCREMENT COMMENT SPU编号, category_id bigint NOT NULL COMMENT 三级分类ID, spec_group_id bigint DEFAULT NULL COMMENT 规格组ID, name varchar(128) NOT NULL COMMENT 商品名称, sub_title varchar(256) DEFAULT NULL COMMENT 促销语, price decimal(10,2) NOT NULL COMMENT 基准价, cost_price decimal(10,2) DEFAULT NULL COMMENT 成本价, stock int NOT NULL DEFAULT 0 COMMENT 总库存, sale_count int DEFAULT 0 COMMENT 销量, status tinyint DEFAULT 0 COMMENT 状态0-下架 1-上架, detail_html text COMMENT 商品详情HTML, created_at datetime NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (id), KEY idx_category (category_id), KEY idx_status (status) ) ENGINEInnoDB DEFAULT CHARSETutf8mb4;特别注意价格字段必须使用DECIMAL类型避免浮点精度问题。库存字段建议增加无符号约束。3. 核心功能实现3.1 商品SKU动态生成前端传参示例{ specs: [ {key: 颜色, value: 黑色}, {key: 内存, value: 8GB} ], price: 5999.00, stock: 100 }后端处理逻辑public Result generateSku(Product product, ListSkuSpec specs) { // 1. 生成规格组合哈希值 String specHash specs.stream() .sorted(Comparator.comparing(SkuSpec::getKey)) .map(s - s.getKey() : s.getValue()) .collect(Collectors.joining(#)); // 2. 检查是否已存在相同SKU if(skuMapper.existsByHash(specHash)) { return Result.fail(相同规格组合已存在); } // 3. 生成SKU编码时间戳随机数 String skuCode SKU System.currentTimeMillis() ThreadLocalRandom.current().nextInt(1000); // 4. 持久化SKU记录 Sku newSku new Sku(); newSku.setProductId(product.getId()); newSku.setSpecJson(JSON.toJSONString(specs)); newSku.setSpecHash(specHash); newSku.setPrice(product.getPrice()); newSku.setStock(product.getStock()); newSku.setCode(skuCode); skuMapper.insert(newSku); return Result.success(newSku); }3.2 购物车合并策略用户登录时合并本地购物车与服务器购物车public void mergeCart(Long userId, ListCartItem localCart) { // 查询用户已有购物车 ListCartItem dbCart cartMapper.selectByUser(userId); // 构建商品ID到数量的映射 MapLong, Integer dbMap dbCart.stream() .collect(Collectors.toMap(CartItem::getSkuId, CartItem::getCount)); // 合并逻辑 for(CartItem localItem : localCart) { Long skuId localItem.getSkuId(); if(dbMap.containsKey(skuId)) { // 数量累加 int newCount dbMap.get(skuId) localItem.getCount(); cartMapper.updateCount(userId, skuId, newCount); } else { // 新增记录 localItem.setUserId(userId); cartMapper.insert(localItem); } } }4. 支付对接实战4.1 微信支付V3接口对接支付流程时序前端调用统一下单API服务端生成支付参数签名返回前端唤起支付控件异步接收支付结果通知关键签名方法public String createSign(String method, String url, String timestamp, String nonceStr, String body, String privateKey) throws Exception { String message method \n url \n timestamp \n nonceStr \n body \n; Signature sign Signature.getInstance(SHA256withRSA); sign.initSign(getPrivateKey(privateKey)); sign.update(message.getBytes(StandardCharsets.UTF_8)); return Base64.getEncoder().encodeToString(sign.sign()); }4.2 订单状态机设计使用状态模式实现订单流转public interface OrderState { void pay(Order order); void deliver(Order order); void receive(Order order); void cancel(Order order); } Component(unpaidState) public class UnpaidState implements OrderState { Override public void pay(Order order) { order.setState(OrderConstant.PAID); // 扣减库存 stockService.reduce(order.getSkuId(), order.getCount()); // 记录支付日志 paymentLogService.record(order); } Override public void cancel(Order order) { order.setState(OrderConstant.CLOSED); // 释放优惠券 couponService.release(order.getCouponId()); } }5. 性能优化实践5.1 缓存策略设计采用多级缓存架构本地Caffeine缓存商品详情Redis集群缓存库存信息MySQL持久层缓存击穿解决方案public Product getProductWithCache(Long id) { // 1. 查询本地缓存 Product product localCache.get(id); if(product ! null) return product; // 2. 获取分布式锁 String lockKey product_lock: id; try { boolean locked redisLock.tryLock(lockKey, 10, TimeUnit.SECONDS); if(locked) { // 3. 二次检查缓存 product localCache.get(id); if(product ! null) return product; // 4. 查询Redis product redisTemplate.opsForValue().get(product: id); if(product null) { // 5. 查询数据库 product productMapper.selectById(id); if(product ! null) { // 6. 回填缓存 redisTemplate.opsForValue().set( product: id, product, 30, TimeUnit.MINUTES); } else { // 7. 缓存空值防穿透 redisTemplate.opsForValue().set( product: id, new NullValue(), 5, TimeUnit.MINUTES); } } // 8. 写入本地缓存 localCache.put(id, product); return product; } } finally { redisLock.unlock(lockKey); } // 9. 降级方案 return getProductFromBackup(id); }5.2 数据库分库分表订单表按用户ID分片# application-sharding.yml spring: shardingsphere: datasource: names: ds0,ds1 sharding: tables: t_order: actual-data-nodes: ds$-{0..1}.t_order_$-{0..15} table-strategy: inline: sharding-column: user_id algorithm-expression: t_order_$-{user_id % 16} database-strategy: inline: sharding-column: user_id algorithm-expression: ds$-{user_id % 2}6. 安全防护方案6.1 常见攻击防护XSS防护Configuration public class WebSecurityConfig extends WebSecurityConfigurerAdapter { Override protected void configure(HttpSecurity http) throws Exception { http.headers() .xssProtection() .and() .contentSecurityPolicy(script-src self); } }CSRF防护Bean public SecurityFilterChain securityFilterChain(HttpSecurity http) throws Exception { http.csrf(csrf - csrf .csrfTokenRepository(CookieCsrfTokenRepository.withHttpOnlyFalse()) .requireCsrfProtectionMatcher( new AndRequestMatcher( new NegatedRequestMatcher( new AntPathRequestMatcher(/api/payment/notify)), new HttpServletRequestMatcher() ) ) ); return http.build(); }6.2 敏感数据加密采用国密SM4算法加密手机号public class Sm4Util { private static final String ALGORITHM_NAME SM4; private static final String DEFAULT_KEY my_secret_key_123; public static String encrypt(String plainText) { Cipher cipher Cipher.getInstance(ALGORITHM_NAME); cipher.init(Cipher.ENCRYPT_MODE, new SecretKeySpec(DEFAULT_KEY.getBytes(), ALGORITHM_NAME)); byte[] encrypted cipher.doFinal(plainText.getBytes()); return Base64.getEncoder().encodeToString(encrypted); } public static String decrypt(String cipherText) { Cipher cipher Cipher.getInstance(ALGORITHM_NAME); cipher.init(Cipher.DECRYPT_MODE, new SecretKeySpec(DEFAULT_KEY.getBytes(), ALGORITHM_NAME)); byte[] decrypted cipher.doFinal( Base64.getDecoder().decode(cipherText)); return new String(decrypted); } }7. 部署与监控7.1 Docker Compose部署version: 3.8 services: app: image: mall-service:1.0 ports: - 8080:8080 environment: - SPRING_PROFILES_ACTIVEprod depends_on: - redis - mysql redis: image: redis:6.2-alpine ports: - 6379:6379 volumes: - redis_data:/data mysql: image: mysql:8.0 ports: - 3306:3306 environment: - MYSQL_ROOT_PASSWORD123456 - MYSQL_DATABASEmall volumes: - mysql_data:/var/lib/mysql volumes: redis_data: mysql_data:7.2 Prometheus监控配置应用暴露metrics端点management.endpoints.web.exposure.includehealth,info,metrics,prometheus management.metrics.tags.application${spring.application.name}Prometheus抓取配置scrape_configs: - job_name: mall-service metrics_path: /actuator/prometheus static_configs: - targets: [app:8080] relabel_configs: - source_labels: [__address__] target_label: instance - source_labels: [__meta_docker_container_name] target_label: container8. 开发经验总结商品图片存储方案选择小项目直接使用OSS Bucket阿里云/七牛云中大型项目自建MinIO集群 CDN加速绝对不要用数据库存图片二进制订单编号生成避坑避免使用纯时间戳并发会重复避免使用UUID无序影响索引性能推荐方案时间戳业务编码随机数例2023081513010012345优惠券核销的并发控制public boolean useCoupon(Long couponId, Long userId) { // 使用CAS乐观锁 int updated couponMapper.updateStatus( couponId, userId, CouponStatus.UNUSED, CouponStatus.USED); return updated 0; }定时任务补偿设计支付超时未回调15分钟延迟队列检查库存扣减失败每小时执行库存对账使用XXL-JOB实现分布式调度这个项目完整实现了电商核心链路在开发过程中特别要注意分布式事务的处理。实际测试时建议用JMeter模拟200并发用户进行全链路压测重点关注库存扣减和订单创建的原子性保证。