rocketMQ之一 应用场景和优缺点
应用场景及其优缺点应用场景应用解耦系统耦合性越高,容错性越低,如果都是直线操作,其中一个部位出问题,整个流程都走不下去如果使用mq,即使其中流程的一部分出问题,只要mq里面数据还在.等到流程恢复的时候,就可以重新走属于自己的一部分,而不会导致其他流程的部分也阻塞流量削峰如果每次访问都是直接连接到应用...
消息队列：rocketmq使用集群模式模拟广播
适用场景适用于每条消息都需要被多台机器处理，每台机器的逻辑可以相同也可以不一样的场景。具体消费示例如下图所示。如果业务需要使用广播模式，也可以创建多个 Group ID，用于订阅同一个 Topic。注意事项消费进度在服务端维护，可靠性高于广播模式。对于一个 Group ID 来说，可以部署一个消费者...
揭秘 RocketMQ 新特性以及在金融场景下的实践
2019 年末， RocketMQ 正式发布了 4.6.0 版本，增加了“ Request-Reply ”的同步调用的新特性。“ Request-Reply ”这个新特性是由微众银行的开发者们总结实践经验，并反馈给社区的。接下来本文会详细介绍此新特性。“ Request-Reply ”是什么图1.1...
常用消息队列rocketmq、rabbitmq、kafka、activemq对比
rocketmq、rabbitmq、kafka、activemq对比 随着互联网“微架构”模式兴起，原有大型集中式的IT服务被分拆成细粒度的多个“微服务”，这些微服务可以在一个局域网内，也可能跨机房部署。一方面对服务之间松耦合的要求越来越高，另一方面，服务之间的联系却越来越紧密，对通信质量的要求也...
rabbitMq、rocketmq、kafaka对比 Rocketmq和Kafka区别
rabbitMq、rocketMq、kafaka适用场景对比架构方面：可靠性：Kafaka是正常的mq架构，包括provider broker consumer。k...
如何实现RabbitMQ、kafaka、rocketmq等消息队列的消息有序-如何rocketmq的消息有序
RocketMQ 提供了一种简单而有效的方法来确保消息的有序性，即通过消息队列中的顺序消费。以下是实现 RocketMQ 消息有序性的基本思路： undefined 消息发送有序性：在发送消息时，可以为每条消息设置一个自定义的 key（例如订单号、用户ID等），保证同一个 key 的消息会被发送到...
RocketMQ架构详解
文章目录 概述RocketMQ架构Broker 高可用集群刷盘策略 概述 RocketMQ一个纯java、分布式、队列模型的开源消息中间件，前身是MetaQ，是阿里研发的一个队列模型的消息中间件，后开源给apache基金会成为了apache的顶级开源项目，具有高性能、高可靠、高实时、分布式...
rocketMq指定broker ip地址，适合解决云主机部署问题
在工作中遇到了一个这个问题，就是我们rocketmq是部署在云主机上的但是我们的开发同事在自己的电脑连接rocketmq链接不上报错显示Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connec...
Rocketmq 入门介绍
从零手写实现 mq 详细介绍一下 rocketmq RocketMQ 是由阿里巴巴开发的分布式消息队列系统，它是一个低延迟、高可靠、高吞吐量的消息中间件。 RocketMQ 最初是作为阿里巴巴的内部项目进行开发的，后来成为了 Apache 软件基金会下的顶级项目，以 Apache 许可证 2....
rocketmq启动broker内存占用过大的问题
解决方法：修改broker启动脚本runbroker.sh里面的jvm参数JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g"改为JAVA_OPT="${JAVA_OPT} -server -Xms128m -...
RocketMQ消息队列（下）
RocketMQ 基本概念 RocketMQ主要有四大核心组成部分：NameServer、Broker、Producer以及Consumer 四部分。这些角色通常以集群的方式存在，RocketMQ 基于纯Java开发，具有高吞吐量、高可用性、适合大规模分布式系统应用的特点。 对于RocketMQ 而...
分布式事务(3)---RocketMQ实现分布式事务原理
分布式事务(3)—RocketMQ实现分布式事务原理 之前讲过有关分布式事务2PC、3PC、TCC的理论知识,博客地址：1、分布式事务(1)---2PC和3PC原理2、分布式事务(2）---TCC原理这篇讲有关RocketMQ实现分布式事务的理论知识，下篇也会示例 通过SpringCloud来实例R...
RocketMQ(七)：高性能探秘之线程池
上一篇文章讲了如何设计和实现高并发高性能的应用，从根本上说明了一些道理。且以rocketmq的mappedFile的实现作为一个突破点，讲解了rocketm...
RocketMQ入门
RocketMQ简介RocketMQ基本概念RocketMQ安装运行wusi@wusi-virtual-machine:~/桌面$ sudo wget https:...
【RocketMQ源码分析】深入消息存储（2）
前文回顾CommitLog篇 ——【RocketMQ源码分析】深入消息存储（1）MappedFile篇 ——【RocketMQ源码分析】深入消息存储（3）前文说完了...
从RocketMQ的Broker源码层面验证一下这两个点
本篇博客会从源码层面，验证在RocketMQ基础概念剖析，并分析一下Producer的底层源码中提到的结论，分别是：Broker在启动时，会将自己注册到所有的Nam...
Rocketmq学习4——Broker消息持久化原理源码浅析
一丶前言在《Rocketmq学习3——消息发送原理源码浅析》中，我们学习了消息发送的要点：本地缓存+rpc 请求namesever + 定时刷新，topic路由信息负载均衡的选择一个Broker进行发送，还支持【故障转移（即支持规避短时间内发送失败的broker）】基于netty实现的rpc进行消息...
rocketMq 消息偏移量 Offset
消息偏移量 Offsetqueue0offset 0 0-20 offset 4 20-40纠错：每条消息的tag对应的HashCode.queue...
RocketMQ源码分析 broker启动，commitlog、consumequeue、indexfile、MappedFileQueue、MappedFile之间的关系以及位置说明
目录1.MappedFile类属性说明1.1.MappedFile类属性如下1.2.MappedFile构造器说明2.MappedFileQueue类说明2...
消息队列 ActiveMQ 、RocketMQ 、RabbitMQ 和 Kafka 如何选择？
「 预计阅读 6 分钟 」旁白：这是一篇拖更了N久的文章...0.0（看不见我~）往期回顾前端框架 jQuery 和 Vue 如何选择？安全框架 Shiro 和 Spring Security 如何选择？正文 消息队列（MQ）在百度百科中，消息队列（MQ）是这么解释的：“消息队列”是在消息...