1. 项目背景与核心价值这个基于SpringBoot和Hadoop的宁波旅游推荐系统本质上解决的是旅游信息过载问题。在宁波这样的旅游城市游客常常面临去哪玩、吃什么、买什么三大难题。传统旅游平台要么推荐过于泛泛要么商业气息太重缺乏可信度。我们设计的这套系统通过Hadoop处理海量用户行为数据和景点数据结合SpringBoot构建灵活的业务系统实现了三个创新点基于用户实时位置的智能周边推荐旅游商品与景点服务的精准匹配多维度评分系统的可信度保障2. 技术架构解析2.1 整体架构设计系统采用经典的三层架构但在数据处理层做了特殊优化[客户端] - [SpringBoot应用层] - [Hadoop数据处理层] - [MySQL/Redis存储层]特别之处在于应用层采用SpringBoot 2.7 MyBatis Plus数据处理层使用Hadoop 3.3生态系统存储层MySQL 8.0做业务数据存储Redis 6.2缓存热点推荐结果2.2 Hadoop组件选型针对旅游推荐场景我们精心选择了以下Hadoop组件组合组件版本用途选型理由HDFS3.3.4原始数据存储高可靠性存储用户行为日志MapReduce3.3.4离线计算处理历史数据生成用户画像Hive3.1.3数据仓库结构化查询景点关联数据Spark3.2.1实时计算处理用户实时请求特别注意Spark虽然不属于Hadoop原生组件但在实际应用中我们发现它对实时推荐场景的性能提升显著因此纳入技术栈。3. 核心功能实现3.1 智能推荐算法实现推荐系统核心算法采用混合推荐策略// 伪代码示例 public ListScenicSpot recommend(User user, Location location) { // 基于内容的推荐 ListScenicSpot contentBased contentBasedFiltering(user); // 协同过滤推荐 ListScenicSpot cfBased collaborativeFiltering(user); // 地理位置过滤 ListScenicSpot locationBased locationFilter(location); // 加权融合 return hybridRecommendation( contentBased, cfBased, locationBased ); }算法调优过程中发现几个关键点宁波地区旅游数据具有明显的时空特性节假日vs工作日用户停留时长是比评分更可靠的兴趣指标餐饮推荐需要结合时段早餐/午餐/晚餐3.2 周边商城集成方案商城模块采用微服务架构设计[推荐服务] - [商品服务] - [订单服务] - [支付服务]关键集成点商品服务暴露RESTful API使用Feign实现服务调用通过Redis缓存商品详情RocketMQ处理订单消息4. 性能优化实践4.1 Hadoop集群调优针对旅游数据的特性我们做了以下优化HDFS配置优化块大小调整为256MB默认128MB副本数设置为2平衡可靠性和存储成本MapReduce参数调整property namemapreduce.task.io.sort.mb/name value512/value /property property namemapreduce.reduce.shuffle.input.buffer.percent/name value0.7/value /propertySpark调优重点executor内存分配4-8GB并行度设置为集群core数的2-3倍启用动态资源分配4.2 SpringBoot性能技巧JVM参数优化-Xms2g -Xmx2g -XX:UseG1GC -XX:MaxGCPauseMillis200接口响应优化启用HTTP/2配置合理的连接池使用Cacheable注解缓存热点数据数据库访问优化配置多数据源使用HikariCP连接池优化MyBatis批量操作5. 典型问题排查5.1 推荐结果不稳定问题现象同一用户相同位置推荐列表差异大排查过程检查实时数据流是否正常验证用户画像一致性分析推荐算法权重配置最终发现是Spark缓存策略问题解决方案val df spark.read... .cache() // 添加缓存 .checkpoint() // 设置检查点5.2 高并发下单失败现象旅游旺季下单接口超时根本原因分析商品服务没有限流数据库连接池耗尽分布式锁实现不当解决方案// 使用Redisson实现分布式锁 RLock lock redisson.getLock(product_ productId); try { lock.lock(5, TimeUnit.SECONDS); // 减库存操作 } finally { lock.unlock(); }6. 部署实践6.1 生产环境部署方案我们采用混合部署架构Hadoop集群3台物理机32核/128GB/10TB*12SpringBoot应用Kubernetes集群10个PodMySQL主从架构1主2从Redis哨兵模式3节点6.2 监控体系搭建Hadoop监控使用Ambari管理集群配置Grafana展示关键指标设置NameNode/DataNode告警SpringBoot监控dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-actuator/artifactId /dependency配置Prometheus采集指标业务监控推荐点击率转化漏斗分析异常订单监控7. 项目演进方向在实际运营中我们发现几个有价值的优化方向引入图计算Neo4j处理景点关联关系使用Flink替代部分Spark实时计算场景增加NLP处理用户评论情感分析开发小程序端提升用户体验特别在数据处理方面我们计划将Hadoop集群升级到3.3.6版本利用ECErasure Coding功能将存储成本降低40%。同时测试中的Spark AQEAdaptive Query Execution特性在复杂推荐查询场景下表现出显著的性能提升。