谢飞机面大厂：Java面试官3轮连环拷问——从Spring Boot到AI Agent的实战穿透

唤醒那回忆

435人浏览 · 2026-03-17 11:01:10

唤醒那回忆 · 2026-03-17 11:01:10 发布

谢飞机面大厂：Java面试官3轮连环拷问——从Spring Boot到AI Agent的实战穿透

场景设定：某一线大厂音视频中台 + AIGC内容生成双业务线联合面试。面试官冷静犀利，谢飞机——985非科班、自学3年、简历写满“精通”、口头禅是“我调过源码”。

🌪️ 第1轮：基础稳不稳？音视频上传链路里的Spring Boot生死局

面试官：我们音视频平台每天处理2000万条UGC上传，首屏加载要求<800ms。请说说你设计的上传接口。

✅ Q1：用Spring Boot实现分片上传接口，如何保证并发安全与进度可查？

❌ 谢飞机：（挠头）啊…用@RestController，前端传filePart，后端MultipartFile接收…进度？嗯…我存个Redis？key叫upload:progress:${uuid}…

✅ Q2：MyBatis执行INSERT INTO video_meta (...) VALUES (...)后，怎么立刻拿到自增ID？如果插入失败但事务未回滚，你怎么感知？

❌ 谢飞机：useGeneratedKeys="true" keyProperty="id"！失败？呃…加个try-catch打印日志…

✅ Q3：上传成功后要触发封面生成、转码、审核三个异步任务。你选@Async还是消息队列？为什么？

❌ 谢飞机：（自信）@Async！简单！加个@EnableAsync和Executor就行…（小声）就是有时候OOM…

💡 面试官点头：Redis存进度是对的，但建议用Redis Stream或Hash结构；MyBatis ID获取正确，但异常需结合TransactionSynchronizationManager监听事务状态；@Async在高并发下确实危险——线程池打满会丢任务，音视频场景必须用Kafka解耦+重试保障。很好，进入下一轮。

🌪️ 第2轮：系统扛不扛？AIGC内容风控服务的微服务韧性挑战

我们刚上线AI生成短视频审核服务，调用路径：Gateway → Auth-Service → AiAudit-Service → RuleEngine-Service。上周峰值QPS 1.2w，RuleEngine超时率突增至35%。

✅ Q1：你作为AiAudit-Service开发者，如何快速定位是RuleEngine慢，还是网络/序列化/熔断问题？

❌ 谢飞机：看日志！feign.RetryableException？那肯定是网络…或者加个@HystrixCommand？

✅ Q2：现要求对RuleEngine调用增加熔断+降级，降级逻辑返回“人工复审中”。你用Resilience4j怎么配TimeLimiter和CircuitBreaker？

❌ 谢飞机：（翻手机备忘录）circuitbreaker.failure-rate-threshold=50… timelimiter.timeout-duration=2s… 其他…复制的配置…

✅ Q3：审核结果需实时推送用户，但WebSocket集群间消息不互通。你如何保证“用户A在节点1上传，节点2推送通知”？

❌ 谢飞机：（卡壳）用Redis Pub/Sub？… 或者… WebSocket加个网关路由？

💡 面试官轻敲桌面：第一问，必须结合Micrometer+Prometheus查feign.client.requests.duration直方图，再比对resilience4j.circuitbreaker.calls指标；第二问，TimeLimiter要配合Future.get(timeout)使用，否则无效；第三问，标准解法是引入消息中间件（如Kafka）做事件广播，WebSocket服务监听Topic消费推送——这是云原生架构的共识。继续。

🌪️ 第3轮：未来有没有？AIGC智能客服的RAG+Agent工程落地

我们正构建企业级文档问答机器人，支持PDF/PPT/Excel混合加载，用户问“报销流程第三步要盖什么章”，需精准定位到《财务制度V3.2.pdf》第17页。

✅ Q1：文档加载阶段，如何避免大文件（如500MB财报PDF）导致JVM OOM？

❌ 谢飞机：（擦汗）… 加-Xmx8g？或者用流式读取… Apache PDFBox好像有PDDocument.loadNonSeq…

✅ Q2：向量化时，用OpenAI Embedding API成本高且不可控。若改用本地Ollama部署nomic-embed-text模型，Spring AI如何切换EmbeddingClient？

❌ 谢飞机：spring.ai.ollama.embedding.model=nomic-embed-text？… 然后… EmbeddingClient注入？

✅ Q3：用户连续追问“那电子发票怎么验真”，系统需自动切换到税务API工具调用。这个“工具选择+参数填充+执行+结果整合”的闭环，Spring AI里哪个组件负责？

❌ 谢飞机：（沉默5秒）… 是… ChatClient？还是AiClient？… 好像有个ToolExecutor…

💡 面试官合上笔记本：Q1答对一半——流式加载+分块（chunk）+禁用字体解析才是关键；Q2配置正确，但需注意Ollama默认HTTP端口及健康检查；Q3答案是 ToolProvider + ToolExecutor + ToolResponseHandler三组件协同，由AiServices自动编排——这正是Agentic RAG区别于传统RAG的核心。谢同学，你对技术有热情，基础扎实，但在**复杂业务抽象与可观测性工程上还需沉淀。回家等通知吧。

✅ 全题技术解析（小白友好版）

🔹 场景锚点：音视频+UGC+AIGC融合业务

为什么不是单场景？ 大厂真实项目必然是多域交织：音视频提供流量入口，AIGC提升内容产能，风控/AI客服保障合规与体验。

🔹 第1轮技术链路：`Spring Boot → MyBatis → Redis`

分片上传进度存储：Redis Hash（HSET upload:123 progress 65% size 104857600）比String更省内存，支持原子更新。
MyBatis主键回写：useGeneratedKeys=true仅对MySQL有效；PostgreSQL需用<selectKey>；异常捕获后必须手动TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()防脏数据。
异步任务选型：@Async无持久化、无重试、无监控，Kafka+DLQ（死信队列）+幂等Consumer才是生产级方案。

🔹 第2轮技术链路：`Spring Cloud OpenFeign → Resilience4j → Kafka`

故障定位黄金三指标：feign.client.requests.duration（耗时）、resilience4j.circuitbreaker.state（熔断状态）、kafka.consumer.fetch-latency-avg（拉取消息延迟）。
Resilience4j最佳实践：TimeLimiter必须包裹CompletableFuture.supplyAsync()，否则超时无效；CircuitBreaker需配置sliding-window-type=count_based应对突发流量。
WebSocket集群通信：禁止直接跨节点调用！标准模式 = User Event → Kafka Topic → All WS Nodes Subscribe → Local Session Push，用spring-kafka + ConcurrentMessageListenerContainer实现。

🔹 第3轮技术链路：`Spring AI → Ollama → ChromaDB → Tool Calling`

大文档防OOM：PDFBox流式加载 + 自定义TextStripper跳过图像/字体 + 分块策略（按语义段落而非固定Token数）。
Embedding模型切换：Spring AI 0.8.1+ 支持OllamaEmbeddingClient.builder().baseUrl("http://localhost:11434").model("nomic-embed-text").build()，自动注册为EmbeddingClient Bean。

Agent工作流本质：

// Spring AI自动识别@Tool方法，生成ToolSpecification
@Tool
public String verifyInvoice(String invoiceNo) { ... }

// AiServices根据LLM返回的tool_calls自动调度
aiServices.chat("电子发票怎么验真？", options);

核心是LLM输出JSON格式tool_calls，框架解析并执行，再将结果喂回LLM生成终态回答——这就是“智能代理”的工程实现。