mq延迟发送如何实现

一、 深度技术方案设计（高并发与可靠性）消息系统设计：在高并发场景下，如何设计一个小程序消息推送系统，同时兼顾实时性和可靠性？如何解决消息重复推送和延迟的问题？消息队列（MQ）细节权衡：为了保证不丢消息，如果要求写入所有 Partition 副本再返回，会如何影响实时性？如何在性能与安全之间做权衡？当主副本（Leader）宕机且数据未同步到从副本时，产生的消息丢失问题该如何解决？（考察对 Offset 水位、ACK 机制的理解）。并发与幂等性控制：在消费者端做幂等判断时，如果两个并发请求同时查 Redis 发现都没消费过，导致重复处理，该如何解决？高并发下单场景：同一个用户瞬间发送多个下单请求（如限购1件），如何控制并发以防止超卖或重复下单？追问：如何具体保证操作的原子性？（如 Lua 脚本的应用场景）。二、 架构能力与跨团队协作（软素质与流程）面试官明确表示这一环节侧重于团队协作和技术架构层面的思维：推动技术标准统一：假设不同业务线使用的加密标准（如 AES 密钥管理）不统一，你如何推动大家执行统一的标准？如何撰写技术提案？跨团队的沟通策略是什么？冲突处理与说服力：如果某个团队以“业务极其紧急”为由拒绝配合统一标准或系统优化，你该如何说服他们？系统重构与风险控制：推动系统重构时，需要考虑哪些层面？如何保证安全切换？（考察灰度发布、切流策略、监控指标 TP99、客诉观察等）。故障复盘与流程优化：场景模拟：上游算法团队修改了接口字段名，导致前后端崩溃，如何快速止损？深度思考：除了代码回滚，从组织协作和流程规范层面，如何避免此类问题再次发生？（引导回答：契约测试、变更规范、回归测试等）。三、 编程与算法考察面试官提供了三道笔试题，并针对代码逻辑进行了追问：任务调度逻辑题：考察在给定时间限制内能完成的任务数量（需考虑任务的前后依赖或时间重叠）。整数反转：追问：如果反转后的结果超出了 int 的上限，在代码中如何处理溢出问题？数学逻辑题（容器倒水/量水问题）：考察如何通过两个不同容量的容器得到目标水量的逻辑推导能力。

自我介绍项目1. 介绍下 Agent 项目中和亮点2. 项目的主要难点是什么3. 举一个项目中的例子4. ES 在项目中的功能5. 检索结果如何进行融合6. 具体是怎么生成向量的，维度是多少7. 怎么让模型知道有哪些工具，以及模型是如何调用工具的8. SSE 协议返回信息的格式是什么样的9. 记忆模块怎么设计的10. 短期记忆放在哪11. 结构化信息有哪些12. 什么时候开始长期记忆抽取13. 使用 Redis 存储短期记忆产生的大 Key 问题怎么解决14. 如何设计一个上下文卸载功能？15. Agen 执行时间长，在服务重启/崩溃后，如何保证可以接着执行任务，保证任务可以完成MySQL 1...

双非大三，目前有两个选择1.北京小厂，给车企做hud的，4400，听已经去的人说项目比较简单，学不到太多，但是资金充足全员mac，能转正，带他的人就是刚实习转正的2.熙牛医疗，5500，听面试官说项目用了很多中间件，dubbo，mq，redis

bg：双非学院本0实习一、自我介绍二、项目拷打Q1：请介绍一下你简历中的项目，挑一个几个你认为做得比较好的地方讲讲。（问了好多拷打了好多）三、八股（格外的少）居然是在会议评论区出的题（第一次见）Q2：HashMap是不是线程安全的、会出现什么问题、你怎么处理的Q3：Synchronize和ReetrantLock区别Q4：数据库索引作用、索引失效的情况（三个就行）、explain怎么看用没用到索引四、场景题（可以写伪代码或者口述 口述了）Q5：1.设计一个泛型类有key和value 2.保证并发安全的同时3.设置限流 5秒五次4.设计一个缓存 最大容量100 超过采取lru删除五、反问环节问了...