简介这是一套基于SpringBoot开发的完整旅游系统源码面向计算机、电子信息工程等专业学生适用于毕业设计、课程设计及期末大作业等实践场景帮助学习者掌握B/S架构下Java全栈开发的核心流程与工程规范。资源包共420个文件涵盖91个Java后端逻辑文件、40个Vue前端组件、21个JS交互脚本、38个JPG/PNG图片资源、12个MyBatis映射XML及2个SpringBoot配置yml文件辅以bat启动脚本、SQL建表语句和基础样式资源结构清晰、模块完整开箱即用。压缩包大小为13.54MB采用标准Maven多模块组织兼容JDK1.8、MySQL 5.7与Tomcat 8.0/9.0支持IDEA/Eclipse开发环境及主流浏览器运行。目前已有195人学习下载所有代码均经实测可正常编译部署配套包含用户管理、景点浏览、订单处理等核心业务功能是理解SpringBootMyBatisVue前后端分离开发模式的优质实践样本。1. 用 Java 写旅游系统不是堆功能而是理清“行程-订单-资源”三股绳很多人拿到“旅游系统代码 Java”这个需求第一反应是翻 GitHub 找个带后台管理、前端页面、MySQL 表结构的完整项目 ZIP 包解压、改数据库连接、启动——结果卡在登录页 404或者搜索线路返回空列表再查日志发现NoClassDefFoundError: com/alibaba/fastjson/JSONObject才意识到这根本不是“能跑就行”的玩具工程。真实业务中的 Java 旅游系统核心不在界面多炫而在于稳住三根主干行程Product如何定义多天多段的动态组合含交通酒店景点导游、订单Order如何应对高并发下的库存扣减与状态机流转预订中→已支付→已出票→已取消、资源Resource如何隔离不同供应商的酒店房型、航班座位、景区门票余量且支持按天粒度实时同步。它面向的是旅行社运营人员、B2B 分销商、以及需要嵌入自有 App 的第三方平台对事务一致性、查询响应如“上海出发下周可订的三亚五日游”、退改规则引擎的要求远高于普通电商。本文不讲 Spring Boot 脚手架生成而是从领域建模开始用最简但可落地的 Java 代码把这三股绳拧紧。2. 用 JPA Hibernate 建模行程与资源为什么不用 MyBatis 手写 SQL2.1 行程TourProduct必须支持“组合式产品”而非单一线路旅游产品天然具有复合性一条“云南六日游”包含 5 晚酒店、3 个机场接送、6 个景点门票、1 名全程导游。若强行用单张tour_product表存储所有字段会导致字段爆炸、扩展困难新增“含保险”字段需全表 ALTER。正确做法是采用JPA 继承映射 关联聚合// 根实体所有旅游产品共性 Entity Inheritance(strategy InheritanceType.JOINED) public abstract class TourProduct { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String name; // 如“丽江-香格里拉深度摄影团” private String code; // 唯一产品编码如 YN-LJ-SH-202408 private BigDecimal basePrice; // 基础价格不含儿童价、单房差 private LocalDate validFrom; // 销售有效期起 private LocalDate validTo; // 销售有效期止 // ... 其他公共字段 } // 具体子类跟团游GroupTour Entity PrimaryKeyJoinColumn(name product_id) public class GroupTour extends TourProduct { private Integer maxGroupSize; // 成团人数上限 private String departureCity; // 出发城市 private String returnCity; // 返回城市 OneToMany(mappedBy groupTour, cascade CascadeType.ALL, orphanRemoval true) private ListTourDay days new ArrayList(); // 多天行程明细 } // 行程天数明细解耦“时间线”与“资源占用” Entity public class TourDay { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; ManyToOne(fetch FetchType.LAZY) JoinColumn(name group_tour_id) private GroupTour groupTour; private Integer dayNumber; // 第几天如 1,2,3... Column(columnDefinition TEXT) // 存储富文本行程描述 private String description; // 关键关联当天占用的具体资源实例 OneToMany(cascade CascadeType.ALL, orphanRemoval true) private ListDayResource resources new ArrayList(); }提示Inheritance(strategy InheritanceType.JOINED)是关键。它让TourProduct、GroupTour、SelfDriveTour自由行等子类各自拥有独立表避免单表字段冗余。TourDay与DayResource的一对多将“行程逻辑”和“资源物理占用”彻底分离——同一份行程模板可绑定不同日期、不同供应商的酒店房型。2.2 资源Resource必须按“供应商类型唯一标识”三维建模酒店房间、航班座位、景区门票表面都是“可预订单位”但其生命周期、库存策略、定价模型完全不同。若用一张resource表加type字段区分很快会陷入CASE WHEN泛滥的 SQL 泥潭。JPA 的DiscriminatorColumn是更优雅的解法Entity Inheritance(strategy InheritanceType.SINGLE_TABLE) DiscriminatorColumn(name resource_type, discriminatorType DiscriminatorType.STRING) public abstract class Resource { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; Column(unique true, nullable false) private String externalId; // 供应商系统中的唯一ID如酒店HOTEL-12345-RM-DELUXE private String name; // 如“ deluxe 房间” private String supplierCode; // 供应商编码如 CTRIP, QUNAR, 自有库存 Column(name stock_quantity) private Integer stock; // 当前可用库存 // 库存变更需事务安全此处仅声明实现见 3.2 节 public abstract void decreaseStock(int amount); } // 酒店房型资源 Entity DiscriminatorValue(HOTEL_ROOM) public class HotelRoomResource extends Resource { private String hotelName; private String roomType; // 标准间、豪华间 private String bedType; // 大床、双床 Override public void decreaseStock(int amount) { if (this.stock amount) { throw new InsufficientStockException(Hotel room externalId stock insufficient); } this.stock - amount; } } // 景区门票资源 Entity DiscriminatorValue(SCENIC_TICKET) public class ScenicTicketResource extends Resource { private String scenicName; // 景区名称 private String ticketType; // 门票类型成人票、学生票、夜场票 private LocalDate validDate; // 有效日期单日票 Override public void decreaseStock(int amount) { // 景区票常需校验日期有效性 if (LocalDate.now().isAfter(validDate)) { throw new InvalidDateException(Ticket for scenicName expired on validDate); } if (this.stock amount) { throw new InsufficientStockException(Scenic ticket externalId stock insufficient); } this.stock - amount; } }2.2.1 为什么选 SINGLE_TABLE 而非 JOINED策略优点缺点本场景适用性JOINED表结构清晰无空字段JOIN 查询性能差尤其资源类型多时❌ 查询“某天所有可用资源”需 5 表 JOINSINGLE_TABLE单表查询快resource_type索引高效表字段多部分字段为空✅ 旅游系统高频操作是“按日期类型查资源”单表 WHERE resource_type HOTEL_ROOM AND valid_date ?极快TABLE_PER_CLASS各子类表完全独立HQL 复杂无法SELECT * FROM Resource❌ 无法统一管理库存扣减逻辑注意externalId必须全局唯一且带供应商前缀如CTRIP-HOTEL-789-RM-STD这是对接多个供应商 API 的基石。stock字段直接存整数避免用BigDecimal引入精度陷阱——库存只能是整数。3. 订单状态机与库存扣减用数据库行锁 乐观锁防超卖3.1 订单Order状态流转必须拒绝“中间态”旅游订单状态不是简单的“未支付→已支付→完成”而是存在强业务约束的有限状态机FSMCREATED→PAID支付成功PAID→CONFIRMED确认资源锁定如酒店预授权CONFIRMED→DEPARTED游客出发PAID→CANCELLED用户主动取消需触发资源释放CONFIRMED→CANCELLED成团失败取消需全额退款任何跳过CONFIRMED直接到DEPARTED的操作都应被拒绝。用枚举 状态迁移校验实现public enum OrderStatus { CREATED, PAID, CONFIRMED, DEPARTED, CANCELLED, REFUNDED } Entity public class Order { Id private String orderNo; // 业务主键如 ORD-20240801-0001 Enumerated(EnumType.STRING) private OrderStatus status OrderStatus.CREATED; Column(name status_updated_at) private LocalDateTime statusUpdatedAt; // 关联行程 ManyToOne(fetch FetchType.LAZY) JoinColumn(name product_id) private TourProduct product; // 关联的资源占用明细关键 OneToMany(mappedBy order, cascade CascadeType.ALL, orphanRemoval true) private ListOrderResource orderResources new ArrayList(); // 状态变更方法强制校验迁移合法性 public void transitionTo(OrderStatus targetStatus) { if (!isValidTransition(this.status, targetStatus)) { throw new IllegalStateException( String.format(Invalid status transition: %s - %s, this.status, targetStatus) ); } this.status targetStatus; this.statusUpdatedAt LocalDateTime.now(); } private boolean isValidTransition(OrderStatus from, OrderStatus to) { return switch (from) { case CREATED - to OrderStatus.PAID || to OrderStatus.CANCELLED; case PAID - to OrderStatus.CONFIRMED || to OrderStatus.CANCELLED; case CONFIRMED - to OrderStatus.DEPARTED || to OrderStatus.CANCELLED; case DEPARTED, CANCELLED, REFUNDED - false; // 终态不可变 }; } }3.2 库存扣减必须原子化行锁 乐观锁双保险高并发下两个用户同时抢最后一间房经典超卖问题。仅靠UPDATE resource SET stock stock - 1 WHERE id ? AND stock 1不够——若库存为 1两个请求同时读到stock1都执行成功导致stock-1。必须结合数据库行锁与应用层乐观锁Service Transactional public class OrderService { Autowired private ResourceRepository resourceRepository; Autowired private OrderRepository orderRepository; /** * 创建订单并扣减资源库存 * param orderRequest 订单请求含行程ID、出行日期、人数 */ public Order createOrder(OrderRequest orderRequest) { // 1. 根据行程ID和出行日期查询当天所需的所有资源酒店、门票等 ListResource requiredResources findRequiredResources( orderRequest.getProductId(), orderRequest.getTravelDate() ); // 2. 对每个资源执行带版本号的扣减乐观锁 for (Resource resource : requiredResources) { // 使用 JPA 的 Version 字段实现乐观锁 // 先查一次获取当前版本号 Resource lockedResource resourceRepository.findById(resource.getId()) .orElseThrow(() - new ResourceNotFoundException(Resource not found: resource.getId())); // 尝试扣减SQL 中加入 version 条件 int updated resourceRepository.decreaseStockByIdAndVersion( lockedResource.getId(), orderRequest.getPeopleCount(), lockedResource.getVersion() ); if (updated 0) { // 扣减失败版本号不匹配被其他事务修改或库存不足 throw new ConcurrentUpdateException( Resource resource.getExternalId() stock update failed, retry ); } } // 3. 所有资源扣减成功创建订单 Order order buildOrder(orderRequest, requiredResources); return orderRepository.save(order); } } // ResourceRepository 中的自定义更新方法 Repository public interface ResourceRepository extends JpaRepositoryResource, Long { /** * 原子化扣减库存UPDATE ... WHERE id ? AND version ? AND stock ? * return 影响行数0 表示失败 */ Modifying Query(UPDATE Resource r SET r.stock r.stock - :amount, r.version r.version 1 WHERE r.id :id AND r.version :version AND r.stock :amount) int decreaseStockByIdAndVersion( Param(id) Long id, Param(amount) int amount, Param(version) int version ); }提示Version字段是乐观锁核心。每次更新stock必须同时version version 1且WHERE条件中校验version。若并发请求读到相同version第二个UPDATE因version不匹配而返回 0 行更新业务层捕获后可重试或提示“库存紧张”。比纯数据库行锁SELECT ... FOR UPDATE更轻量适合旅游系统中资源种类多、单次扣减量小的场景。4. 查询优化用 Elasticsearch 替代 MySQL 全文检索行程4.1 MySQL LIKE 搜索“云南”为何慢执行计划暴露真相当用户在首页搜索框输入“云南”后端执行SELECT * FROM tour_product WHERE name LIKE %云南% OR description LIKE %云南%即使name和description加了索引MySQL 仍会进行全表扫描——因为LIKE %云南%无法使用 BTree 索引的最左前缀原则。Explain 结果显示type: ALLrows: 125000响应时间 2s。旅游系统要求“秒级响应”必须换方案。4.2 用 Elasticsearch 实现多字段、多条件、高亮的行程搜索将行程数据同步到 ES建立专用索引tour_productsPUT /tour_products { mappings: { properties: { id: { type: long }, name: { type: text, analyzer: ik_max_word, // 中文分词 search_analyzer: ik_smart }, code: { type: keyword }, // 精确匹配用 basePrice: { type: double }, validFrom: { type: date }, validTo: { type: date }, tags: { type: keyword }, // 如 [摄影, 亲子, 徒步] itinerary: { type: text, analyzer: ik_max_word } } } }Java 中使用RestHighLevelClient构建搜索 DSLService public class TourSearchService { Autowired private RestHighLevelClient esClient; /** * 搜索行程支持关键词、价格区间、日期范围、标签过滤 */ public SearchResponse searchTours(String keyword, BigDecimal minPrice, BigDecimal maxPrice, LocalDate startDate, LocalDate endDate, ListString tags) { SearchSourceBuilder sourceBuilder new SearchSourceBuilder(); // 1. 多字段全文检索name itinerary MultiMatchQueryBuilder multiMatchQuery QueryBuilders.multiMatchQuery(keyword, name^3, itinerary^1) .type(MultiMatchQueryBuilder.Type.BEST_FIELDS); // 2. 组合过滤条件 BoolQueryBuilder boolQuery QueryBuilders.boolQuery() .must(multiMatchQuery); if (minPrice ! null maxPrice ! null) { boolQuery.filter(QueryBuilders.rangeQuery(basePrice).gte(minPrice).lte(maxPrice)); } if (startDate ! null endDate ! null) { boolQuery.filter(QueryBuilders.rangeQuery(validFrom).lte(endDate)); boolQuery.filter(QueryBuilders.rangeQuery(validTo).gte(startDate)); } if (!CollectionUtils.isEmpty(tags)) { boolQuery.filter(QueryBuilders.termsQuery(tags, tags)); } sourceBuilder.query(boolQuery); // 3. 高亮显示关键词 HighlightBuilder highlightBuilder new HighlightBuilder(); highlightBuilder.field(name).preTags(em).postTags(/em); highlightBuilder.field(itinerary).preTags(em).postTags(/em); sourceBuilder.highlighter(highlightBuilder); SearchRequest searchRequest new SearchRequest(tour_products); searchRequest.source(sourceBuilder); try { return esClient.search(searchRequest, RequestOptions.DEFAULT); } catch (IOException e) { throw new SearchException(Elasticsearch search failed, e); } } }4.2.1 同步策略何时将 MySQL 数据推送到 ES方案实现方式延迟适用场景定时任务Quartz 每 5 分钟SELECT * FROM tour_product WHERE updated_at last_sync_time5 分钟对实时性要求不高的后台管理数据库日志Binlog使用 Debezium 监听 MySQL binlog实时捕获 INSERT/UPDATE/DELETE 1 秒✅ 推荐旅游产品上架、调价需秒级生效应用层双写Service 中先save()到 MySQL再esClient.index()到 ES低但代码侵入性强❌ 易因 ES 写入失败导致数据不一致注意ES 索引中code字段设为keyword类型确保GET /tour_products/_search?qcode:YN-LJ-SH-202408能精确匹配用于订单系统根据产品编码快速查详情避免模糊搜索。5. 生产就绪技巧用 Resilience4j 实现资源服务降级与熔断5.1 为什么旅游系统必须处理外部依赖失败旅游系统重度依赖第三方服务酒店库存查询携程 API、航班时刻航司接口、景区预约文旅局平台。这些服务不可控——网络抖动、对方限流、自身超时都会导致订单创建卡死。若不做防护一个接口超时会拖垮整个 Tomcat 线程池引发雪崩。5.2 用 Resilience4j 的 CircuitBreaker TimeLimiter 实现优雅降级引入 Maven 依赖dependency groupIdio.github.resilience4j/groupId artifactIdresilience4j-spring-boot2/artifactId version1.7.0/version /dependency配置application.ymlresilience4j.circuitbreaker: instances: ctripHotel: registerHealthIndicator: true failureRateThreshold: 50 # 错误率 50% 触发熔断 waitDurationInOpenState: 60s # 熔断后等待60秒尝试半开 slidingWindowSize: 10 # 统计最近10次调用 minimumNumberOfCalls: 5 # 至少5次调用才统计 resilience4j.timelimiter: instances: ctripHotel: timeoutDuration: 2s # 调用携程API超时2秒 cancelRunningFuture: true在调用外部服务的方法上添加注解Service public class ExternalResourceService { CircuitBreaker(name ctripHotel, fallbackMethod getHotelFallback) TimeLimiter(name ctripHotel) public CompletableFutureHotelAvailability queryCtripHotel(String hotelId, LocalDate checkIn) { // 调用携程HTTP API return CompletableFuture.supplyAsync(() - { // 模拟HTTP调用 return ctripApiClient.checkAvailability(hotelId, checkIn); }); } // 降级方法返回缓存数据或默认值 private CompletableFutureHotelAvailability getHotelFallback(String hotelId, LocalDate checkIn, Throwable throwable) { log.warn(Ctrip API call failed, using fallback for hotel {} on {}, hotelId, checkIn, throwable); // 返回本地缓存的酒店信息可能过期但保证可用 return CompletableFuture.completedFuture( cacheService.getCachedHotel(hotelId) ); } }5.2.1 熔断器状态监控通过 Actuator 暴露健康端点启用 Actuator 后访问/actuator/health可看到{ status: UP, components: { ctripHotel: { status: UP, details: { failureRate: 30.0%, state: CLOSED, slowCallRate: 5.0% } } } }提示fallbackMethod必须是同一类中的public方法且参数列表需兼容原方法可多一个Throwable参数。降级逻辑要轻量——绝不允许在降级方法中再调用另一个可能失败的外部服务否则降级失效。缓存数据应设置合理过期时间如 30 分钟避免长期返回陈旧信息。本文还有配套的精品资源点击获取
Java旅游系统核心设计：行程-订单-资源三域建模
简介这是一套基于SpringBoot开发的完整旅游系统源码面向计算机、电子信息工程等专业学生适用于毕业设计、课程设计及期末大作业等实践场景帮助学习者掌握B/S架构下Java全栈开发的核心流程与工程规范。资源包共420个文件涵盖91个Java后端逻辑文件、40个Vue前端组件、21个JS交互脚本、38个JPG/PNG图片资源、12个MyBatis映射XML及2个SpringBoot配置yml文件辅以bat启动脚本、SQL建表语句和基础样式资源结构清晰、模块完整开箱即用。压缩包大小为13.54MB采用标准Maven多模块组织兼容JDK1.8、MySQL 5.7与Tomcat 8.0/9.0支持IDEA/Eclipse开发环境及主流浏览器运行。目前已有195人学习下载所有代码均经实测可正常编译部署配套包含用户管理、景点浏览、订单处理等核心业务功能是理解SpringBootMyBatisVue前后端分离开发模式的优质实践样本。1. 用 Java 写旅游系统不是堆功能而是理清“行程-订单-资源”三股绳很多人拿到“旅游系统代码 Java”这个需求第一反应是翻 GitHub 找个带后台管理、前端页面、MySQL 表结构的完整项目 ZIP 包解压、改数据库连接、启动——结果卡在登录页 404或者搜索线路返回空列表再查日志发现NoClassDefFoundError: com/alibaba/fastjson/JSONObject才意识到这根本不是“能跑就行”的玩具工程。真实业务中的 Java 旅游系统核心不在界面多炫而在于稳住三根主干行程Product如何定义多天多段的动态组合含交通酒店景点导游、订单Order如何应对高并发下的库存扣减与状态机流转预订中→已支付→已出票→已取消、资源Resource如何隔离不同供应商的酒店房型、航班座位、景区门票余量且支持按天粒度实时同步。它面向的是旅行社运营人员、B2B 分销商、以及需要嵌入自有 App 的第三方平台对事务一致性、查询响应如“上海出发下周可订的三亚五日游”、退改规则引擎的要求远高于普通电商。本文不讲 Spring Boot 脚手架生成而是从领域建模开始用最简但可落地的 Java 代码把这三股绳拧紧。2. 用 JPA Hibernate 建模行程与资源为什么不用 MyBatis 手写 SQL2.1 行程TourProduct必须支持“组合式产品”而非单一线路旅游产品天然具有复合性一条“云南六日游”包含 5 晚酒店、3 个机场接送、6 个景点门票、1 名全程导游。若强行用单张tour_product表存储所有字段会导致字段爆炸、扩展困难新增“含保险”字段需全表 ALTER。正确做法是采用JPA 继承映射 关联聚合// 根实体所有旅游产品共性 Entity Inheritance(strategy InheritanceType.JOINED) public abstract class TourProduct { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; private String name; // 如“丽江-香格里拉深度摄影团” private String code; // 唯一产品编码如 YN-LJ-SH-202408 private BigDecimal basePrice; // 基础价格不含儿童价、单房差 private LocalDate validFrom; // 销售有效期起 private LocalDate validTo; // 销售有效期止 // ... 其他公共字段 } // 具体子类跟团游GroupTour Entity PrimaryKeyJoinColumn(name product_id) public class GroupTour extends TourProduct { private Integer maxGroupSize; // 成团人数上限 private String departureCity; // 出发城市 private String returnCity; // 返回城市 OneToMany(mappedBy groupTour, cascade CascadeType.ALL, orphanRemoval true) private ListTourDay days new ArrayList(); // 多天行程明细 } // 行程天数明细解耦“时间线”与“资源占用” Entity public class TourDay { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; ManyToOne(fetch FetchType.LAZY) JoinColumn(name group_tour_id) private GroupTour groupTour; private Integer dayNumber; // 第几天如 1,2,3... Column(columnDefinition TEXT) // 存储富文本行程描述 private String description; // 关键关联当天占用的具体资源实例 OneToMany(cascade CascadeType.ALL, orphanRemoval true) private ListDayResource resources new ArrayList(); }提示Inheritance(strategy InheritanceType.JOINED)是关键。它让TourProduct、GroupTour、SelfDriveTour自由行等子类各自拥有独立表避免单表字段冗余。TourDay与DayResource的一对多将“行程逻辑”和“资源物理占用”彻底分离——同一份行程模板可绑定不同日期、不同供应商的酒店房型。2.2 资源Resource必须按“供应商类型唯一标识”三维建模酒店房间、航班座位、景区门票表面都是“可预订单位”但其生命周期、库存策略、定价模型完全不同。若用一张resource表加type字段区分很快会陷入CASE WHEN泛滥的 SQL 泥潭。JPA 的DiscriminatorColumn是更优雅的解法Entity Inheritance(strategy InheritanceType.SINGLE_TABLE) DiscriminatorColumn(name resource_type, discriminatorType DiscriminatorType.STRING) public abstract class Resource { Id GeneratedValue(strategy GenerationType.IDENTITY) private Long id; Column(unique true, nullable false) private String externalId; // 供应商系统中的唯一ID如酒店HOTEL-12345-RM-DELUXE private String name; // 如“ deluxe 房间” private String supplierCode; // 供应商编码如 CTRIP, QUNAR, 自有库存 Column(name stock_quantity) private Integer stock; // 当前可用库存 // 库存变更需事务安全此处仅声明实现见 3.2 节 public abstract void decreaseStock(int amount); } // 酒店房型资源 Entity DiscriminatorValue(HOTEL_ROOM) public class HotelRoomResource extends Resource { private String hotelName; private String roomType; // 标准间、豪华间 private String bedType; // 大床、双床 Override public void decreaseStock(int amount) { if (this.stock amount) { throw new InsufficientStockException(Hotel room externalId stock insufficient); } this.stock - amount; } } // 景区门票资源 Entity DiscriminatorValue(SCENIC_TICKET) public class ScenicTicketResource extends Resource { private String scenicName; // 景区名称 private String ticketType; // 门票类型成人票、学生票、夜场票 private LocalDate validDate; // 有效日期单日票 Override public void decreaseStock(int amount) { // 景区票常需校验日期有效性 if (LocalDate.now().isAfter(validDate)) { throw new InvalidDateException(Ticket for scenicName expired on validDate); } if (this.stock amount) { throw new InsufficientStockException(Scenic ticket externalId stock insufficient); } this.stock - amount; } }2.2.1 为什么选 SINGLE_TABLE 而非 JOINED策略优点缺点本场景适用性JOINED表结构清晰无空字段JOIN 查询性能差尤其资源类型多时❌ 查询“某天所有可用资源”需 5 表 JOINSINGLE_TABLE单表查询快resource_type索引高效表字段多部分字段为空✅ 旅游系统高频操作是“按日期类型查资源”单表 WHERE resource_type HOTEL_ROOM AND valid_date ?极快TABLE_PER_CLASS各子类表完全独立HQL 复杂无法SELECT * FROM Resource❌ 无法统一管理库存扣减逻辑注意externalId必须全局唯一且带供应商前缀如CTRIP-HOTEL-789-RM-STD这是对接多个供应商 API 的基石。stock字段直接存整数避免用BigDecimal引入精度陷阱——库存只能是整数。3. 订单状态机与库存扣减用数据库行锁 乐观锁防超卖3.1 订单Order状态流转必须拒绝“中间态”旅游订单状态不是简单的“未支付→已支付→完成”而是存在强业务约束的有限状态机FSMCREATED→PAID支付成功PAID→CONFIRMED确认资源锁定如酒店预授权CONFIRMED→DEPARTED游客出发PAID→CANCELLED用户主动取消需触发资源释放CONFIRMED→CANCELLED成团失败取消需全额退款任何跳过CONFIRMED直接到DEPARTED的操作都应被拒绝。用枚举 状态迁移校验实现public enum OrderStatus { CREATED, PAID, CONFIRMED, DEPARTED, CANCELLED, REFUNDED } Entity public class Order { Id private String orderNo; // 业务主键如 ORD-20240801-0001 Enumerated(EnumType.STRING) private OrderStatus status OrderStatus.CREATED; Column(name status_updated_at) private LocalDateTime statusUpdatedAt; // 关联行程 ManyToOne(fetch FetchType.LAZY) JoinColumn(name product_id) private TourProduct product; // 关联的资源占用明细关键 OneToMany(mappedBy order, cascade CascadeType.ALL, orphanRemoval true) private ListOrderResource orderResources new ArrayList(); // 状态变更方法强制校验迁移合法性 public void transitionTo(OrderStatus targetStatus) { if (!isValidTransition(this.status, targetStatus)) { throw new IllegalStateException( String.format(Invalid status transition: %s - %s, this.status, targetStatus) ); } this.status targetStatus; this.statusUpdatedAt LocalDateTime.now(); } private boolean isValidTransition(OrderStatus from, OrderStatus to) { return switch (from) { case CREATED - to OrderStatus.PAID || to OrderStatus.CANCELLED; case PAID - to OrderStatus.CONFIRMED || to OrderStatus.CANCELLED; case CONFIRMED - to OrderStatus.DEPARTED || to OrderStatus.CANCELLED; case DEPARTED, CANCELLED, REFUNDED - false; // 终态不可变 }; } }3.2 库存扣减必须原子化行锁 乐观锁双保险高并发下两个用户同时抢最后一间房经典超卖问题。仅靠UPDATE resource SET stock stock - 1 WHERE id ? AND stock 1不够——若库存为 1两个请求同时读到stock1都执行成功导致stock-1。必须结合数据库行锁与应用层乐观锁Service Transactional public class OrderService { Autowired private ResourceRepository resourceRepository; Autowired private OrderRepository orderRepository; /** * 创建订单并扣减资源库存 * param orderRequest 订单请求含行程ID、出行日期、人数 */ public Order createOrder(OrderRequest orderRequest) { // 1. 根据行程ID和出行日期查询当天所需的所有资源酒店、门票等 ListResource requiredResources findRequiredResources( orderRequest.getProductId(), orderRequest.getTravelDate() ); // 2. 对每个资源执行带版本号的扣减乐观锁 for (Resource resource : requiredResources) { // 使用 JPA 的 Version 字段实现乐观锁 // 先查一次获取当前版本号 Resource lockedResource resourceRepository.findById(resource.getId()) .orElseThrow(() - new ResourceNotFoundException(Resource not found: resource.getId())); // 尝试扣减SQL 中加入 version 条件 int updated resourceRepository.decreaseStockByIdAndVersion( lockedResource.getId(), orderRequest.getPeopleCount(), lockedResource.getVersion() ); if (updated 0) { // 扣减失败版本号不匹配被其他事务修改或库存不足 throw new ConcurrentUpdateException( Resource resource.getExternalId() stock update failed, retry ); } } // 3. 所有资源扣减成功创建订单 Order order buildOrder(orderRequest, requiredResources); return orderRepository.save(order); } } // ResourceRepository 中的自定义更新方法 Repository public interface ResourceRepository extends JpaRepositoryResource, Long { /** * 原子化扣减库存UPDATE ... WHERE id ? AND version ? AND stock ? * return 影响行数0 表示失败 */ Modifying Query(UPDATE Resource r SET r.stock r.stock - :amount, r.version r.version 1 WHERE r.id :id AND r.version :version AND r.stock :amount) int decreaseStockByIdAndVersion( Param(id) Long id, Param(amount) int amount, Param(version) int version ); }提示Version字段是乐观锁核心。每次更新stock必须同时version version 1且WHERE条件中校验version。若并发请求读到相同version第二个UPDATE因version不匹配而返回 0 行更新业务层捕获后可重试或提示“库存紧张”。比纯数据库行锁SELECT ... FOR UPDATE更轻量适合旅游系统中资源种类多、单次扣减量小的场景。4. 查询优化用 Elasticsearch 替代 MySQL 全文检索行程4.1 MySQL LIKE 搜索“云南”为何慢执行计划暴露真相当用户在首页搜索框输入“云南”后端执行SELECT * FROM tour_product WHERE name LIKE %云南% OR description LIKE %云南%即使name和description加了索引MySQL 仍会进行全表扫描——因为LIKE %云南%无法使用 BTree 索引的最左前缀原则。Explain 结果显示type: ALLrows: 125000响应时间 2s。旅游系统要求“秒级响应”必须换方案。4.2 用 Elasticsearch 实现多字段、多条件、高亮的行程搜索将行程数据同步到 ES建立专用索引tour_productsPUT /tour_products { mappings: { properties: { id: { type: long }, name: { type: text, analyzer: ik_max_word, // 中文分词 search_analyzer: ik_smart }, code: { type: keyword }, // 精确匹配用 basePrice: { type: double }, validFrom: { type: date }, validTo: { type: date }, tags: { type: keyword }, // 如 [摄影, 亲子, 徒步] itinerary: { type: text, analyzer: ik_max_word } } } }Java 中使用RestHighLevelClient构建搜索 DSLService public class TourSearchService { Autowired private RestHighLevelClient esClient; /** * 搜索行程支持关键词、价格区间、日期范围、标签过滤 */ public SearchResponse searchTours(String keyword, BigDecimal minPrice, BigDecimal maxPrice, LocalDate startDate, LocalDate endDate, ListString tags) { SearchSourceBuilder sourceBuilder new SearchSourceBuilder(); // 1. 多字段全文检索name itinerary MultiMatchQueryBuilder multiMatchQuery QueryBuilders.multiMatchQuery(keyword, name^3, itinerary^1) .type(MultiMatchQueryBuilder.Type.BEST_FIELDS); // 2. 组合过滤条件 BoolQueryBuilder boolQuery QueryBuilders.boolQuery() .must(multiMatchQuery); if (minPrice ! null maxPrice ! null) { boolQuery.filter(QueryBuilders.rangeQuery(basePrice).gte(minPrice).lte(maxPrice)); } if (startDate ! null endDate ! null) { boolQuery.filter(QueryBuilders.rangeQuery(validFrom).lte(endDate)); boolQuery.filter(QueryBuilders.rangeQuery(validTo).gte(startDate)); } if (!CollectionUtils.isEmpty(tags)) { boolQuery.filter(QueryBuilders.termsQuery(tags, tags)); } sourceBuilder.query(boolQuery); // 3. 高亮显示关键词 HighlightBuilder highlightBuilder new HighlightBuilder(); highlightBuilder.field(name).preTags(em).postTags(/em); highlightBuilder.field(itinerary).preTags(em).postTags(/em); sourceBuilder.highlighter(highlightBuilder); SearchRequest searchRequest new SearchRequest(tour_products); searchRequest.source(sourceBuilder); try { return esClient.search(searchRequest, RequestOptions.DEFAULT); } catch (IOException e) { throw new SearchException(Elasticsearch search failed, e); } } }4.2.1 同步策略何时将 MySQL 数据推送到 ES方案实现方式延迟适用场景定时任务Quartz 每 5 分钟SELECT * FROM tour_product WHERE updated_at last_sync_time5 分钟对实时性要求不高的后台管理数据库日志Binlog使用 Debezium 监听 MySQL binlog实时捕获 INSERT/UPDATE/DELETE 1 秒✅ 推荐旅游产品上架、调价需秒级生效应用层双写Service 中先save()到 MySQL再esClient.index()到 ES低但代码侵入性强❌ 易因 ES 写入失败导致数据不一致注意ES 索引中code字段设为keyword类型确保GET /tour_products/_search?qcode:YN-LJ-SH-202408能精确匹配用于订单系统根据产品编码快速查详情避免模糊搜索。5. 生产就绪技巧用 Resilience4j 实现资源服务降级与熔断5.1 为什么旅游系统必须处理外部依赖失败旅游系统重度依赖第三方服务酒店库存查询携程 API、航班时刻航司接口、景区预约文旅局平台。这些服务不可控——网络抖动、对方限流、自身超时都会导致订单创建卡死。若不做防护一个接口超时会拖垮整个 Tomcat 线程池引发雪崩。5.2 用 Resilience4j 的 CircuitBreaker TimeLimiter 实现优雅降级引入 Maven 依赖dependency groupIdio.github.resilience4j/groupId artifactIdresilience4j-spring-boot2/artifactId version1.7.0/version /dependency配置application.ymlresilience4j.circuitbreaker: instances: ctripHotel: registerHealthIndicator: true failureRateThreshold: 50 # 错误率 50% 触发熔断 waitDurationInOpenState: 60s # 熔断后等待60秒尝试半开 slidingWindowSize: 10 # 统计最近10次调用 minimumNumberOfCalls: 5 # 至少5次调用才统计 resilience4j.timelimiter: instances: ctripHotel: timeoutDuration: 2s # 调用携程API超时2秒 cancelRunningFuture: true在调用外部服务的方法上添加注解Service public class ExternalResourceService { CircuitBreaker(name ctripHotel, fallbackMethod getHotelFallback) TimeLimiter(name ctripHotel) public CompletableFutureHotelAvailability queryCtripHotel(String hotelId, LocalDate checkIn) { // 调用携程HTTP API return CompletableFuture.supplyAsync(() - { // 模拟HTTP调用 return ctripApiClient.checkAvailability(hotelId, checkIn); }); } // 降级方法返回缓存数据或默认值 private CompletableFutureHotelAvailability getHotelFallback(String hotelId, LocalDate checkIn, Throwable throwable) { log.warn(Ctrip API call failed, using fallback for hotel {} on {}, hotelId, checkIn, throwable); // 返回本地缓存的酒店信息可能过期但保证可用 return CompletableFuture.completedFuture( cacheService.getCachedHotel(hotelId) ); } }5.2.1 熔断器状态监控通过 Actuator 暴露健康端点启用 Actuator 后访问/actuator/health可看到{ status: UP, components: { ctripHotel: { status: UP, details: { failureRate: 30.0%, state: CLOSED, slowCallRate: 5.0% } } } }提示fallbackMethod必须是同一类中的public方法且参数列表需兼容原方法可多一个Throwable参数。降级逻辑要轻量——绝不允许在降级方法中再调用另一个可能失败的外部服务否则降级失效。缓存数据应设置合理过期时间如 30 分钟避免长期返回陈旧信息。本文还有配套的精品资源点击获取
