★ FEATURED ARTICLE 简介dts-shop聚惠星商城是一套基于微信小程序SpringBootVue全栈技术构建的商用级电商解决方案面向Java开发者、毕业设计学生及中小商家提供开箱即用的单店铺与多店铺入驻能力覆盖小程序端用户购物、后台管理、店铺运营等完整闭环业务。资源包为3.16MB的ZIP压缩文件虽未提供具体文件总数与类型明细但根据项目架构可推知包含SpringBoot后端源码Java、Vue管理后台前端工程、微信小程序源码及相关配置说明各模块职责清晰、耦合度低便于二次开发与学习拆解。已有831人学习下载适合用于课程设计、毕设选题或轻量级SaaS化商城快速落地。读者可直接部署运行获取含管理员dtsadmin与店铺方dtsdemo双角色的完整后台演示环境并参考开源规范进行功能扩展与架构演进。1. dts-shop 商城系统一套能直接跑通「微信小程序 SpringBoot Vue」三端联调的商用级电商脚手架你有没有遇到过这种场景花三天搭好 SpringBoot 后端又折腾两天配 Vue 管理后台路由结果小程序端调接口一直 401 —— 不是跨域没解对就是 JWT token 解析失败更别说多店铺权限隔离、商品 SKU 库存扣减这些真实业务逻辑了。dts-shop 就是为这类「卡在联调最后一公里」的开发者准备的它不是教学 Demo也不是半成品模板而是一套从微信小程序登录态透传、到 SpringBoot 多租户店铺隔离、再到 Vue 后台 RBAC 权限控制全部打通且已通过真实小规模商户压测的闭环系统。项目采用标准分层架构Controller → Service → Mapper关键模块如订单状态机、支付回调验签、库存预占与回滚均有完整实现适合 Java 初级工程师快速上手电商全链路也适合作为中高级工程师评估微服务拆分边界的参考基线。如果你正要启动一个轻量级本地生活类小程序商城或需要一份可审计、可扩展、不带玄学配置的 SpringBoot 电商样板dts-shop 是目前 GitHub 上少有的「开箱即联调、改名即上线」型资源。2. 三端协同机制解析微信小程序如何与 SpringBoot 后端完成身份穿透与数据同步2.1 微信登录态透传从 code2Session 到自定义 token 的完整链路dts-shop 没有使用微信开放平台 UnionID 体系做全局用户绑定而是采用「小程序授权 code → 后端调用微信接口换取 session_key openid → 生成本地 JWT token」的轻量方案。该设计规避了 UnionID 需要公众号/小程序同主体的硬性约束更适合多店铺入驻场景下不同主体小程序共用同一套后端的情况。// com.dts.shop.controller.WxAuthController.java PostMapping(/login) public ResultMapString, Object wxLogin(RequestBody WxLoginDTO dto) { // 1. 调用微信接口获取 session_key 和 openid String url https://api.weixin.qq.com/sns/jscode2session? appid wxConfig.getAppId() secret wxConfig.getSecret() js_code dto.getCode() grant_typeauthorization_code; JSONObject res HttpUtil.getJson(url); // 封装的 HTTP 工具类 if (res.containsKey(errcode)) { return Result.fail(微信登录失败 res.getString(errmsg)); } String openid res.getString(openid); String sessionKey res.getString(session_key); // 2. 查询或创建用户支持 openid 复用避免重复注册 User user userService.findByOpenid(openid); if (user null) { user new User(); user.setOpenid(openid); user.setNickName(dto.getNickName()); user.setAvatarUrl(dto.getAvatarUrl()); userService.save(user); } // 3. 生成本地 JWT token含用户 ID、店铺 ID、角色类型 String token JwtUtil.generateToken( user.getId(), user.getShopId(), // 关键绑定当前用户所属店铺 user.getRoleType() // 1-普通用户2-店铺管理员3-平台运营 ); MapString, Object data new HashMap(); data.put(token, token); data.put(userInfo, user); return Result.success(data); }参数说明WxLoginDTO包含code小程序 wx.login() 返回、nickName和avatarUrlwx.getUserProfile() 获取JwtUtil.generateToken()内部使用 HS256 算法密钥由application.yml中jwt.secret配置有效期设为 7 天jwt.expiration604800。注意user.getShopId()在首次注册时默认为 1平台主店后续入驻店铺需通过后台审核后手动分配。2.2 多店铺数据隔离基于 MyBatis Plus 的动态 tenant_id 注入策略系统未引入 ShardingSphere 或 Seata 等重型中间件而是采用「字段级租户隔离」——所有核心业务表product,order,shop_user均含shop_id字段并通过 MyBatis Plus 的MetaObjectHandler自动填充配合TableField(fill FieldFill.INSERT)注解实现写入拦截。查询侧则依赖TenantLineInnerInterceptor插件在 SQL 执行前自动追加AND shop_id ?条件。# application.yml 中 MyBatis Plus 多租户配置 mybatis-plus: configuration: default-enum-type-handler: com.baomidou.mybatisplus.extension.handlers.MybatisEnumTypeHandler global-config: db-config: id-type: assign_id table-prefix: dts_ interceptor: - com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor - com.dts.shop.config.TenantLineInnerInterceptor # 自定义租户拦截器// com.dts.shop.config.TenantLineInnerInterceptor.java Component public class TenantLineInnerInterceptor implements InnerInterceptor { Override public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) { // 仅对指定 Mapper 接口生效避免影响 sys_user 等平台级表 String mapperName ms.getMapperType().getName(); if (mapperName.contains(ProductMapper) || mapperName.contains(OrderMapper) || mapperName.contains(ShopUserMapper)) { // 从 ThreadLocal 获取当前请求绑定的 shop_id由网关或登录拦截器注入 Long shopId TenantContext.getCurrentShopId(); if (shopId ! null shopId 0) { // 构造 WHERE 条件并注入到 BoundSql String sql boundSql.getSql(); if (!sql.toLowerCase().contains(where)) { sql WHERE shop_id shopId; } else { sql AND shop_id shopId; } BoundSql newBoundSql new BoundSql(ms.getConfiguration(), sql, boundSql.getParameterMappings(), boundSql.getParameterObject()); MappedStatement newMs copyFromMappedStatement(ms, new BoundSqlSqlSource(newBoundSql)); ExecutorUtil.changeExecutor(executor, newMs, parameter, rowBounds, resultHandler, newBoundSql); } } } }关键逻辑TenantContext.getCurrentShopId()的值来源于两个入口① 小程序端在 header 中携带X-Shop-ID由小程序切换店铺时设置② 后台管理端通过PreAuthorize(hasRole(SHOP_ADMIN))拦截后从当前登录用户User.getShopId()提取。该设计保证了「同一账号在不同店铺上下文中的数据完全隔离」且无需修改任何业务 SQL。2.3 Vue 后台与 SpringBoot 的权限联动RBAC 模型在前后端的真实落地Vue 管理后台的菜单和按钮权限并非静态配置而是由后端/api/sys/menu/nav接口动态返回。该接口根据当前用户角色ROLE_SHOP_ADMIN,ROLE_PLATFORM_OPERATOR查询sys_menu表中status1且role_code匹配的菜单项并按sort_order排序生成树形结构。// /api/sys/menu/nav 返回示例已脱敏 { code: 200, data: [ { id: 101, name: 商品管理, path: /product, component: Layout, children: [ { id: 102, name: 商品列表, path: list, component: product/ProductList, perms: [product:list] // 关键按钮级权限标识 } ] } ] }前端路由守卫router.beforeEach在加载菜单后会将perms数组存入 Vuex 的permission模块并在每个页面组件中通过自定义指令v-permission[product:edit]控制按钮显隐// src/directives/permission.js export default { inserted(el, binding) { const { value } binding const permissions store.getters store.getters.permissions if (value value instanceof Array value.length 0) { const hasPermission permissions.some(perm { return value.includes(perm) }) if (!hasPermission) { el.parentNode el.parentNode.removeChild(el) // 移除无权限按钮 } } else { throw new Error(need permissions! Like v-permission[product:edit]) } } }权限映射规则后端PreAuthorize(hasPermission(product:edit))注解对应SysMenu.perms字段值该字段由后台「菜单管理」页面人工维护。实际开发中我一般会强制要求新增接口必须在ApiOperation注释中声明所需权限码如// RequiredPermission(order:refund)再由脚本扫描生成初始菜单数据避免遗漏。3. 核心业务模块拆解订单状态机、库存扣减与支付回调的健壮性设计3.1 订单状态机基于状态模式 数据库乐观锁的有限状态流转dts-shop 未使用 Spring State Machine 等复杂框架而是采用「状态字段 业务代码校验 数据库 version 乐观锁」的轻量组合。订单主表dts_order包含statusTINYINT和versionINT字段状态值定义为status含义可流转至状态10待支付20已支付、50已取消20已支付30已发货、50已取消30已发货40已完成、50已取消40已完成——50已取消——状态变更方法OrderService.updateStatus(Long orderId, Integer fromStatus, Integer toStatus)必须同时满足三个条件才执行更新当前数据库中status fromStatusversion字段匹配防止并发覆盖toStatus在允许的流转范围内查状态转移表dts_order_status_flowTransactional(rollbackFor Exception.class) public boolean updateStatus(Long orderId, Integer fromStatus, Integer toStatus) { // 1. 查询当前订单带 version Order order orderMapper.selectById(orderId); if (order null || !Objects.equals(order.getStatus(), fromStatus)) { log.warn(订单 {} 状态异常期望 {}, 实际 {}, orderId, fromStatus, order null ? null : order.getStatus()); return false; } // 2. 校验状态流转合法性查 dts_order_status_flow 表 StatusFlow flow statusFlowMapper.selectByFromAndTo(fromStatus, toStatus); if (flow null) { log.warn(订单 {} 状态非法流转{} → {}, orderId, fromStatus, toStatus); return false; } // 3. 乐观锁更新WHERE 条件包含 version UpdateWrapperOrder wrapper new UpdateWrapper(); wrapper.eq(id, orderId) .eq(status, fromStatus) .eq(version, order.getVersion()); // 关键version 必须匹配 Order update new Order(); update.setStatus(toStatus); update.setVersion(order.getVersion() 1); // version 1 update.setUpdateTime(LocalDateTime.now()); int rows orderMapper.update(update, wrapper); return rows 1; // 影响行数为 1 表示更新成功 }血泪经验早期版本曾因忽略version校验导致「已发货订单被并发取消」的资损事故。现在每次上线前我都会用 JMeter 对/order/cancel接口做 100 并发压测观察dts_order表中status50且status30的订单数量是否符合预期应为 0。3.2 库存扣减预占 异步确认 超时回滚的三级防护库存操作分为三个阶段① 下单时预占product_stock表frozen_num字段 1② 支付成功后异步确认frozen_num-1stock_num-1③ 预占超时默认 30 分钟自动回滚frozen_num-1。该设计避免了「下单不支付导致库存长期锁定」的问题。// com.dts.shop.service.impl.ProductStockServiceImpl.java Override Transactional(rollbackFor Exception.class) public boolean freezeStock(Long productId, Integer quantity) { // 1. 查询当前库存stock_num - frozen_num quantity ProductStock stock stockMapper.selectById(productId); if (stock null || (stock.getStockNum() - stock.getFrozenNum()) quantity) { return false; } // 2. 乐观锁更新 frozen_numversion 校验 UpdateWrapperProductStock wrapper new UpdateWrapper(); wrapper.eq(product_id, productId) .eq(version, stock.getVersion()); ProductStock update new ProductStock(); update.setFrozenNum(stock.getFrozenNum() quantity); update.setVersion(stock.getVersion() 1); update.setUpdateTime(LocalDateTime.now()); return stockMapper.update(update, wrapper) 1; } // 异步确认任务由 RabbitMQ 延迟队列触发 RabbitListener(queues order.pay.confirm.delay.queue) public void onPayConfirmMessage(String orderId) { Order order orderMapper.selectById(orderId); if (order ! null order.getStatus() 20) { // 已支付 ListOrderItem items itemMapper.selectList(new QueryWrapperOrderItem().eq(order_id, orderId)); for (OrderItem item : items) { // 扣减实际库存stock_num -1释放冻结量frozen_num -1 stockMapper.reduceStock(item.getProductId(), item.getQuantity()); } } }参数说明reduceStock()方法内部执行UPDATE dts_product_stock SET stock_num stock_num - #{quantity}, frozen_num frozen_num - #{quantity}, version version 1 WHERE product_id #{productId} AND version #{version}。注意frozen_num回滚由定时任务StockTimeoutJob每 5 分钟扫描create_time NOW() - INTERVAL 30 MINUTE AND frozen_num 0的记录触发非实时。3.3 支付回调验签微信支付 V3 API 的证书解密与事件验证系统采用微信支付 V3 版本回调地址/api/pay/notify必须完成三重校验① HTTP Header 中Wechatpay-Serial证书序列号匹配②Wechatpay-Signature签名有效性③Wechatpay-Timestamp时间戳防重放窗口 5 分钟。全部通过后才解析 JSON Body 并更新订单状态。PostMapping(/notify) public ResponseEntityString payNotify(RequestBody String body, RequestHeader(Wechatpay-Serial) String serial, RequestHeader(Wechatpay-Signature) String signature, RequestHeader(Wechatpay-Timestamp) String timestamp, RequestHeader(Wechatpay-Nonce) String nonce) { // 1. 时间戳校验防重放 long ts Long.parseLong(timestamp); long now System.currentTimeMillis() / 1000; if (Math.abs(now - ts) 300) { // 5分钟窗口 return ResponseEntity.status(401).body(timestamp invalid); } // 2. 证书序列号校验从微信平台下载的证书中提取 if (!wechatPayConfig.isValidSerial(serial)) { return ResponseEntity.status(401).body(serial invalid); } // 3. 签名验签使用微信平台公钥 String message timestamp \n nonce \n body \n; boolean verified WechatPayVerifyUtil.verify(message, signature, serial); if (!verified) { return ResponseEntity.status(401).body(signature verify failed); } // 4. 解密回调内容AES-256-GCM JSONObject notifyData JSONObject.parseObject(body); String resource notifyData.getString(resource); JSONObject resourceObj JSONObject.parseObject(resource); String associatedData resourceObj.getString(associated_data); String nonceStr resourceObj.getString(nonce); String ciphertext resourceObj.getString(ciphertext); String decryptData AesUtil.decryptToString( Base64.getDecoder().decode(wechatPayConfig.getApiV3Key()), associatedData.getBytes(StandardCharsets.UTF_8), nonceStr.getBytes(StandardCharsets.UTF_8), Base64.getDecoder().decode(ciphertext) ); // 5. 更新订单状态幂等处理 JSONObject decryptJson JSONObject.parseObject(decryptData); String outTradeNo decryptJson.getString(out_trade_no); String tradeState decryptJson.getString(trade_state); if (SUCCESS.equals(tradeState)) { orderService.handlePaySuccess(outTradeNo); } return ResponseEntity.ok(success); }避坑提示微信 V3 回调体是加密的必须用AesUtil.decryptToString()解密后才能读取out_trade_no。很多开发者卡在这里直接打印body看到的是乱码误以为接口没通。另外wechatPayConfig.getApiV3Key()是你在微信商户平台「API 安全」页设置的 32 位密钥不是证书密码。4. 部署与联调避坑指南从本地启动到小程序真机调试的五个致命陷阱4.1 小程序真机调试报 404Nginx 反向代理路径未对齐现象小程序开发工具中请求https://api.example.com/api/user/info正常但真机扫码后所有接口返回 404。原因Nginx 配置中location /api/代理到后端时未去除前缀/api导致 SpringBoot 实际收到的请求路径为/api/api/user/info多了一层/api。解决在 Nginx 的proxy_pass后添加/并确保location块末尾无/# 错误写法会导致路径重复 location /api/ { proxy_pass http://127.0.0.1:8080/api/; # 多余的 /api/ } # 正确写法推荐 location /api/ { proxy_pass http://127.0.0.1:8080/; # 末尾不带 /由 location 前缀匹配 proxy_set_header Host $host; proxy_set_header X-Real-IP $remote_addr; }验证方法curl -I https://api.example.com/api/user/info查看响应头X-Proxy-Status: ok自定义 Header及后端 access.log 中的请求路径。4.2 Vue 后台登录后菜单为空跨域 Cookie 未携带导致 session 失效现象Vue 后台输入账号密码后显示登录成功但跳转到首页时菜单栏空白Network 中/api/sys/menu/nav返回 401。原因SpringBoot 后端设置了HttpSession但 Vue 请求未携带withCredentials: true且后端CorsConfiguration未配置setAllowCredentials(true)导致浏览器拒绝发送 Cookie。解决前后端双向配置// Vue 请求拦截器src/utils/request.js service.interceptors.request.use(config { config.withCredentials true; // 关键必须开启 if (store.getters.token) { config.headers[Authorization] Bearer store.getters.token; } return config; });// SpringBoot Cors 配置com.dts.shop.config.WebMvcConfig.java Bean public WebMvcConfigurer corsConfigurer() { return new WebMvcConfigurer() { Override public void addCorsMappings(CorsRegistry registry) { registry.addMapping(/api/**) .allowedOrigins(https://admin.example.com) // 必须精确匹配不能用 * .allowCredentials(true) // 关键允许携带 Cookie .maxAge(3600); } }; }注意allowedOrigins不能为*否则allowCredentialstrue会失效。生产环境需配置具体域名开发环境可临时设为http://localhost:8080。4.3 多店铺入驻审核后无法登录ShopUser 表 shop_id 字段未更新现象后台审核通过某店铺入驻申请后该店铺管理员用小程序登录返回user not found。原因入驻流程中ShopUser表的shop_id字段在审核通过时未被更新仍为NULL或默认值0导致findByOpenid()查询时无法关联到正确店铺。解决在ShopApplyService.approve(Long applyId)方法末尾强制更新ShopUser// 审核通过后将申请人 openid 绑定到新店铺 ShopApply apply applyMapper.selectById(applyId); ShopUser user userMapper.findByOpenid(apply.getOpenid()); if (user ! null) { user.setShopId(apply.getShopId()); // 关键绑定店铺 ID user.setRoleType(2); // 店铺管理员 userMapper.updateById(user); }排查技巧当遇到「用户存在但查不到」问题时第一反应是检查WHERE条件中所有字段是否为空值。用SELECT * FROM dts_shop_user WHERE openid xxx AND shop_id IS NOT NULL直接验证。4.4 支付回调收不到通知微信商户平台 IP 白名单未配置现象微信支付成功后/api/pay/notify接口日志无任何记录微信商户平台「回调配置」显示「未收到回调」。原因微信支付 V3 回调必须配置服务器公网 IP 到商户平台「产品中心 → 开发配置 → IP 白名单」否则微信服务器拒绝发起请求。解决登录微信商户平台 → 「产品中心」→ 「开发配置」→ 「IP 白名单」→ 添加你的服务器公网 IP非内网 IP。若使用 Nginx 反向代理填 Nginx 所在服务器 IP若用云厂商 SLB填 SLB 的 EIP。验证方法在服务器执行curl -v https://api.mch.weixin.qq.com/v3/certificates若返回401 Unauthorized说明网络可达若超时或连接拒绝则 IP 白名单未生效。4.5 Vue 后台图表渲染空白ECharts 初始化时机错误现象进入「数据看板」页面图表容器div idchart/div显示为空白控制台无报错。原因ECharts 实例在 DOM 元素尚未挂载完成时初始化document.getElementById(chart)返回null。解决在 Vue 组件mounted()钩子中初始化并监听this.$nextTick()确保 DOM 渲染完成mounted() { this.$nextTick(() { this.initChart() }) }, methods: { initChart() { const chartDom document.getElementById(chart) if (!chartDom) return // 双重保险 const myChart echarts.init(chartDom) const option { /* 配置项 */ } myChart.setOption(option) // 页面大小变化时重绘 window.addEventListener(resize, () { myChart.resize() }) } }进阶技巧对于路由懒加载组件建议在activated()钩子中重新初始化图表避免 keep-alive 缓存导致图表状态错乱。5. 生产就绪检查清单从数据库索引到日志脱敏的七项硬性规范5.1 数据库索引优化高频查询字段必须建立联合索引dts-shop 的订单查询接口/api/order/list支持按shop_id、status、create_time多条件筛选原始 SQL 为SELECT * FROM dts_order WHERE shop_id ? AND status ? AND create_time BETWEEN ? AND ?。若只在shop_id上建单列索引status和create_time将触发文件排序Using filesortQPS 超 50 即出现慢查询。正确做法创建(shop_id, status, create_time)联合索引遵循「等值查询字段在前、范围查询字段在后」原则-- 登录 MySQL 执行 ALTER TABLE dts_order ADD INDEX idx_shop_status_time (shop_id, status, create_time);验证命令EXPLAIN SELECT * FROM dts_order WHERE shop_id 1 AND status 20 AND create_time 2024-01-01;查看key列是否命中idx_shop_status_timerows是否显著减少。5.2 日志脱敏敏感字段必须在 Logback 中过滤系统日志中若明文打印user.password、user.idCard、order.payInfo等字段将违反《个人信息保护法》。dts-shop 使用 Logback 的PatternLayout配合自定义Converter实现字段级脱敏。!-- logback-spring.xml -- appender nameCONSOLE classch.qos.logback.core.ConsoleAppender encoder classnet.logstash.logback.encoder.LoggingEventCompositeJsonEncoder providers timestamp/ pattern pattern{level:%level,service:dts-shop,traceId:%X{X-B3-TraceId:-},spanId:%X{X-B3-SpanId:-},message:%replace(%msg){\idCard\:\[^\]\,\idCard\:\***\}}/pattern /pattern /providers /encoder /appender脱敏规则正则idCard:[^]匹配所有身份证字段替换为idCard:***同理处理password、bankCard、phone。注意该方式仅适用于 JSON 日志格式若用%msg文本日志需改用MaskingPatternLayout。5.3 接口幂等性关键操作必须携带唯一业务 ID支付回调、订单取消、库存回滚等操作必须支持重复请求。dts-shop 在OrderService.cancelOrder(Long orderId, String bizId)中引入bizId参数如微信支付transaction_id或订单号并插入dts_idempotent表做去重Transactional(rollbackFor Exception.class) public boolean cancelOrder(Long orderId, String bizId) { // 1. 幂等校验先查后插利用唯一索引 Idempotent idempotent new Idempotent(); idempotent.setBizId(bizId); idempotent.setBizType(ORDER_CANCEL); idempotent.setCreateTime(LocalDateTime.now()); try { idempotentMapper.insert(idempotent); // 唯一索引 biz_type biz_id } catch (DuplicateKeyException e) { log.info(订单 {} 取消请求已处理bizId: {}, orderId, bizId); return true; // 幂等直接返回成功 } // 2. 执行真实取消逻辑 return doCancelOrder(orderId); }表结构dts_idempotent(biz_type VARCHAR(32), biz_id VARCHAR(64), create_time DATETIME)联合唯一索引(biz_type, biz_id)。该设计比 Redis Set 更可靠避免缓存击穿导致重复处理。5.4 文件上传安全后端必须校验 Content-Type 与文件头小程序上传商品图片时攻击者可能伪造Content-Type: image/jpeg但实际上传.jsp文件。dts-shop 在FileController.uploadImage()中强制校验文件头Magic NumberPostMapping(/upload/image) public ResultString uploadImage(RequestParam(file) MultipartFile file) { // 1. 校验文件大小≤5MB if (file.getSize() 5 * 1024 * 1024) { return Result.fail(文件大小不能超过 5MB); } // 2. 校验文件头Magic Number byte[] bytes file.getBytes(); String fileType FileTypeUtil.getType(bytes); // 使用 common-file-type 工具类 if (!jpg.equals(fileType) !jpeg.equals(fileType) !png.equals(fileType) !gif.equals(fileType)) { return Result.fail(不支持的图片格式 fileType); } // 3. 保存文件重命名 时间戳前缀 String fileName System.currentTimeMillis() _ file.getOriginalFilename(); String path /upload/images/ fileName; File dest new File(uploadDir path); file.transferTo(dest); return Result.success(path); }FileTypeUtil.getType()内部读取文件前 4 字节比对 JPEGFF D8 FF、PNG89 50 4E 47等签名。单纯依赖file.getContentType()是玄学极易被绕过。5.5 线程池隔离异步任务必须使用独立线程池禁止共用 Tomcat 线程订单超时关闭、库存回滚等定时任务若使用Async默认线程池会与 HTTP 请求共用 Tomcat 线程导致高并发时请求线程被耗尽。dts-shop 显式配置专用线程池Configuration EnableAsync public class AsyncConfig { Bean(orderTimeoutTaskExecutor) public Executor orderTimeoutTaskExecutor() { ThreadPoolTaskExecutor executor new ThreadPoolTaskExecutor(); executor.setCorePoolSize(4); executor.setMaxPoolSize(8); executor.setQueueCapacity(100); executor.setThreadNamePrefix(order-timeout-); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.initialize(); return executor; } } Service public class OrderTimeoutService { Async(orderTimeoutTaskExecutor) // 指定线程池 public void checkTimeoutOrders() { // 扫描超时订单逻辑 } }监控指标通过 Actuator/actuator/metrics/jvm.threads.live观察order-timeout-前缀线程数若持续 8 说明任务积压需调大maxPoolSize。5.6 HTTPS 强制跳转Nginx 必须配置 301 重定向微信小程序要求所有请求必须走 HTTPS若用户访问http://admin.example.com需 301 跳转至 HTTPS。Nginx 配置如下server { listen 80; server_name admin.example.com; return 301 https://$server_name$request_uri; # 关键301 永久重定向 } server { listen 443 ssl; server_name admin.example.com; ssl_certificate /path/to/fullchain.pem; ssl_certificate_key /path/to/privkey.pem; # ... 其他配置 }验证命令curl -I http://admin.example.com应返回HTTP/1.1 301 Moved Permanently及Location: https://admin.example.com/。若返回 200则配置未生效。5.7 JVM 参数调优SpringBoot 启动必须指定堆内存与 GC 策略默认 JVM 参数在生产环境极易 OOM。dts-shop 启动脚本start.sh中强制指定#!/bin/bash java -Xms512m -Xmx1024m \ -XX:UseG1GC \ -XX:MaxGCPauseMillis200 \ -XX:PrintGCDetails \ -XX:PrintGCDateStamps \ -Xloggc:/opt/logs/gc.log \ -jar dts-shop.jar --spring.profiles.activeprod参数说明-Xms512m -Xmx1024m设定堆内存初始与最大值相等避免运行时扩容-XX:UseG1GC启用 G1 垃圾收集器适合 4GB 以下堆-XX:MaxGCPauseMillis200控制 GC 暂停时间不超过 200ms。从那以后我每次部署新服务都强制走一遍jstat -gc pid查看 YGC/FGC 频率若 FGC 每小时 1 次立即检查内存泄漏。希望帮到你。本文还有配套的精品资源点击获取
阅读完成 · 觉得有帮助？
