rocketmq:connect to 172.17.42.1:10911 failed这个问题可能和我一样
这个原因网上说了很多。比如说在config/broker.conf配置文件中添加： brokerIP1=服务器地址 namesrvAddr =服务器地址:9876 重点：但是上面的都试过了，不行。于是我ping了下服务器IP，发现ping 不通。就把IP加入到了白名单里，才可以。...
消息队列比较-rabbitmq/kafka/rocketmq/ONS
主要是比较这几种队列中间件：rabbitmqkafkarocketmqONS分以下几个维度来比较高并发毫无疑问KAFKA发消息的速度是最快的ROCKETMQ/ONS次之rabbitmq最慢高可用这几种都能做MASTER/SLAVE，跨机房的高可用KAFKA复制有很多坑，所以这个分数要降低所需要的节点...
Win10搭建rocketmq遇到的问题及解决办法
由于项目需要与第三方交互，而第三方提供得对接方式是rocketmq，所以开始了熟悉rocketmq-搭建环境-写代码之路。按照网上的一些教程启动NAMESERVER，启动BROKER都没问题，但是到了编译rocketmq-console就出了问题：1.cmd提示mvn不是内部命令，因为我是个java...
rocketmq 自动创建topic源码分析
默认情况下，topic不用手动创建，当producer进行消息发送时，会从nameserver拉取topic的路由信息，如果topic的路由信息不存在，那么会默认拉取broker启动时默认创建好名为“TBW102”的Topic。TBW102这个topic在自动创建队列中比较重要，开启自动创建topi...
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...