兼容Apache RocketMQ的高性能消息队列
在我们熟知的Kafka、RabbitMQ等消费队列中,都没有实现事务消息这个功能,RocketMQ是唯一实现了这一功能的消息队列中间件,今天我们来从底层看一下R...
RocketMQ作为消息队列的典型代表,其在高并发状况下处理消息又很不错的性能,同时又能够通过将消息持久化到磁盘确保消息不会丢失,本文旨在从RocketMQ的源...
在日常处理高并发的业务需求时,为了优化执行效率,我们会将一个业务拆分成几个部分,通过消息队列异步执行任务来提高业务执行效率,而消息队列除了我们知道的Kafka、...
在分布式系统中,通信是关键环节,而消息队列在此扮演着至关重要的角色,尤其是在处理异步通信和削峰填谷方面。随着业务量的增长和请求量的激增,消息队列逐渐成为设计复杂...
在分布式系统中由于相关联的多个服务所在的数据库互相隔离,数据库无法使用本地事务来保证数据的一致性,因此需要使用分布式事务来保证数据的一致性
如果不使用保证顺序的手段,由于多队列、网络等因素可能会导致先处理支付订单的消息再处理创建订单的消息,这样就会导致处理失败
这里推荐一篇有关Java 集合Fail-Fast、Fail-Safe机制的文章:深入Java集合框架:解密List的Fail-Fast与Fail-Safe机制 ...
这里推荐一篇JVM垃圾回收相关的文章:深入解析Java垃圾回收机制:原理、实现与优化策略 文章阐述了JVM垃圾回收的基本概念、机制以及设计原理,总结垃圾回收的算...
这里推荐一篇Java Optional的文章:深入探讨 Java 8 的 Optional:提高代码安全性与可读性 文章列举Java Optional的用法,优...
这里推荐一篇Java语法糖的文章:Java 语法糖:让开发更丝滑的“幕后操作” 文章列举常用的Java语法糖并分析优劣点,让我们的开发更加丝滑~
在计算机科学领域,队列是一种常见的数据结构,用于在多线程或多进程环境中进行有效的消息传递和任务调度。然而,传统的队列实现通常使用锁来保护共享资源,这可能导致性能...
上篇文章从Broker接收消息开始,到消息持久化到各种文件结束,分析完消息在Broker持久化的流程与原理
上篇文章我们分析完RocketMQ发送消息的原理,得到结果客户端会通过RPC组件向Broker进行通信
上篇文章主要介绍消息中间件并以RocketMQ架构展开描述其核心组件以及MQ运行流程
在队列的基础上,加入生产者与消费者模型,使用队列作为载体就能够组成简单的消息队列,在队列中“运输”的数据被称为消息
官方文档: https://rocketmq.apache.org/zh/docs/introduction/02concepts
有了NameServer,生产者和消费者只需要通过NameServer建立连接无需关心BrokerServer.类似Spring Cloud中注册中心和服务之间...
1、启动NameServer 安装完RocketMQ包后,我们启动NameServer