1. 项目背景与意义随着社会经济发展和人们生活水平的提高宠物已成为越来越多家庭的重要成员。然而传统的宠物服务市场存在信息不对称、服务分散、管理不规范等问题。宠物主人在寻找宠物医疗、美容、寄养、食品用品购买等服务时往往需要花费大量时间和精力进行筛选和比较。SpringBoot宠物一站式服务平台旨在通过互联网技术整合宠物服务资源为宠物主人提供便捷、透明、可靠的一站式服务体验。该平台的建设具有以下重要意义提升服务效率通过线上预约、在线咨询、智能推荐等功能减少用户等待时间优化服务流程。规范市场秩序建立服务商准入和评价体系促进宠物服务行业的标准化和规范化发展。促进信息共享构建宠物健康档案、服务记录等数据共享机制为宠物提供连续性的健康管理服务。推动产业升级通过数字化手段连接宠物主人、服务商和供应商形成完整的宠物服务生态链。2. 技术栈选型2.1 后端技术栈Spring Boot 3.x作为核心框架提供快速开发、自动配置和微服务支持。Spring Security负责用户认证、授权和安全防护。Spring Data JPA简化数据库操作支持对象关系映射。MySQL 8.0作为关系型数据库存储用户、宠物、订单等核心业务数据。Redis用于缓存热点数据、会话管理和分布式锁。RabbitMQ实现异步消息处理如订单通知、服务提醒等。Elasticsearch提供宠物服务、商品等内容的全文检索功能。MinIO对象存储服务用于存储宠物图片、服务商资质文件等。2.2 前端技术栈Vue 3 TypeScript构建响应式、类型安全的用户界面。Element Plus提供丰富的UI组件库加速开发进程。Axios处理HTTP请求与后端API进行通信。Vue Router实现前端路由管理。Pinia状态管理库替代Vuex。2.3 开发与部署Maven/Gradle项目构建和依赖管理。Docker Docker Compose容器化部署实现环境一致性。Jenkins/GitLab CI持续集成和持续部署流水线。Nginx反向代理和负载均衡。3. 系统核心模块设计3.1 用户中心模块负责用户注册、登录、个人信息管理和宠物档案管理。支持多角色普通用户、服务商、管理员权限控制。3.2 服务商城模块整合宠物医疗、美容、寄养、训练等服务提供分类展示、搜索筛选、在线预约和评价功能。3.3 商品商城模块销售宠物食品、用品、药品等商品支持购物车、订单管理和在线支付。3.4 社区交流模块提供养宠经验分享、问答互助、活动发布等社交功能增强用户粘性。3.5 后台管理模块为管理员和服务商提供数据统计、内容审核、订单处理、用户管理等后台操作界面。4. 核心代码实现4.1 项目结构pet-platform/ ├── src/main/java/com/petplatform/ │ ├── PetPlatformApplication.java # 启动类 │ ├── config/ # 配置类 │ ├── controller/ # 控制器层 │ ├── service/ # 服务层 │ ├── repository/ # 数据访问层 │ ├── entity/ # 实体类 │ ├── dto/ # 数据传输对象 │ ├── vo/ # 视图对象 │ ├── exception/ # 异常处理 │ └── util/ # 工具类 ├── src/main/resources/ │ ├── application.yml # 主配置文件 │ ├── application-dev.yml # 开发环境配置 │ ├── application-prod.yml # 生产环境配置 │ └── mapper/ # MyBatis映射文件如使用 └── pom.xml # Maven依赖管理4.2 核心实体类设计// 用户实体 Entity Table(name user) Data NoArgsConstructor AllArgsConstructor public class User { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; Column(unique true, nullable false) private String username; // 用户名 private String password; // 密码加密后 private String nickname; // 昵称 private String phone; // 手机号 private String email; // 邮箱 Enumerated(EnumType.STRING) private UserRole role; // 用户角色 Enumerated(EnumType.STRING) private UserStatus status; // 用户状态 CreationTimestamp private LocalDateTime createTime; // 创建时间 UpdateTimestamp private LocalDateTime updateTime; // 更新时间 } // 宠物实体 Entity Table(name pet) Data NoArgsConstructor AllArgsConstructor public class Pet { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String name; // 宠物名称 Enumerated(EnumType.STRING) private PetType type; // 宠物类型猫、狗等 private String breed; // 品种 private Integer age; // 年龄月 private Double weight; // 体重kg private String avatar; // 头像URL ManyToOne JoinColumn(name owner_id) private User owner; // 所属主人 CreationTimestamp private LocalDateTime createTime; } // 服务订单实体 Entity Table(name service_order) Data NoArgsConstructor AllArgsConstructor public class ServiceOrder { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String orderNo; // 订单编号 ManyToOne JoinColumn(name user_id) private User user; // 下单用户 ManyToOne JoinColumn(name service_id) private ServiceItem serviceItem; // 服务项目 ManyToOne JoinColumn(name pet_id) private Pet pet; // 服务宠物 private LocalDateTime serviceTime; // 预约服务时间 private String address; // 服务地址 private BigDecimal amount; // 订单金额 Enumerated(EnumType.STRING) private OrderStatus status; // 订单状态 CreationTimestamp private LocalDateTime createTime; }4.3 服务层核心逻辑// 服务预约业务逻辑 Service RequiredArgsConstructor Slf4j public class ServiceOrderService { private final ServiceOrderRepository orderRepository; private final ServiceItemRepository serviceRepository; private final UserRepository userRepository; private final PetRepository petRepository; private final RabbitTemplate rabbitTemplate; /** 创建服务预约订单 */ Transactional public ServiceOrderVO createOrder(ServiceOrderCreateDTO dto) { // 1. 参数校验 User user userRepository.findById(dto.getUserId()) .orElseThrow(() - new BusinessException(用户不存在)); ServiceItem service serviceRepository.findById(dto.getServiceId()) .orElseThrow(() - new BusinessException(服务项目不存在)); Pet pet petRepository.findById(dto.getPetId()) .orElseThrow(() - new BusinessException(宠物不存在)); // 2. 检查服务时间是否可用 if (!isServiceTimeAvailable(service, dto.getServiceTime())) { throw new BusinessException(该时间段已被预约请选择其他时间); } // 3. 生成订单 ServiceOrder order new ServiceOrder(); order.setOrderNo(generateOrderNo()); order.setUser(user); order.setServiceItem(service); order.setPet(pet); order.setServiceTime(dto.getServiceTime()); order.setAddress(dto.getAddress()); order.setAmount(service.getPrice()); order.setStatus(OrderStatus.PENDING_PAYMENT); // 4. 保存订单 ServiceOrder savedOrder orderRepository.save(order); // 5. 发送订单创建消息 sendOrderCreatedMessage(savedOrder); log.info(服务订单创建成功订单号{}, savedOrder.getOrderNo()); // 6. 返回视图对象 return convertToVO(savedOrder); } /** 检查服务时间是否可用 */ private boolean isServiceTimeAvailable(ServiceItem service, LocalDateTime serviceTime) { // 查询该服务在该时间段是否已有预约 long count orderRepository.countByServiceItemAndServiceTimeAndStatusNot( service, serviceTime, OrderStatus.CANCELLED ); return count 0; } /** 生成订单编号 */ private String generateOrderNo() { return SO System.currentTimeMillis() RandomUtil.randomNumbers(4); } /** 发送订单创建消息到消息队列 */ private void sendOrderCreatedMessage(ServiceOrder order) { OrderMessage message new OrderMessage(); message.setOrderId(order.getId()); message.setOrderNo(order.getOrderNo()); message.setUserId(order.getUser().getId()); message.setServiceName(order.getServiceItem().getName()); message.setServiceTime(order.getServiceTime()); rabbitTemplate.convertAndSend( order.exchange, order.created, message ); } /** 实体转视图对象 */ private ServiceOrderVO convertToVO(ServiceOrder order) { ServiceOrderVO vo new ServiceOrderVO(); BeanUtils.copyProperties(order, vo); vo.setServiceName(order.getServiceItem().getName()); vo.setPetName(order.getPet().getName()); vo.setUserName(order.getUser().getNickname()); return vo; } }4.4 控制器层实现// 服务订单控制器 RestController RequestMapping(/api/service-order) RequiredArgsConstructor Validated Slf4j public class ServiceOrderController { private final ServiceOrderService orderService; /** 创建服务订单 */ PostMapping(/create) PreAuthorize(hasRole(USER)) public Resultlt;ServiceOrderVOgt; createOrder(Valid RequestBody ServiceOrderCreateDTO dto) { ServiceOrderVO orderVO orderService.createOrder(dto); return Result.success(预约成功, orderVO); } /** 查询用户订单列表 */ GetMapping(/list) PreAuthorize(hasRole(USER)) public Resultlt;PageResultlt;ServiceOrderVOgt;gt; listOrders( RequestParam(defaultValue 1) Integer page, RequestParam(defaultValue 10) Integer size, RequestParam(required false) OrderStatus status) { Pageable pageable PageRequest.of(page - 1, size, Sort.by(createTime).descending()); PageResultlt;ServiceOrderVOgt; pageResult orderService.listUserOrders(pageable, status); return Result.success(pageResult); } /** 取消订单 */ PostMapping(/{orderId}/cancel) PreAuthorize(hasRole(USER)) public Resultlt;Voidgt; cancelOrder(PathVariable Long orderId) { orderService.cancelOrder(orderId); return Result.success(订单取消成功); } /** 支付订单 */ PostMapping(/{orderId}/pay) PreAuthorize(hasRole(USER)) public Resultlt;Voidgt; payOrder(PathVariable Long orderId) { orderService.payOrder(orderId); return Result.success(支付成功); } } // 统一返回结果封装 Data NoArgsConstructor AllArgsConstructor public class ResultT { private Integer code; // 状态码 private String message; // 消息 private T data; // 数据 private Long timestamp; // 时间戳 public static lt;Tgt; Resultlt;Tgt; success(T data) { return new Resultlt;gt;(200, success, data, System.currentTimeMillis()); } public static lt;Tgt; Resultlt;Tgt; success(String message, T data) { return new Resultlt;gt;(200, message, data, System.currentTimeMillis()); } public static Resultlt;Voidgt; error(Integer code, String message) { return new Resultlt;gt;(code, message, null, System.currentTimeMillis()); } }4.5 关键配置示例# application.yml 主配置文件 spring: application: name: pet-platform 数据源配置 datasource: url: jdbc:mysql://localhost:3306/pet_platform?useUnicodetruecharacterEncodingutf8useSSLfalseserverTimezoneAsia/Shanghai username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver hikari: maximum-pool-size: 20 minimum-idle: 5 connection-timeout: 30000 JPA配置 jpa: hibernate: ddl-auto: update show-sql: true properties: hibernate: format_sql: true dialect: org.hibernate.dialect.MySQL8Dialect Redis配置 redis: host: localhost port: 6379 password: database: 0 timeout: 5000ms lettuce: pool: max-active: 20 max-idle: 10 min-idle: 5 RabbitMQ配置 rabbitmq: host: localhost port: 5672 username: guest password: guest virtual-host: / 文件上传配置 servlet: multipart: max-file-size: 10MB max-request-size: 20MB 自定义配置 pet: platform: # 订单相关配置 order: auto-cancel-minutes: 30 # 未支付订单自动取消时间分钟 refund-deadline-days: 7 # 退款申请截止天数 # 文件存储配置 file: upload-path: /data/pet-platform/uploads access-url: http://localhost:8080/uploads 短信配置 sms: enabled: false provider: aliyun sign-name: 宠物平台 template-code: SMS_123456789 日志配置 logging: level: com.petplatform: DEBUG org.springframework.web: INFO file: name: logs/pet-platform.log pattern: console: %d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n5. 关键技术实现要点5.1 分布式锁防止超卖// 使用Redis实现分布式锁 Service RequiredArgsConstructor public class InventoryService { private final RedisTemplatelt;String, Stringgt; redisTemplate; private final ProductRepository productRepository; /** 扣减库存使用分布式锁 */ public boolean deductStock(Long productId, Integer quantity) { String lockKey lock:product: productId; String requestId UUID.randomUUID().toString(); try { // 尝试获取分布式锁 Boolean locked redisTemplate.opsForValue().setIfAbsent( lockKey, requestId, 10, TimeUnit.SECONDS ); if (Boolean.TRUE.equals(locked)) { try { // 查询商品库存 Product product productRepository.findById(productId) .orElseThrow(() -gt; new BusinessException(商品不存在)); if (product.getStock() amp;amp;lt; quantity) { return false; // 库存不足 }lt;/codegt;lt;/pregt;/code/pre
1. 项目背景与意义随着社会经济发展和人们生活水平的提高宠物已成为越来越多家庭的重要成员。然而传统的宠物服务市场存在信息不对称、服务分散、管理不规范等问题。宠物主人在寻找宠物医疗、美容、寄养、食品用品购买等服务时往往需要花费大量时间和精力进行筛选和比较。SpringBoot宠物一站式服务平台旨在通过互联网技术整合宠物服务资源为宠物主人提供便捷、透明、可靠的一站式服务体验。该平台的建设具有以下重要意义提升服务效率通过线上预约、在线咨询、智能推荐等功能减少用户等待时间优化服务流程。规范市场秩序建立服务商准入和评价体系促进宠物服务行业的标准化和规范化发展。促进信息共享构建宠物健康档案、服务记录等数据共享机制为宠物提供连续性的健康管理服务。推动产业升级通过数字化手段连接宠物主人、服务商和供应商形成完整的宠物服务生态链。2. 技术栈选型2.1 后端技术栈Spring Boot 3.x作为核心框架提供快速开发、自动配置和微服务支持。Spring Security负责用户认证、授权和安全防护。Spring Data JPA简化数据库操作支持对象关系映射。MySQL 8.0作为关系型数据库存储用户、宠物、订单等核心业务数据。Redis用于缓存热点数据、会话管理和分布式锁。RabbitMQ实现异步消息处理如订单通知、服务提醒等。Elasticsearch提供宠物服务、商品等内容的全文检索功能。MinIO对象存储服务用于存储宠物图片、服务商资质文件等。2.2 前端技术栈Vue 3 TypeScript构建响应式、类型安全的用户界面。Element Plus提供丰富的UI组件库加速开发进程。Axios处理HTTP请求与后端API进行通信。Vue Router实现前端路由管理。Pinia状态管理库替代Vuex。2.3 开发与部署Maven/Gradle项目构建和依赖管理。Docker Docker Compose容器化部署实现环境一致性。Jenkins/GitLab CI持续集成和持续部署流水线。Nginx反向代理和负载均衡。3. 系统核心模块设计3.1 用户中心模块负责用户注册、登录、个人信息管理和宠物档案管理。支持多角色普通用户、服务商、管理员权限控制。3.2 服务商城模块整合宠物医疗、美容、寄养、训练等服务提供分类展示、搜索筛选、在线预约和评价功能。3.3 商品商城模块销售宠物食品、用品、药品等商品支持购物车、订单管理和在线支付。3.4 社区交流模块提供养宠经验分享、问答互助、活动发布等社交功能增强用户粘性。3.5 后台管理模块为管理员和服务商提供数据统计、内容审核、订单处理、用户管理等后台操作界面。4. 核心代码实现4.1 项目结构pet-platform/ ├── src/main/java/com/petplatform/ │ ├── PetPlatformApplication.java # 启动类 │ ├── config/ # 配置类 │ ├── controller/ # 控制器层 │ ├── service/ # 服务层 │ ├── repository/ # 数据访问层 │ ├── entity/ # 实体类 │ ├── dto/ # 数据传输对象 │ ├── vo/ # 视图对象 │ ├── exception/ # 异常处理 │ └── util/ # 工具类 ├── src/main/resources/ │ ├── application.yml # 主配置文件 │ ├── application-dev.yml # 开发环境配置 │ ├── application-prod.yml # 生产环境配置 │ └── mapper/ # MyBatis映射文件如使用 └── pom.xml # Maven依赖管理4.2 核心实体类设计// 用户实体 Entity Table(name user) Data NoArgsConstructor AllArgsConstructor public class User { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; Column(unique true, nullable false) private String username; // 用户名 private String password; // 密码加密后 private String nickname; // 昵称 private String phone; // 手机号 private String email; // 邮箱 Enumerated(EnumType.STRING) private UserRole role; // 用户角色 Enumerated(EnumType.STRING) private UserStatus status; // 用户状态 CreationTimestamp private LocalDateTime createTime; // 创建时间 UpdateTimestamp private LocalDateTime updateTime; // 更新时间 } // 宠物实体 Entity Table(name pet) Data NoArgsConstructor AllArgsConstructor public class Pet { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String name; // 宠物名称 Enumerated(EnumType.STRING) private PetType type; // 宠物类型猫、狗等 private String breed; // 品种 private Integer age; // 年龄月 private Double weight; // 体重kg private String avatar; // 头像URL ManyToOne JoinColumn(name owner_id) private User owner; // 所属主人 CreationTimestamp private LocalDateTime createTime; } // 服务订单实体 Entity Table(name service_order) Data NoArgsConstructor AllArgsConstructor public class ServiceOrder { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String orderNo; // 订单编号 ManyToOne JoinColumn(name user_id) private User user; // 下单用户 ManyToOne JoinColumn(name service_id) private ServiceItem serviceItem; // 服务项目 ManyToOne JoinColumn(name pet_id) private Pet pet; // 服务宠物 private LocalDateTime serviceTime; // 预约服务时间 private String address; // 服务地址 private BigDecimal amount; // 订单金额 Enumerated(EnumType.STRING) private OrderStatus status; // 订单状态 CreationTimestamp private LocalDateTime createTime; }4.3 服务层核心逻辑// 服务预约业务逻辑 Service RequiredArgsConstructor Slf4j public class ServiceOrderService { private final ServiceOrderRepository orderRepository; private final ServiceItemRepository serviceRepository; private final UserRepository userRepository; private final PetRepository petRepository; private final RabbitTemplate rabbitTemplate; /** 创建服务预约订单 */ Transactional public ServiceOrderVO createOrder(ServiceOrderCreateDTO dto) { // 1. 参数校验 User user userRepository.findById(dto.getUserId()) .orElseThrow(() - new BusinessException(用户不存在)); ServiceItem service serviceRepository.findById(dto.getServiceId()) .orElseThrow(() - new BusinessException(服务项目不存在)); Pet pet petRepository.findById(dto.getPetId()) .orElseThrow(() - new BusinessException(宠物不存在)); // 2. 检查服务时间是否可用 if (!isServiceTimeAvailable(service, dto.getServiceTime())) { throw new BusinessException(该时间段已被预约请选择其他时间); } // 3. 生成订单 ServiceOrder order new ServiceOrder(); order.setOrderNo(generateOrderNo()); order.setUser(user); order.setServiceItem(service); order.setPet(pet); order.setServiceTime(dto.getServiceTime()); order.setAddress(dto.getAddress()); order.setAmount(service.getPrice()); order.setStatus(OrderStatus.PENDING_PAYMENT); // 4. 保存订单 ServiceOrder savedOrder orderRepository.save(order); // 5. 发送订单创建消息 sendOrderCreatedMessage(savedOrder); log.info(服务订单创建成功订单号{}, savedOrder.getOrderNo()); // 6. 返回视图对象 return convertToVO(savedOrder); } /** 检查服务时间是否可用 */ private boolean isServiceTimeAvailable(ServiceItem service, LocalDateTime serviceTime) { // 查询该服务在该时间段是否已有预约 long count orderRepository.countByServiceItemAndServiceTimeAndStatusNot( service, serviceTime, OrderStatus.CANCELLED ); return count 0; } /** 生成订单编号 */ private String generateOrderNo() { return SO System.currentTimeMillis() RandomUtil.randomNumbers(4); } /** 发送订单创建消息到消息队列 */ private void sendOrderCreatedMessage(ServiceOrder order) { OrderMessage message new OrderMessage(); message.setOrderId(order.getId()); message.setOrderNo(order.getOrderNo()); message.setUserId(order.getUser().getId()); message.setServiceName(order.getServiceItem().getName()); message.setServiceTime(order.getServiceTime()); rabbitTemplate.convertAndSend( order.exchange, order.created, message ); } /** 实体转视图对象 */ private ServiceOrderVO convertToVO(ServiceOrder order) { ServiceOrderVO vo new ServiceOrderVO(); BeanUtils.copyProperties(order, vo); vo.setServiceName(order.getServiceItem().getName()); vo.setPetName(order.getPet().getName()); vo.setUserName(order.getUser().getNickname()); return vo; } }4.4 控制器层实现// 服务订单控制器 RestController RequestMapping(/api/service-order) RequiredArgsConstructor Validated Slf4j public class ServiceOrderController { private final ServiceOrderService orderService; /** 创建服务订单 */ PostMapping(/create) PreAuthorize(hasRole(USER)) public Resultlt;ServiceOrderVOgt; createOrder(Valid RequestBody ServiceOrderCreateDTO dto) { ServiceOrderVO orderVO orderService.createOrder(dto); return Result.success(预约成功, orderVO); } /** 查询用户订单列表 */ GetMapping(/list) PreAuthorize(hasRole(USER)) public Resultlt;PageResultlt;ServiceOrderVOgt;gt; listOrders( RequestParam(defaultValue 1) Integer page, RequestParam(defaultValue 10) Integer size, RequestParam(required false) OrderStatus status) { Pageable pageable PageRequest.of(page - 1, size, Sort.by(createTime).descending()); PageResultlt;ServiceOrderVOgt; pageResult orderService.listUserOrders(pageable, status); return Result.success(pageResult); } /** 取消订单 */ PostMapping(/{orderId}/cancel) PreAuthorize(hasRole(USER)) public Resultlt;Voidgt; cancelOrder(PathVariable Long orderId) { orderService.cancelOrder(orderId); return Result.success(订单取消成功); } /** 支付订单 */ PostMapping(/{orderId}/pay) PreAuthorize(hasRole(USER)) public Resultlt;Voidgt; payOrder(PathVariable Long orderId) { orderService.payOrder(orderId); return Result.success(支付成功); } } // 统一返回结果封装 Data NoArgsConstructor AllArgsConstructor public class ResultT { private Integer code; // 状态码 private String message; // 消息 private T data; // 数据 private Long timestamp; // 时间戳 public static lt;Tgt; Resultlt;Tgt; success(T data) { return new Resultlt;gt;(200, success, data, System.currentTimeMillis()); } public static lt;Tgt; Resultlt;Tgt; success(String message, T data) { return new Resultlt;gt;(200, message, data, System.currentTimeMillis()); } public static Resultlt;Voidgt; error(Integer code, String message) { return new Resultlt;gt;(code, message, null, System.currentTimeMillis()); } }4.5 关键配置示例# application.yml 主配置文件 spring: application: name: pet-platform 数据源配置 datasource: url: jdbc:mysql://localhost:3306/pet_platform?useUnicodetruecharacterEncodingutf8useSSLfalseserverTimezoneAsia/Shanghai username: root password: 123456 driver-class-name: com.mysql.cj.jdbc.Driver hikari: maximum-pool-size: 20 minimum-idle: 5 connection-timeout: 30000 JPA配置 jpa: hibernate: ddl-auto: update show-sql: true properties: hibernate: format_sql: true dialect: org.hibernate.dialect.MySQL8Dialect Redis配置 redis: host: localhost port: 6379 password: database: 0 timeout: 5000ms lettuce: pool: max-active: 20 max-idle: 10 min-idle: 5 RabbitMQ配置 rabbitmq: host: localhost port: 5672 username: guest password: guest virtual-host: / 文件上传配置 servlet: multipart: max-file-size: 10MB max-request-size: 20MB 自定义配置 pet: platform: # 订单相关配置 order: auto-cancel-minutes: 30 # 未支付订单自动取消时间分钟 refund-deadline-days: 7 # 退款申请截止天数 # 文件存储配置 file: upload-path: /data/pet-platform/uploads access-url: http://localhost:8080/uploads 短信配置 sms: enabled: false provider: aliyun sign-name: 宠物平台 template-code: SMS_123456789 日志配置 logging: level: com.petplatform: DEBUG org.springframework.web: INFO file: name: logs/pet-platform.log pattern: console: %d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg%n5. 关键技术实现要点5.1 分布式锁防止超卖// 使用Redis实现分布式锁 Service RequiredArgsConstructor public class InventoryService { private final RedisTemplatelt;String, Stringgt; redisTemplate; private final ProductRepository productRepository; /** 扣减库存使用分布式锁 */ public boolean deductStock(Long productId, Integer quantity) { String lockKey lock:product: productId; String requestId UUID.randomUUID().toString(); try { // 尝试获取分布式锁 Boolean locked redisTemplate.opsForValue().setIfAbsent( lockKey, requestId, 10, TimeUnit.SECONDS ); if (Boolean.TRUE.equals(locked)) { try { // 查询商品库存 Product product productRepository.findById(productId) .orElseThrow(() -gt; new BusinessException(商品不存在)); if (product.getStock() amp;amp;lt; quantity) { return false; // 库存不足 }lt;/codegt;lt;/pregt;/code/pre
