湛江手机建站模板哈尔滨公司网站建设多少钱

湛江手机建站模板,哈尔滨公司网站建设多少钱,dw怎么做网站布局,端游传奇排行榜前十名大厂 Java 面试实录#xff1a;严肃面试官 vs 搞笑水货程序员谢飞机#xff08;音视频弹幕场景#xff09;场景#xff1a;某互联网大厂「音视频 内容社区」业务线。核心链路#xff1a;直播间弹幕/评论 → Kafka → 弹幕服务 → Redis 热缓存 → MySQL 落库 → 实时风控…大厂 Java 面试实录严肃面试官 vs 搞笑水货程序员谢飞机音视频弹幕场景场景某互联网大厂「音视频 内容社区」业务线。核心链路直播间弹幕/评论 → Kafka → 弹幕服务 → Redis 热缓存 → MySQL 落库 → 实时风控 → Prometheus 监控告警。角色面试官严肃问得很深还会循循善诱。谢飞机搞笑水货简单题能答复杂题开始“云里雾里”但嘴很硬。第一轮直播弹幕链路的基础设计从能跑到能稳Q1面试官直播间弹幕量很大你会怎么设计弹幕服务的入口Spring MVC 还是 WebFluxA1谢飞机我一般用Spring MVC因为我熟……咳因为它成熟稳定。要是并发特别高我也可以“考虑”WebFlux毕竟它……更丝滑面试官引导回答方向对。MVC 是阻塞模型线程数是瓶颈WebFlux 适合高并发 IO 场景但要端到端响应式才有效。那弹幕入口你怎么做限流Q2面试官给我一个你在 Spring Boot 里做限流Resilience4j的例子按直播间维度限流。A2谢飞机限流我会就是……把请求挡住。Resilience4j 我用过注解RateLimiter。然后超了就返回“你太快了”。面试官点头能用就行但大厂要讲“按 key 限流”。继续弹幕要异步落库为什么你会选 KafkaQ3面试官Kafka 落地弹幕消息你怎么保证“不会丢”至少说清楚 producer 和 consumer 的关键参数。A3谢飞机Kafka 不会丢的吧它不是很可靠嘛。producer 我会开acksallconsumer 我会手动提交 offset……嗯然后就不丢了面试官表扬 追问关键点抓到了acksall和手动提交。那你怎么做“幂等”避免重复消费导致重复入库Q4面试官弹幕消费落库怎么做幂等给个 MySQL/Redis 方案都行。A4谢飞机幂等嘛就是“只执行一次”。我可以用 Redis setnx或者数据库加唯一索引比如 messageId 唯一这样插入重复就失败。当然失败了我就……忽略。面试官认可这就对了业务幂等是大厂基本功。第二轮性能与一致性从能稳到能扛Q1面试官弹幕接口要返回很快但又要展示“最近 50 条”。你怎么设计缓存用 Redis 还是 CaffeineA1谢飞机我选 Redis因为它在“远端”大家都能用。Caffeine 是本地缓存适合单机……不过我也可以两级缓存Caffeine 顶一下热点Redis 做共享。面试官引导思路正确二级缓存常见。那你怎么避免缓存击穿/穿透Q2面试官说说缓存穿透、击穿、雪崩你分别怎么应对A2谢飞机穿透查不到也一直查数据库我就加布隆过滤器虽然我没手写过。击穿热点 key 过期一堆人打 DB我就加互斥锁或者逻辑过期。雪崩很多 key 同时过期我就随机过期时间、加限流降级。面试官赞许虽然“没手写过”很诚实但思路完整。接下来落库用 MyBatis 还是 JPA连接池你选啥Q3面试官MyBatis/JPA 你怎么选连接池 HikariCP 为什么是默认首选A3谢飞机我选 MyBatisSQL 更可控性能调优也直观。JPA 适合简单 CRUD。HikariCP 快而且……Spring Boot 默认就是它我也就默认了。面试官补刀“默认就用”是水货回答。说一个 HikariCP 的关键点它做了更少的锁竞争、连接获取路径更短。好继续弹幕消息要跨服务调用风控你用 Feign 还是 gRPCQ4面试官风控服务是高 QPS、低延迟你选 OpenFeign 还是 gRPC为什么A4谢飞机我一般用 Feign很方便写接口就行。但如果追求性能……gRPC 用 protobuf传输更小延迟更低也更适合内部高频调用。面试官认可这次回答像个人了。第三轮可观测性与事故处理从能扛到能救火Q1面试官弹幕延迟突然升高你怎么定位你会看哪些指标Micrometer 怎么接 PrometheusA1谢飞机我会先看 Grafana 面板QPS、RT、错误率。Micrometer 接 Prometheus 就是加依赖然后暴露/actuator/prometheus。面试官继续逼问那你怎么把 Kafka 消费延迟也纳入监控以及链路追踪怎么做Q2面试官Kafka 的 lag 怎么监控链路追踪用 Jaeger/Zipkin你在 Spring Cloud 体系里怎么串起来A2谢飞机lag 可以看 consumer group 的 offset 差值……用 exporter 或者自己采集。追踪我知道用 traceId把它传来传去然后 Jaeger 就能看调用链。面试官点评方向对但描述含糊大厂要“可操作”。例如用Kafka Exporter Prometheus链路用OpenTelemetry/或 Sleuth自动注入 traceId。最后一题系统降级怎么做Q3面试官弹幕服务依赖风控服务风控挂了你怎么办给个 Resilience4j 的降级例子。A3谢飞机那就降级呗风控调用失败就默认放行……或者默认拦截我觉得默认放行用户体验好。面试官眼神危险代码可以用CircuitBreakerfallback 返回一个“通过”的结果。面试官严肃安全和体验要权衡通常风控失败要“分级处理”至少对高风险流量要默认拦截。行了今天到这。回去等通知有消息 HR 联系你。文章最后把上面问题的“标准答案”一次讲透带代码、场景、可落地下面按面试链路把关键技术点补齐让小白也能跟下来。1弹幕入口Spring MVC vs WebFlux 怎么选业务场景直播弹幕接口是典型“高并发 IO”请求短、响应快主要瓶颈在网络、序列化、下游依赖Redis/Kafka/风控。Spring MVCServlet一个请求占用一个线程吞吐受线程池限制优点是生态成熟、调试简单。Spring WebFluxReactive事件循环 非阻塞 IO适合高并发、长连接/IO 密集但必须“端到端响应式”Redis/Kafka 客户端、下游调用也要配套否则收益有限。建议入口是短请求、依赖链路多且大部分组件仍是阻塞 →MVC 线程池治理更稳。若是长连接如 WebSocket 弹幕推送或整体响应式链路 →WebFlux 更合适。2限流Resilience4j 在 Spring Boot 的用法按接口限流 降级Maven 依赖dependency groupIdio.github.resilience4j/groupId artifactIdresilience4j-spring-boot3/artifactId version2.2.0/version /dependency配置application.ymlresilience4j.ratelimiter: instances: danmakuPost: limitForPeriod: 200 limitRefreshPeriod: 1s timeoutDuration: 0代码Spring MVCRestController RequestMapping(/api/live) class DanmakuController { PostMapping(/{roomId}/danmaku) io.github.resilience4j.ratelimiter.annotation.RateLimiter( name danmakuPost, fallbackMethod rateLimited ) public MapString, Object post(PathVariable long roomId, RequestBody DanmakuReq req) { // 这里只演示真实场景会写 Kafka、写 Redis、异步落库 return Map.of(ok, true); } private MapString, Object rateLimited(long roomId, DanmakuReq req, Throwable t) { return Map.of(ok, false, msg, 发送过快请稍后再试); } } record DanmakuReq(String content, String msgId, long uid) {}说明严格“按直播间 roomId 限流”通常要用网关层Spring Cloud Gateway/Nginx或自定义 key 维度限流组件注解限流更像“方法级保护”。3Kafka如何尽量不丢消息 不重复入库至少一次 幂等Producer关键参数acksallISR 全部确认才算成功enable.idempotencetrue幂等生产避免重试导致重复写入retries配合幂等min.insync.replicasbroker 侧要合理配置Consumer手动提交 offset处理成功再提交Spring Kafka示意KafkaListener(topics danmaku, groupId danmaku-consumer) public void onMessage(ConsumerRecordString, DanmakuEvent record, Acknowledgment ack) { DanmakuEvent e record.value(); // 1) 幂等校验例如用 DB 唯一键 or Redis SETNX // 2) 落库成功 // 3) ack.acknowledge() 手动提交 ack.acknowledge(); } record DanmakuEvent(String msgId, long roomId, long uid, String content, long ts) {}幂等落库MySQL 唯一键推荐、简单、可靠表设计增加唯一索引CREATE TABLE danmaku ( id BIGINT PRIMARY KEY AUTO_INCREMENT, msg_id VARCHAR(64) NOT NULL, room_id BIGINT NOT NULL, uid BIGINT NOT NULL, content VARCHAR(255) NOT NULL, ts BIGINT NOT NULL, UNIQUE KEY uk_msg_id(msg_id) );插入时用“插入忽略/冲突不报错”的语义MySQL 示例INSERT INTO danmaku(msg_id, room_id, uid, content, ts) VALUES(?, ?, ?, ?, ?) ON DUPLICATE KEY UPDATE msg_id msg_id;4缓存Redis Caffeine 二级缓存防击穿/穿透/雪崩业务目标读最近 50 条弹幕要快写弹幕要尽量不阻塞。Redis共享、跨实例Caffeine单机热点缓存降低 Redis 压力常用治理穿透布隆过滤器 / 空值缓存短 TTL击穿热点 key 互斥锁 / 逻辑过期后台重建雪崩TTL 加随机值 限流降级 多级缓存5连接池为什么 HikariCP 常用面试可说的关键点别说“默认就用”连接获取路径短、优化了锁竞争对超时、泄漏检测等治理能力更完整Spring Boot 深度集成配置简单、性能表现稳定6服务间调用Feign vs gRPC弹幕 → 风控一般是内部高频调用FeignHTTP/JSON开发效率高调试方便适合通用业务接口gRPCHTTP/2 Protobuf序列化更小、性能更好、适合高 QPS 低延迟、强约束接口7可观测性Micrometer Prometheus Grafana TracePrometheus 指标暴露Spring BootActuator常见配置依赖spring-boot-starter-actuator、micrometer-registry-prometheus暴露端点/actuator/prometheusKafka lag 监控落地做法可操作部署Kafka Exporter或使用平台自带监控Prometheus 抓取 lag 指标consumer group 的 current offset vs log end offsetGrafana 面板告警lag 持续上升 消费耗时增大链路追踪使用 OpenTelemetry或 Spring Cloud Sleuth 老体系自动注入 traceId/spanId上报到 Jaeger/Zipkin定位慢点在 Redis、DB、风控还是 Kafka8降级风控挂了怎么办Resilience4j 熔断 fallback典型策略风控不可用时按风险等级处理高风险新号、异常 IP、命中历史黑名单→ 默认拦截低风险老用户、低频→ 可降级放行但要打点审计代码示例熔断 fallbackService class RiskClient { io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker( name risk, fallbackMethod fallback ) public RiskResult check(DanmakuEvent e) { // 这里假设调用远程风控服务Feign/gRPC return new RiskResult(true, pass); } private RiskResult fallback(DanmakuEvent e, Throwable t) { // 示例按 uid/roomId 做简单分级 boolean allow e.uid() 100000; // 演示用真实应查画像/黑名单/阈值 return new RiskResult(allow, allow ? degraded-pass : degraded-block); } } record RiskResult(boolean allow, String reason) {}小结这条链路的“面试官想听什么”入口模型MVC/WebFlux 选型要结合端到端阻塞/非阻塞与连接形态HTTP vs WebSocket。限流/降级不仅会用注解更要讲清“key 维度”“兜底策略”。Kafka 不丢不重acksall、幂等生产、手动提交、业务幂等。缓存治理二级缓存 三大问题穿透/击穿/雪崩的工程化解法。可观测性指标 日志 TraceKafka lag 要能落到 exporter 告警规则。如果你希望下一篇继续这个系列我可以把场景升级到WebSocket 弹幕推送背压、连接治理Flink 实时风控Kafka → Flink → Redis/ESKubernetes 灰度发布 指标回滚策略