消息队列RocketMQ、Kafka小计
Broker部署相对复杂,Broker分为Master与Slave,一个Master可以对应多个Slave,但是一个Slave只能对应一个Master,Master与Slave的对应关系通过指定相同的BrokerName,不同的BrokerId来定义,BrokerId为0表示Master,非0表示S
RocketMQ【高级特性、负载均衡 、事务消息 、消息查询】(三)-全面详解(学习总结---从入门到深化)
RocketMQ【高级特性、负载均衡 、事务消息、消息查询】(三)-全面详解(学习总结---从入门到深化)
四、RocketMQ的控制台安装
RocketMQ控制台
linux 安装 RocketMQ
RocketMQ 因其架构简单、业务功能丰富、具备极强可扩展性等特点被众多企业开发者以及云厂商广泛采用。历经十余年的大规模场景打磨,RocketMQ 已经成为业内共识的金融级可靠业务消息首选方案,被广泛应用于互联网、大数据、移动互联网、物联网等领域的业务场景。
flink 整合rocketmq
flink 整合 rocketmq
Spring Rocketmq 事务消息 @RocketMQMessageListener注解的使用
RocketMQMessageListener事务消息监听器。
【RocketMQ】RocketMQ快速入门
Metaq1.x是RocketMQ前身的第一个版本,本质上把Kafka做了一次java版本的重写(Kafka是scala语言开发)。Meta2.x,主要是对存储部分进行了优化,因为kafka的数据存储,它的partition是一个全量的复制,在阿里、在淘宝的这种海量交易。Kafka这种机制的横向拓展
RocketMQ常见问题及解决方案
RocketMQ FAQ1)消费端处理消息发生异常没有捕获或是因为其他原因,没有返回消费状态解决方案:消费端捕获异常,如果需要重试,返回ConsumeConcurrentlyStatus.RECONSUME_LATER,如果不需要重试,返回ConsumeConcurrentlyStatus.RECO
Windows下启动rocketMq
提示:本文章环境:rocketmq5.0.0、windows10、java8(请提前安装并配置好java环境)
大数据生态中的 RocketMQ 5.0
随着RocketMQ 5.0的发布,RocketMQ 在处理消息、事件和流上实现了统一,有了越来越强大的优势,存储和计算分离的特性也使其能提供更低的成本,使企业上云更省钱、更省力,也更省人力。
RocketMQ事务消息
RocketMQ 事务消息
RocketMQ 消费者Rebalance算法 解析——图解、源码级解析
📆 最近更新:2022年10月15日🍊 个人简介:通信工程本硕💪、Java程序员🌕。做过科研paper,发过专利,优秀的程序员不应该只是CRUD。
RocketMQ的单机安装以及启动
RocketMQ的单机安装以及启动
RocketMQ 消费者拉取消息(Pull) 解析——图解、源码级解析
📆 最近更新:2022年9月30日🍊 个人简介:通信工程本硕💪、Java程序员🌕。做过科研paper,发过专利,优秀的程序员不应该只是CRUD。
RocketMQ Push消息给消费者 解析——图解、源码级解析
文章目录概述Push消息消费流程开启消息消费接收消息概述RocketMQ中消费者有两种方式获得消息来消费:Push模式和Pull模式Push模式:服务端将消息推送到客户端Pull模式:客户端不断请求服务端,或许消息实际上这两种模式的底层实现都是采用的Consumer主动拉取消息的方式在Push方式里
RocketMQ源码(7)—Producer发送消息源码(1)—发送消息的总体流程【一万字】
基于RocketMQ 4.9.3,详细的介绍了Producer发送消息的总体流程的源码,包括生产者重试机制、生产者故障转移机制、VIP通道等知识都会一一介绍。
RocketMQ源码(6)—Producer生产者启动源码【一万字】
详细介绍了RocketMQ的客户端Producer生产者启动的源码。
RocketMQ 顺序消息解析——图解、源码级解析
优秀的程序员不应该只是CRUD
RocketMQ源码(4)—Broker与NameServer的心跳服务源码
详细介绍了RocketMQ的Broker与NameServer的心跳服务源码。
全站最硬核 百万字强肝RocketMq源码 火热更新中~(一百一十二)NameSrv的作用及高性能顺序写盘
Namesrv就是一个注册中心,存储当前集群所有Brokers信息、Topic跟Broker的对应关系。Namesrv用于存储Topic、Broker关系信息,功能简单,稳定性高。多个Namesrv之间相互没有通信,单台Namesrv宕机不影响其他Namesrv与集群;即使整个Namesrv集群宕机