PriorityBlockingQueue 是线程安全的无界优先队列，基于堆实现权重排序，支持自定义 Comparator 降序排高权消息，权重相同时按入队时间升序防饥饿，适用于多生产者-多消费者的消息分发场景。
PriorityBlockingQueue 是 Java 并发包中专为高优先级消息分发设计的线程安全队列，它天然适合在消息系统中实现“权重驱动、先到不先得”的下发逻辑——关键不是谁先来，而是谁更重要。
为什么选 PriorityBlockingQueue 而不是普通队列
普通阻塞队列（如 LinkedBlockingQueue）按 FIFO 原则处理，无法区分验证码短信和营销通知的紧急程度；而 PriorityBlockingQueue 内部基于堆结构，支持自定义排序规则，能确保高权重消息始终排在消费队列头部。它无界但线程安全，put/take 操作自动同步，无需额外加锁，适合多生产者-多消费者模型。
如何定义“高权重变量”并参与排序
权重不能硬编码在消息体里靠 if 判断，而应作为可比较字段嵌入消息对象，并通过外部 Comparator 控制排序逻辑：
- 消息类（如 SmsMessage）包含 weight（int）、enqueueTime（long）、content（String）等字段
- 构造队列时传入 Comparator：(m1, m2) → Integer.compare(m2.getWeight(), m1.getWeight()) 实现降序（权重高者优先）
- 权重相同时，用 enqueueTime 升序兜底，避免饥饿：Long.compare(m1.getEnqueueTime(), m2.getEnqueueTime())
- 不建议让消息类实现 Comparable，否则耦合严重，难以在监控系统、运维后台等不同场景切换排序策略
典型消息分发流程示例
以短信中心为例，验证码类消息 weight=10，订单通知 weight=3，促销广告 weight=1：
- 生产端调用 queue.put(new SmsMessage(10, "验证码:123456"))，立即进入堆顶位置
- 即使它比 weight=1 的消息晚入队 2 秒，take() 时仍会第一个被取出
- 消费线程调用 queue.take() 阻塞等待，一旦有高权消息就绪，立刻响应，无轮询开销
- 若需防止 OOM，可在初始化时指定初始容量，或配合监控做队列长度阈值告警
与 Kafka 等中间件的协同思路
Kafka 本身不支持原生优先级，但可与 PriorityBlockingQueue 分层配合：
- Kafka 作为可靠传输层，负责消息持久化与跨服务投递
- 下游服务启动后，将拉取到的消息按权重注入本地 PriorityBlockingQueue
- 业务线程池从该队列 take() 执行，实现“Kafka 保底 + 内存队列提速”的混合模型
- 注意：需保证单实例内消费顺序，跨实例优先级需依赖全局调度器或分片 Key 对齐
不复杂但容易忽略。
