Java大厂面试实战：电商高并发场景下的Spring Boot+Redis+Kafka技术栈深度解析

Java大厂面试实战电商高并发场景下的技术栈深度解析前言在互联网大厂面试中技术面试官往往会结合具体业务场景来考察候选人的技术深度和广度。本文模拟了一场电商场景下的Java技术面试通过面试官与求职者谢飞机的三轮对话帮助大家理解大厂面试的考察重点。面试场景某电商大厂后端开发岗位面试官严肃脸你好请坐。今天我们来聊聊电商场景下的技术实现问题。谢飞机紧张地搓手好...好的面试官好第一轮基础技术考察电商商品系统问题1电商商品详情页的并发量很大你会用哪些技术来优化谢飞机这个...可以用缓存Redis缓存商品数据数据库用连接池...还有Spring Boot做快速开发面试官点头方向对。具体说说Redis怎么设计缓存结构谢飞机就...key-value嘛key是商品IDvalue是商品信息的JSON字符串面试官微笑不错基础概念清晰。那缓存穿透、击穿、雪崩怎么解决谢飞机擦汗穿透...是查不存在的数据可以用布隆过滤器击穿...热点数据过期加互斥锁雪崩...大量缓存同时过期设置随机过期时间面试官满意回答得很好继续。问题2商品库存扣减怎么保证数据一致性谢飞机用数据库事务Transactional注解加上就行面试官高并发场景下呢比如秒杀活动1万人同时抢100件商品。谢飞机犹豫那...那用Redis预扣减先在Redis里减库存再异步写数据库面试官引导思路对但怎么防止超卖谢飞机用Redis的Lua脚本保证原子性或者用Redisson的分布式锁面试官点头很好知道用原子操作。问题3订单系统用什么数据库分库分表怎么设计谢飞机MySQL分库分表...按用户ID哈希还是按订单时间面试官两种方案各有什么优缺点谢飞机挠头用户ID哈希...查询用户订单快但时间范围查询慢按时间分表...时间查询快但用户订单查询要扫多个表面试官认可理解到位。那用什么中间件谢飞机ShardingSphere或者MyCat第二轮进阶技术考察微服务架构问题4电商系统怎么用微服务拆分谢飞机按业务域拆分用户服务、商品服务、订单服务、支付服务、库存服务...面试官服务之间怎么调用谢飞机Spring Cloud OpenFeign还有Spring Cloud Gateway做网关面试官服务挂了怎么办谢飞机自信熔断降级用Resilience4j或者Sentinel面试官赞许技术选型很新不错。问题5订单创建后需要通知库存、物流、积分等多个系统怎么设计谢飞机用消息队列Kafka面试官为什么选Kafka不选RabbitMQ谢飞机思考Kafka吞吐量高适合日志和大量消息RabbitMQ功能更丰富有各种交换器面试官电商场景下呢谢飞机订单消息量大用Kafka需要复杂路由用RabbitMQ面试官满意理解场景差异。问题6消息丢失怎么解决谢飞机开始含糊Kafka有ack机制...生产者确认...消费者手动提交...面试官具体怎么配置谢飞机眼神飘忽ackall...retries设置大一点...幂等性消费...面试官皱眉幂等性怎么实现谢飞机擦汗数据库唯一索引或者Redis记录已处理的消息ID面试官记录继续下一轮。第三轮架构设计考察高并发与监控问题7双11大促系统怎么保证高可用谢飞机紧张限流熔断降级预案面试官具体怎么限流谢飞机网关层限流用SentinelQPS阈值...用户维度限流...接口维度限流...面试官服务实例怎么扩缩容谢飞机KubernetesHPA自动扩缩容面试官点头云原生意识不错。问题8系统监控怎么做谢飞机稍微自信PrometheusGrafana监控指标...JVM...CPU...内存...面试官链路追踪呢谢飞机SkyWalking或者ZipkinJaeger面试官日志收集谢飞机ELK StackElasticsearchLogstashKibana面试官认可技术栈比较全面。问题9分布式事务怎么解决谢飞机开始含糊SeataTCC模式...或者...最终一致性面试官订单和库存的分布式事务具体怎么设计谢飞机眼神游离先扣库存...再创建订单...失败了回滚...用消息队列保证最终一致...面试官追问回滚失败怎么办谢飞机冒汗补偿事务定时任务扫描...人工介入面试官记录好今天先到这里。面试结束面试官合上笔记本今天的面试就到这里我们会在一周内给你反馈请保持手机畅通。谢飞机松一口气好的好的谢谢面试官详细答案解析小白学习专区一、缓存优化方案1.1 Redis缓存结构设计// 商品缓存Key设计 String productKey product: productId; // 库存缓存Key设计 String stockKey stock: productId; // 热点数据单独缓存 String hotProductKey hot:product: productId;技术要点使用分层缓存策略热点数据单独处理Key设计要有业务含义便于管理设置合理的过期时间避免雪崩1.2 缓存三大问题解决方案| 问题 | 原因 | 解决方案 | |------|------|----------| | 缓存穿透 | 查询不存在的数据 | 布隆过滤器、缓存空值 | | 缓存击穿 | 热点数据过期 | 互斥锁、永不过期异步更新 | | 缓存雪崩 | 大量缓存同时过期 | 随机过期时间、高可用集群 |代码示例// 布隆过滤器防止穿透 Autowired private RedissonClient redissonClient; public Product getProduct(Long productId) { RBloomFilterLong bloomFilter redissonClient.getBloomFilter(product:bloom); if (!bloomFilter.contains(productId)) { return null; // 直接返回不查数据库 } // 正常查询逻辑 } // 互斥锁防止击穿 public Product getProductWithLock(Long productId) { String key lock:product: productId; RLock lock redissonClient.getLock(key); if (lock.tryLock()) { try { // 双重检查后加载缓存 return loadProductFromDb(productId); } finally { lock.unlock(); } } // 等待后重试 }二、库存扣减一致性方案2.1 Redis Lua脚本原子扣减-- 库存扣减Lua脚本 local stockKey KEYS[1] local quantity tonumber(ARGV[1]) local current tonumber(redis.call(GET, stockKey)) if current quantity then redis.call(DECRBY, stockKey, quantity) return 1 -- 成功 else return 0 -- 库存不足 end// Java调用Lua脚本 Autowired private RedisTemplateString, Object redisTemplate; public boolean deductStock(Long productId, Integer quantity) { String script ...; // 上面的Lua脚本 RedisScriptLong redisScript RedisScript.of(script, Long.class); Long result redisTemplate.execute( redisScript, Collections.singletonList(stock: productId), quantity ); return result 1; }2.2 分布式锁方案RedissonAutowired private RedissonClient redissonClient; public Order createOrder(OrderDTO dto) { RLock lock redissonClient.getLock(order: dto.getUserId()); if (lock.tryLock(3, 10, TimeUnit.SECONDS)) { try { // 1. 校验库存 // 2. 扣减库存 // 3. 创建订单 return orderService.create(dto); } finally { lock.unlock(); } } throw new BusinessException(系统繁忙请稍后重试); }三、分库分表设计3.1 分片策略对比| 分片方式 | 优点 | 缺点 | 适用场景 | |----------|------|------|----------| | 用户ID哈希 | 用户订单查询快 | 时间范围查询慢 | C端用户订单 | | 订单时间 | 时间查询快 | 用户查询需扫多表 | 后台管理查询 | | 复合分片 | 兼顾多种查询 | 配置复杂 | 大型电商系统 |3.2 ShardingSphere配置示例spring: shardingsphere: datasource: names: ds0,ds1 rules: sharding: tables: t_order: actual-data-nodes: ds${0..1}.t_order_${0..3} table-strategy: standard: sharding-column: user_id sharding-algorithm-name: user-hash sharding-algorithms: user-hash: type: HASH props: sharding-count: 8四、微服务架构设计4.1 服务拆分原则电商系统微服务拆分 ├── 用户服务 (user-service) ├── 商品服务 (product-service) ├── 订单服务 (order-service) ├── 库存服务 (inventory-service) ├── 支付服务 (payment-service) ├── 物流服务 (logistics-service) └── 网关服务 (gateway-service)4.2 OpenFeign调用示例FeignClient(name inventory-service) public interface InventoryClient { PostMapping(/api/inventory/deduct) ResultBoolean deductStock(RequestBody StockDTO dto); } Service public class OrderService { Autowired private InventoryClient inventoryClient; public Order createOrder(OrderDTO dto) { // 调用库存服务 ResultBoolean result inventoryClient.deductStock( new StockDTO(dto.getProductId(), dto.getQuantity()) ); if (!result.getData()) { throw new BusinessException(库存不足); } // 创建订单逻辑 } }4.3 熔断降级配置Resilience4jConfiguration public class ResilienceConfig { Bean public CircuitBreakerConfig circuitBreakerConfig() { return CircuitBreakerConfig.custom() .failureRateThreshold(50) // 失败率阈值50% .waitDurationInOpenState(Duration.ofSeconds(30)) // 打开状态等待时间 .slidingWindowSize(10) // 滑动窗口大小 .build(); } } Service public class InventoryService { CircuitBreaker(name inventoryService, fallbackMethod fallback) public Boolean deductStock(Long productId, Integer quantity) { // 正常调用逻辑 } public Boolean fallback(Long productId, Integer quantity, Exception e) { // 降级逻辑返回缓存数据或默认值 return false; } }五、消息队列设计5.1 Kafka vs RabbitMQ选型对比| 特性 | Kafka | RabbitMQ | |------|-------|----------| | 吞吐量 | 10万/秒 | 万级/秒 | | 延迟 | 毫秒级 | 毫秒级 | | 可靠性 | 高 | 非常高 | | 功能 | 简单 | 丰富各种交换器 | | 适用场景 | 日志、大数据、订单流 | 复杂路由、事务消息 |5.2 Kafka消息可靠性配置# 生产者配置 spring: kafka: producer: acks: all # 所有副本确认 retries: 3 # 重试次数 properties: enable.idempotence: true # 幂等性 max.in.flight.requests.per.connection: 5 # 消费者配置 consumer: enable-auto-commit: false # 手动提交 isolation.level: read_committed # 读已提交5.3 幂等性消费实现Service public class OrderMessageConsumer { Autowired private StringRedisTemplate redisTemplate; KafkaListener(topics order-created) public void consumeOrderMessage(ConsumerRecordString, String record) { String messageId record.key(); String idempotentKey order:message: messageId; // 使用Redis SETNX实现幂等 Boolean success redisTemplate.opsForValue() .setIfAbsent(idempotentKey, 1, 24, TimeUnit.HOURS); if (!success) { log.warn(重复消息已处理过{}, messageId); return; } try { // 处理业务逻辑 processOrder(record.value()); } catch (Exception e) { // 处理失败删除幂等标记允许重试 redisTemplate.delete(idempotentKey); throw e; } } }六、高可用架构设计6.1 限流策略SentinelRestController RequestMapping(/api/order) public class OrderController { PostMapping(/create) SentinelResource(value createOrder, blockHandler handleBlock, fallback handleFallback) public ResultOrder createOrder(RequestBody OrderDTO dto) { return orderService.create(dto); } // 限流处理 public ResultOrder handleBlock(OrderDTO dto, BlockException e) { return Result.fail(系统繁忙请稍后重试); } // 降级处理 public ResultOrder handleFallback(OrderDTO dto, Throwable e) { return Result.fail(服务暂时不可用); } }6.2 Kubernetes HPA配置apiVersion: autoscaling/v2 kind: HorizontalPodAutoscaler metadata: name: order-service-hpa spec: scaleTargetRef: apiVersion: apps/v1 kind: Deployment name: order-service minReplicas: 3 maxReplicas: 20 metrics: - type: Resource resource: name: cpu target: type: Utilization averageUtilization: 70 - type: Resource resource: name: memory target: type: Utilization averageUtilization: 80七、监控体系设计7.1 PrometheusGrafana监控指标# Spring Boot Actuator配置 management: endpoints: web: exposure: include: health,info,metrics,prometheus metrics: export: prometheus: enabled: true tags: application: ${spring.application.name}核心监控指标JVM堆内存、GC次数、线程数应用QPS、响应时间、错误率业务订单量、支付成功率、库存周转率中间件Redis命中率、Kafka积压量、数据库连接数7.2 链路追踪SkyWalking// 无需代码侵入Agent自动采集 // 配置application.yml skywalking: agent: service_name: order-service namespace: ecommerce collector: backend_service: skywalking-oap:118007.3 日志收集ELK# Logback配置 dependencies: - logback-classic - logstash-logback-encoder # logback-spring.xml appender nameLOGSTASH classnet.logstash.logback.appender.LogstashTcpSocketAppender destinationlogstash:5000/destination encoder classnet.logstash.logback.encoder.LogstashEncoder/ /appender八、分布式事务方案8.1 Seata AT模式推荐// 全局事务注解 GlobalTransactional public Order createOrderWithStock(OrderDTO dto) { // 1. 扣减库存库存服务 inventoryService.deduct(dto.getProductId(), dto.getQuantity()); // 2. 创建订单订单服务 Order order orderService.create(dto); // 3. 扣减余额账户服务 accountService.deduct(dto.getUserId(), dto.getAmount()); return order; // 任意一步失败自动回滚所有操作 }8.2 最终一致性方案消息队列订单创建流程 1. 订单服务创建订单状态待支付→ 本地事务提交 2. 订单服务发送订单创建消息 → Kafka 3. 库存服务消费消息 → 扣减库存 4. 积分服务消费消息 → 增加积分 5. 物流服务消费消息 → 生成物流单 补偿机制 - 定时任务扫描超时未支付订单 - 自动取消订单发送订单取消消息 - 各服务消费取消消息回滚操作总结面试准备建议技术栈学习路径基础层Java核心 → JVM → 数据结构与算法 框架层Spring Boot → Spring Cloud → MyBatis 中间件Redis → Kafka → Elasticsearch 架构层微服务 → 分布式 → 高并发 运维层Docker → Kubernetes → 监控体系面试技巧业务场景结合不要只背八股文要结合具体业务场景回答循序渐进从简单到复杂展示思考过程承认不足不会的问题诚实说展示学习能力主动引导在自己熟悉的领域多展开引导面试官提问常见误区❌ 只背答案不理解原理❌ 技术栈贪多不精❌ 忽视业务场景理解❌ 不关注新技术发展最后提醒面试是双向选择保持自信展现真实的自己。祝大家都能拿到心仪的Offer本文基于真实面试场景整理技术点仅供参考实际面试请以公司要求为准。