0

0

Java中Apache中Event模型在高并发实时系统中的表现

舞姬之光

舞姬之光

发布时间:2026-03-14 17:55:03

|

279人浏览过

|

来源于php中文网

原创

Apache Commons Event模型是单线程同步的轻量级观察者实现,不适用于高并发实时系统,因其无异步分发、无并发安全、无事件缓冲与失败恢复能力。

apache commons event模型(如eventsupport)本质上是单线程、同步、基于观察者模式的轻量级事件通知机制,**不适合高并发实时系统**。它没有内置线程安全设计、无异步分发能力、无背压控制、也缺乏事件持久化或失败重试机制,直接用于高并发场景极易引发阻塞、丢失事件、线程竞争甚至系统雪崩。

同步调用导致线程阻塞

默认情况下,事件发布(fireEvent)会**逐个同步调用所有注册监听器**。若某个监听器执行耗时(如IO、远程调用、复杂计算),整个事件分发线程会被卡住,后续事件积压,吞吐量骤降。

  • 监听器中避免任何阻塞操作(如数据库查询、HTTP请求)
  • 如必须异步处理,需手动将逻辑提交到线程池(如CompletableFuture.runAsync()),但需自行管理异常和生命周期
  • 不建议在监听器中启动新线程——易造成资源泄漏和难以监控

缺乏线程安全性与并发控制

EventSupport内部使用ArrayList存储监听器,添加/移除监听器及事件分发过程均未加锁。在多线程频繁注册、注销监听器的场景下,可能抛出ConcurrentModificationException或产生不可预期的行为。

  • 监听器注册/注销应尽量在系统初始化阶段完成,运行期避免动态变更
  • 若必须动态管理,需外部加锁(如synchronized块或ReentrantLock)保护add/removeListener调用
  • 不可依赖其“线程安全”——它根本不是为并发设计的

无事件缓冲、无失败恢复、无监控能力

该模型是纯内存、即发即弃的:事件一旦发布,成功与否完全取决于监听器是否执行完毕;没有队列缓冲、没有重试、没有死信处理、也没有事件计数或耗时统计。

意兔-AI漫画相机
意兔-AI漫画相机

照片变漫画手绘,做周边好物

下载
  • 实时性要求高的系统需要可追溯、可重放、可限流的事件管道(如Kafka + Kafka Streams、RabbitMQ + Spring AMQP)
  • 关键业务事件建议走消息中间件,而非内存事件总线
  • 如坚持用内存事件,至少包装一层带日志记录和异常捕获的代理监听器

替代方案更契合高并发实时需求

真实高并发实时系统(如交易风控、实时推荐、IoT设备联动)普遍采用成熟事件驱动架构(EDA),而非Apache Commons Event:

立即学习Java免费学习笔记(深入)”;

  • 消息中间件:Kafka(高吞吐、分区有序、持久化)、Pulsar(多租户、分层存储)、RocketMQ(事务消息、定时延迟)
  • 响应式框架:Project Reactor(Flux/Mono)、RxJava,支持非阻塞背压、异步编排、错误恢复
  • 专用事件总线:Spring Event(配合@Async和线程池)、Axon Framework(CQRS+Event Sourcing)

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

161

2025.08.06

Java Spring Security 与认证授权
Java Spring Security 与认证授权

本专题系统讲解 Java Spring Security 框架在认证与授权中的应用,涵盖用户身份验证、权限控制、JWT与OAuth2实现、跨站请求伪造(CSRF)防护、会话管理与安全漏洞防范。通过实际项目案例,帮助学习者掌握如何 使用 Spring Security 实现高安全性认证与授权机制,提升 Web 应用的安全性与用户数据保护。

89

2026.01.26

rabbitmq和kafka有什么区别
rabbitmq和kafka有什么区别

rabbitmq和kafka的区别:1、语言与平台;2、消息传递模型;3、可靠性;4、性能与吞吐量;5、集群与负载均衡;6、消费模型;7、用途与场景;8、社区与生态系统;9、监控与管理;10、其他特性。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

207

2024.02.23

Java 消息队列与异步架构实战
Java 消息队列与异步架构实战

本专题系统讲解 Java 在消息队列与异步系统架构中的核心应用,涵盖消息队列基本原理、Kafka 与 RabbitMQ 的使用场景对比、生产者与消费者模型、消息可靠性与顺序性保障、重复消费与幂等处理,以及在高并发系统中的异步解耦设计。通过实战案例,帮助学习者掌握 使用 Java 构建高吞吐、高可靠异步消息系统的完整思路。

49

2026.01.28

什么是中间件
什么是中间件

中间件是一种软件组件,充当不兼容组件之间的桥梁,提供额外服务,例如集成异构系统、提供常用服务、提高应用程序性能,以及简化应用程序开发。想了解更多中间件的相关内容,可以阅读本专题下面的文章。

184

2024.05.11

Golang 中间件开发与微服务架构
Golang 中间件开发与微服务架构

本专题系统讲解 Golang 在微服务架构中的中间件开发,包括日志处理、限流与熔断、认证与授权、服务监控、API 网关设计等常见中间件功能的实现。通过实战项目,帮助开发者理解如何使用 Go 编写高效、可扩展的中间件组件,并在微服务环境中进行灵活部署与管理。

226

2025.12.18

kafka消费者组有什么作用
kafka消费者组有什么作用

kafka消费者组的作用:1、负载均衡;2、容错性;3、广播模式;4、灵活性;5、自动故障转移和领导者选举;6、动态扩展性;7、顺序保证;8、数据压缩;9、事务性支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

175

2024.01.12

kafka消费组的作用是什么
kafka消费组的作用是什么

kafka消费组的作用:1、负载均衡;2、容错性;3、灵活性;4、高可用性;5、扩展性;6、顺序保证;7、数据压缩;8、事务性支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

159

2024.02.23

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

49

2026.03.13

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号