消息中间件

首页 标签 消息中间件
# 消息中间件 #
关注
28628内容
RocketMQ:底层Netty频繁OS OOM
本文分析了一起RocketMQ应用因底层Netty频繁申请堆外内存导致OS OOM的问题。根本原因为多个ClassLoader加载了多个Netty的PooledByteBufAllocator实例,各自独立占用堆外内存,绕过JVM的MaxDirectMemorySize限制,最终导致系统内存耗尽。通过Arthas排查发现总占用远超配置,建议短期调小Java堆以腾出空间,并推动中间件优化内存使用。
|
2月前
|
系统预警专题(语音通知)
适用于科技公司服务器或物联网设备异常时的语音告警通知。开通语音服务后,可申请资质、话术、模板与号码,通过API调用实现自动外呼,支持变量替换与呼叫记录查询,提升运维响应效率。(238字)
|
2月前
|
阿里生产故障专题06
本文排查了一例RocketMQ应用因Netty频繁申请堆外内存导致OS OOM的问题。根本原因为多个ClassLoader加载了多个Netty的PooledByteBufAllocator实例,各自独立占用堆外内存,总使用量远超MaxDirectMemorySize限制。虽单个Allocator受1G限制,但7个实例叠加致整体超限,且Netty通过Unsafe直接分配内存,绕过JVM管控,最终引发系统级OOM。
|
2月前
|
应用架构图
技术架构是将业务需求转化为技术实现的关键过程,涵盖分层设计、技术选型与系统集成。包括单体架构的四层模型(表现、业务、数据、基础)与分布式架构下的服务调用关系,明确内外系统边界,支撑应用高效协同与扩展。
异步消息组件MQ高级
本文详细讲解了消息队列(RabbitMQ)的可靠性保障机制,涵盖生产者重试与确认、消费者确认、消息持久化、幂等性处理及延迟消息等核心方案,并通过自动取消超时订单场景实践,确保消息不丢失、不重复、最终一致。
微服务核心组件:消息中间件(MQ)从入门到实战
本章深入讲解微服务中消息中间件的核心作用,聚焦RabbitMQ与SpringAMQP实战。涵盖同步与异步通信对比、MQ选型分析,通过Docker快速部署RabbitMQ,详解生产者/消费者模型、四种消息模式(简单队列、工作队列、发布订阅、通配符路由),并引入prefetch优化与JSON序列化提升性能。结合注解驱动开发,全面掌握高可用、低耦合的异步通信架构设计。(239字)
RocketMQ:底层Netty频繁OS OOM
本文记录了一例Java应用因多ClassLoader加载多个Netty的PooledByteBufAllocator导致堆外内存超限、触发OS OOM的排查过程。通过NMT、Arthas等工具分析,发现7个不同类加载器各自维护堆外内存配额,绕过JVM直接内存管控,最终总占用远超MaxDirectMemorySize设置。建议短期调整堆大小以保障可用性,长期推动中间件优化。
RocketMQ:A2A协议实现多智能体优化
Apache RocketMQ推出LiteTopic轻量级通信模型,结合A2A协议与AgentScope框架,为多智能体系统提供高可靠、低延迟的异步通信方案,支持会话持久化、断点续传与动态协同,助力AI应用构建稳定高效的协作基座。
免费试用