如何实现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）是这么解释的：“消息队列”是在消息...
rocketmq学习(二) rocketmq集群部署与图形化控制台安装
1.rocketmq图形化控制台安装虽然rocketmq为用户提供了使用命令行管理主题、消费组以及broker配置的功能，但对于不够熟练的非运维人员来说，命令行的管理界面还是较难使用的。为此，我们可以使用图形化的管理界面来简化管理操作。rocketmq官方推荐的图形化控制台目前还处在不成熟的孵化阶段...
Spring Cloud异步场景分布式事务怎样做？试试RocketMQ
一、背景在微服务架构中，我们常常使用异步化的手段来提升系统的 吞吐量 和 解耦 上下游，而构建异步架构最常用的手段就是使用 消息队列(MQ)，那异步架构怎样才能实现...
rocketMQ部署
rocketMQ部署(单机) 1、 环境：CentOS7 64 & JDK1.8+ 64 & 用户:www2、 下载binary文件包：wget http://mirror.rise.ph/apache/rocketmq/4.3.0...
RocketMQ(2)---Docker部署RocketMQ集群
RocketMQ(2)—Docker集群部署RocketMQ =前言=1、因为自己只买了一台阿里云服务器，所以RocketMQ集群都部署在单台服务器上只是端口不同，如果实际开发，可以分别部署在多台服务器上。2、这里有关 Broker 和 NameServer 分别都做了了集群部署(各部署两个），且B...
RocketMQ快速入门
前面几篇文章介绍了为什么选择RocketMQ，以及与kafka的一些对比： 阿里 RocketMQ 优势对比，方便大家对于RocketMQ有一个简单的整体了解，之后介绍了：MQ 应用场景，让我们知道MQ在什么时候可以使用，可以解决什么问题，之后介绍了：RocketMQ集群部署配置；本篇文章接着上篇内...