Spring监听器（ApplicationEvent）：比MQ更轻的异步神器！
<h3 id="引言当咖啡店遭遇程序员">引言：当咖啡店遭遇程序员</h3><blockquote>
<p>“顾客挤爆柜台时，优秀的店长不会催促咖啡师加速，而是启动一套科学的协作机制——<br>
就像Spring事件驱动，用<strong>发布-订阅模式</strong>让系统像顶级咖啡团队般优雅应对洪峰流量”</p>
</blockquote>
<hr>
<h3 id="一咖啡店里的监听器3位灵魂角色">一、咖啡店里的监听器：3位灵魂角色</h3>
<p><strong>真实战场还原</strong>（每秒1000订单的咖啡店）：</p>
<div class="mermaid">graph LR
顾客["🔥 顾客喊单（事件发布者）"] --> 订单事件["📦 OrderEvent（事件对象）"]
订单事件 --> 咖啡师["☕ 咖啡师（监听器1）"]
订单事件 --> 收银员["💰 收银员（监听器2）"]
订单事件 --> 甜点师["🍰 甜点师（监听器3）"]
</div><h4 id="1-事件定义咖啡店的订单小票">1. 事件定义：咖啡店的「订单小票」</h4>
<pre><code class="language-java">public class OrderEvent extends ApplicationEvent {
// final修饰的订单ID：就像咖啡师绝不涂改的订单小票
private final String orderId;
// 创建时间：记录订单诞生时刻（线程安全不可变）
private final LocalDateTime createTime = LocalDateTime.now();
// 无setter：防止多线程并发篡改订单
}
</code></pre>
<h4 id="2-事件发布店长的广播系统">2. 事件发布：店长的「广播系统」</h4>
<pre><code class="language-java">@Service
public class OrderService {
// 店长的麦克风（构造器注入更优雅）
private final ApplicationEventPublisher eventPublisher;
public void createOrder(Order order) {
// 核心业务：生成订单（咖啡店接单）
eventPublisher.publishEvent(new OrderEvent(this, order.getId())); // 📢 广播订单
}
}
</code></pre>
<h4 id="3-事件监听咖啡团队的技能响应">3. 事件监听：咖啡团队的「技能响应」</h4>
<pre><code class="language-java">@Component
public class CoffeeMakerListener {
@EventListener
@Order(1) // 优先级：先做咖啡再推荐甜点
public void makeCoffee(OrderEvent event) {
// 专注做咖啡，不关心谁结账
log.info("咖啡师：开始制作订单{}的拿铁...", event.getOrderId());
}
}
</code></pre>
<hr>
<h3 id="二扛住亿级流量的3把利器">二、扛住亿级流量的3把利器</h3>
<h4 id="-场景1冷启动缓存预加载防雪崩">🔥 <strong>场景1：冷启动缓存预加载（防雪崩）</strong></h4>
<pre><code class="language-java">@Component
public class CachePreloader {
// 在Spring容器"开店准备完成"时触发
@EventListener(ContextRefreshedEvent.class)
public void initCache() {
// 异步加载省时30%（实测数据）
CompletableFuture.runAsync(() -> {
provinceService.loadProvincesToCache();
productService.preloadHotProducts();
});
}
}
</code></pre>
<h4 id="-场景2事务成功后的缓存清理保一致性">💡 <strong>场景2：事务成功后的缓存清理（保一致性）</strong></h4>
<pre><code class="language-java">// 只在数据库提交成功后执行（避免脏清理）
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void cleanCache(OrderUpdateEvent event) {
// 异步清理：不阻塞结账队伍
redisTemplate.executeAsync(new RedisCallback<>() {
@Override
public Void doInRedis(RedisConnection connection) {
connection.del(("order:" + event.getId()).getBytes());
return null;
}
});
}
</code></pre>
<h4 id="-场景3无侵入式功能扩展">🚀 <strong>场景3：无侵入式功能扩展</strong></h4>
<p><strong>改造前（臃肿的收银台）</strong>：</p>
<pre><code class="language-java">public void pay() {
paymentService.pay(); // 核心支付
auditService.log(); // 审计代码入侵
riskService.check(); // 风控代码耦合
marketingService.addPoints(); // 新增需求污染核心
}
</code></pre>
<p><strong>事件驱动改造后</strong>：</p>
<pre><code class="language-java">// 纯净支付核心（专注收钱）
public void pay(Long orderId) {
paymentService.process(orderId);
eventPublisher.publishEvent(new PaymentSuccessEvent(orderId)); // 📢 广播支付成功
}
// 新增积分模块（无需修改支付代码）
@Component
public class PointListener {
@EventListener
public void addPoints(PaymentSuccessEvent event) {
// 积分服务独立演进
pointService.award(event.getOrderId(), 100);
}
}
</code></pre>
<hr>
<h3 id="三血泪教训3个深夜加班事故">三、血泪教训：3个深夜加班事故</h3>
<h4 id="-事故1多线程篡改事件订单混乱">🚫 <strong>事故1：多线程篡改事件（订单混乱）</strong></h4>
<pre><code class="language-java">// 错误！事件必须是只读的
@EventListener
public void handle(OrderEvent event) {
event.setStatus("MODIFIED"); // ⚠️ 多线程并发修改引发订单错乱
}
</code></pre>
<blockquote>
<p><strong>正确做法</strong>：事件类设计为final字段 + 无setter</p>
</blockquote>
<h4 id="-事故2异步事件丢失顾客投诉">🚫 <strong>事故2：异步事件丢失（顾客投诉）</strong></h4>
<pre><code class="language-java">@SpringBootApplication
@EnableAsync // 必须显式开启异步
public class Application {
@Bean("eventExecutor")
public Executor taskExecutor() {
// 关键参数：拒绝策略用CallerRunsPolicy（避免丢单）
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
return executor;
}
}
// 指定线程池执行
@Async("eventExecutor")
@EventListener
public void asyncHandle(OrderEvent event) {...}
</code></pre>
<h4 id="-事故3事件循环调用咖啡师卡死">🚫 <strong>事故3：事件循环调用（咖啡师卡死）</strong></h4>
<pre><code class="language-java">// 错误：在事件处理中发布新事件
@EventListener
public void handleA(EventA a) {
publisher.publishEvent(new EventB());
}
@EventListener
public void handleB(EventB b) {
publisher.publishEvent(new EventA()); // ♻️ 死循环！
}
</code></pre>
<hr>
<h3 id="四关键抉择监听器-vs-mq-架构对垒">四、关键抉择：监听器 vs MQ 架构对垒</h3>
<table>
<thead>
<tr>
<th><strong>维度</strong></th>
<th><strong>Spring监听器</strong></th>
<th><strong>MQ消息队列</strong></th>
</tr>
</thead>
<tbody>
<tr>
<td><strong>适用场景</strong></td>
<td>单机事务协作 ✅</td>
<td>跨服务通信 ✅</td>
</tr>
<tr>
<td><strong>可靠性</strong></td>
<td>进程宕机事件消失 ❌</td>
<td>持久化/重试 ✅</td>
</tr>
<tr>
<td><strong>吞吐量</strong></td>
<td>内存级传输，10w+/s 🚀</td>
<td>受网络限制，1w/s ⚠️</td>
</tr>
<tr>
<td><strong>开发效率</strong></td>
<td>免搭建MQ，注解即用 ✅</td>
<td>需部署中间件 ❌</td>
</tr>
<tr>
<td><strong>数据一致性</strong></td>
<td>本地事务保障 ✅</td>
<td>需分布式事务 ⚠️</td>
</tr>
</tbody>
</table>
<blockquote>
<p><strong>黄金决策树</strong>：</p>
<ul>
<li>同JVM事务操作 → <code>Spring监听器</code>（开发效率王炸）</li>
<li>跨服务最终一致 → <code>RocketMQ</code>（可靠性担当）</li>
</ul>
</blockquote>
<hr>
<h3 id="五性能调优监听器的涡轮增压">五、性能调优：监听器的涡轮增压</h3>
<ol>
<li>
<p><strong>异步喷射</strong>：</p>
<pre><code class="language-java">@Async // 方法级异步（线程池加速）
@EventListener
public void asyncProcess(LogEvent event) {...}
</code></pre>
</li>
<li>
<p><strong>条件过滤</strong>（减少无效处理）：</p>
<pre><code class="language-java">// 只处理VIP客户的订单
@EventListener(condition = "#event.user.level == 'VIP'")
public void handleVipOrder(OrderEvent event) {...}
</code></pre>
</li>
<li>
<p><strong>批量处理</strong>（Spring 4.2+特性）：</p>
<pre><code class="language-java">// 一次性处理整批订单（提升数据库IO效率）
@EventListener
public void batchProcess(List<OrderEvent> events) {
orderDao.batchInsert(events.stream().map(OrderConverter::toEntity).toList());
}
</code></pre>
</li>
</ol>
<hr>
<h3 id="六最佳实践5条生存法则">六、最佳实践：5条生存法则</h3>
<ol>
<li>
<p><strong>单一职责原则</strong><br>
<code>一个监听器只做一件事</code>：如 <code>PaymentListener</code> 只处理支付，<code>CouponListener</code> 只发券</p>
</li>
<li>
<p><strong>事件轻量化</strong><br>
禁止在事件中携带 <code>HttpSession</code> 等重型对象（建议只传ID）</p>
</li>
<li>
<p><strong>异常隔离舱</strong><br>
异步事件必须独立捕获异常：</p>
<pre><code class="language-java">@Async
@EventListener
public void handle(Event event) {
try {
businessLogic();
} catch (Exception e) {
// 记录日志 + 告警（防止雪崩）
log.error("事件处理失败: {}", event, e);
alarmManager.notify(e);
}
}
</code></pre>
</li>
<li>
<p><strong>版本兼容设计</strong><br>
事件类预留版本字段：</p>
<pre><code class="language-java">public class OrderEvent {
private final String version = "1.0"; // 未来可扩展
}
</code></pre>
</li>
<li>
<p><strong>监控三件套</strong></p>
<pre><code class="language-java">// 监控处理时长/失败率/QPS
@Around("@annotation(org.springframework.context.event.EventListener)")
public Object monitor(ProceedingJoinPoint pjp) {
Timer.Sample sample = Timer.start();
try {
return pjp.proceed();
} finally {
sample.stop(Metrics.timer("event.process.time"));
}
}
</code></pre>
</li>
</ol>
<hr>
<h3 id="结语事件驱动的艺术">结语：事件驱动的艺术</h3>
<blockquote>
<p>优秀架构的本质不是预测所有需求，而是拥抱变化。<br>
通过Spring事件监听器，我们将系统拆解为<strong>可插拔的乐高模块</strong>：</p>
<ul>
<li>新增功能时 → 添加监听器（无需修改核心代码）</li>
<li>流量暴增时 → 开启异步（无需重构架构）</li>
</ul>
<p>这恰如经营咖啡店的真谛：<br>
<strong>“不是雇佣更快的咖啡师，而是设计永不拥堵的协作机制”</strong></p>
<p><strong>程序员彩蛋</strong>：<br>
下回当你为需求变更焦头烂额时，不妨问问自己：<br>
<strong>“我的代码，像一家应对自如的咖啡店吗？”</strong></p>
</blockquote>
<hr>
<blockquote>
<p>技术选型建议：<strong>万级QPS以内首选Spring事件，超越则上MQ</strong></p>
</blockquote>
<hr>
<blockquote>
<p>文章的最后，想和你多聊两句。</p>
<p>技术之路，常常是热闹与孤独并存。那些深夜的调试、灵光一闪的方案、还有踩坑爬起后的顿悟，如果能有人一起聊聊，该多好。</p>
<p>为此，我建了一个小花园——我的微信公众号「<strong>[努力的小郑]</strong>」。</p>
<p>这里没有高深莫测的理论堆砌，只有我对后端开发、系统设计和工程实践的持续思考与沉淀。它更像我的<strong>数字笔记本</strong>，记录着那些值得被记住的解决方案和思维火花。</p>
<p>如果你觉得今天的文章还有一点启发，或者单纯想找一个同行者偶尔聊聊技术、谈谈思考，那么，欢迎你来坐坐。<br>
<img src="https://img2024.cnblogs.com/blog/3703499/202601/3703499-20260105210259813-964799315.jpg"></p>
<p>愿你前行路上，总有代码可写，有梦可追，也有灯火可亲。</p>
</blockquote><br><br>
来源：https://www.cnblogs.com/xzqcsj/p/19310278
頁:
[1]