Java打造：羽毛球馆线上预约系统源码-洪萨配资

以下是一套基于Java的羽毛球馆线上预约系统完整源码方案，涵盖技术架构、核心功能、数据库设计、关键代码实现及部署优化，支持高并发、实时交互与多端适配：

一、技术架构

1.核心框架

Spring Boot 3.0：快速构建微服务，集成安全、缓存、事务等模块
Spring Cloud Alibaba 2022：实现服务注册（Nacos）、熔断降级（Sentinel）、分布式事务（Seata）
Spring Security OAuth2：支持微信/手机号双登录，JWT令牌管理用户会话

2.数据库设计

MySQL 8.0：按城市分库，ShardingSphere水平分表（订单表按月分表）
Redis 7.0：缓存热门场馆实时库存（venue:stock:{venueId}）、用户会话（user:token:{token}）
MongoDB 6.0：存储用户运动偏好、场馆评价等非结构化数据

3.消息队列

Kafka 3.6：异步处理预约通知、支付回调，峰值QPS 5000+
RocketMQ 5.1：实现最终一致性事务（如预约成功但支付失败场景）

4.物联网集成

MQTT协议：通过EMQX Broker与智能门禁、灯光控制器通信
Netty：自定义TCP协议处理老旧设备（如仅支持串口通信的计费器）

5.前端适配

UniApp：编译微信小程序、H5、APP三端
Vue3 + Element Plus：管理后台（场馆运营端）

二、核心功能实现

1.实时库存管理

java

// 场馆库存服务（Redis原子操作保证并发安全） @Service public class VenueStockService { @Autowired private RedisTemplate<String, Integer> redisTemplate; // 扣减库存（返回剩余数量） public int decreaseStock(Long venueId, LocalDateTime startTime, int duration) { String key = "venue:stock:" + venueId + ":" + startTime.toEpochSecond(ZoneOffset.UTC); return redisTemplate.opsForValue().decrement(key, duration).intValue(); } // 初始化每日库存（每晚3点执行） @Scheduled(cron = "0 0 3 * * ?") public void initDailyStock() { List<Venue> venues = venueRepository.findAll(); venues.forEach(venue -> { for (int hour = 8; hour <= 22; hour++) { // 营业时间8:00-22:00 LocalDateTime startTime = LocalDateTime.now().withHour(hour).withMinute(0); String key = "venue:stock:" + venue.getId() + ":" + startTime.toEpochSecond(ZoneOffset.UTC); redisTemplate.opsForValue().set(key, venue.getTotalCourts() * 2); // 默认每时段2小时容量 } }); } }

2.分布式预约锁

java

// 基于Redisson的分布式锁实现 @Service public class BookingLockService { @Autowired private RedissonClient redissonClient; public boolean tryLock(Long venueId, Long courtId, LocalDateTime startTime) { String lockKey = "booking:lock:" + venueId + ":" + courtId + ":" + startTime.toEpochSecond(ZoneOffset.UTC); RLock lock = redissonClient.getLock(lockKey); try { return lock.tryLock(10, 30, TimeUnit.SECONDS); // 等待10秒，锁持有30秒 } catch (InterruptedException e) { Thread.currentThread().interrupt(); return false; } } }

3.支付与通知集成

java

// 微信支付回调处理 @RestController @RequestMapping("/api/payment") public class PaymentController { @Autowired private OrderService orderService; @Autowired private WebSocketService webSocketService; @PostMapping("/wechat/callback") public String handleWechatCallback(@RequestBody String xmlData) { // 解析微信支付回调 Map<String, String> result = XmlUtil.parse(xmlData); String orderId = result.get("out_trade_no"); String status = result.get("result_code"); // 更新订单状态 if ("SUCCESS".equals(status)) { orderService.completeOrder(orderId); // 通过WebSocket推送支付成功通知 Order order = orderService.getById(orderId); webSocketService.sendPaymentResult(order.getUserId(), "支付成功"); } return "<xml><return_code><![CDATA[SUCCESS]]></return_code></xml>"; } }

4.设备联动控制

java

// 发送场次开始指令（MQTT） @Service public class DeviceControlService { @Autowired private MqttClient mqttClient; public void startCourtSession(Long courtId, LocalDateTime startTime) { JSONObject command = new JSONObject(); command.put("action", "start"); command.put("courtId", courtId); command.put("lightLevel", 80); // 灯光亮度80% command.put("acTemp", 26); // 空调温度26℃ String topic = "/device/court/" + courtId + "/command"; mqttClient.publish(topic, new MqttMessage(command.toJSONString().getBytes())); } }

三、数据库表设计

1.场馆表（venue）

sql

CREATE TABLE `venue` ( `id` bigint NOT NULL AUTO_INCREMENT, `name` varchar(100) NOT NULL COMMENT '场馆名称', `address` varchar(255) NOT NULL COMMENT '详细地址', `longitude` decimal(10,6) NOT NULL COMMENT '经度', `latitude` decimal(10,6) NOT NULL COMMENT '纬度', `total_courts` int NOT NULL COMMENT '场地总数', `contact_phone` varchar(20) NOT NULL COMMENT '联系电话', PRIMARY KEY (`id`), KEY `idx_location` (`longitude`,`latitude`) ) ENGINE=InnoDB;

2.预约订单表（booking_order）

sql

CREATE TABLE `booking_order` ( `id` bigint NOT NULL AUTO_INCREMENT, `order_no` varchar(32) NOT NULL COMMENT '订单号', `user_id` bigint NOT NULL COMMENT '用户ID', `venue_id` bigint NOT NULL COMMENT '场馆ID', `court_id` bigint NOT NULL COMMENT '场地ID', `start_time` datetime NOT NULL COMMENT '开始时间', `end_time` datetime NOT NULL COMMENT '结束时间', `status` tinyint NOT NULL COMMENT '状态(0:待支付 1:已支付 2:已完成 3:已取消)', `amount` decimal(10,2) NOT NULL COMMENT '金额', PRIMARY KEY (`id`), UNIQUE KEY `uk_order_no` (`order_no`), KEY `idx_user` (`user_id`), KEY `idx_venue_time` (`venue_id`,`start_time`) ) ENGINE=InnoDB;

四、部署优化方案

容器化部署

使用Docker Compose编排服务（MySQL主从+Redis集群+Nacos+Spring Boot应用）

示例docker-compose.yml片段：

yaml

services: mysql-master: image: mysql:8.0 environment: MYSQL_ROOT_PASSWORD: root123 MYSQL_DATABASE: venue_booking volumes: - ./mysql/master/data:/var/lib/mysql redis-cluster: image: redis:7.0 command: redis-server --cluster-enabled yes --appendonly yes

性能监控
- Prometheus + Grafana监控JVM指标（GC次数、内存使用）
- SkyWalking APM追踪预约全链路耗时（从用户点击到设备响应）
压测数据
- 使用JMeter模拟2000用户并发预约，90%请求响应时间<500ms
- 关键接口TPS：
  - 查询库存：1200/s
  - 创建订单：800/s