RocketMQ学习记录-----安装和启动RocketMQ以及可视化控制台
这篇文章仅用来记录如何在Linux环境下安装RocketMQ，方便下次要再次安装可以快速找到教程。同时记录了在安装过程中可能出现的问题。本文下载的是4.4.0版本的RocketMQ。需要环境：CentOS6系统，JDK1.8+（配置好$JAVA_HOME），Maven 3.2+。1、下载安装包，从官...
org.apache.rocketmq.remoting.exception.RemotingConnectException rocketmq控制台网络连接异常
使用docker安装rocketmq 控制台， 控制台报了如上面异常信息上面事没有问题的，已经解决，店家添加或者其他操作都会弹出网络链接异常。这是由于控制台连接nameservere连接异常，由于之前我的这个控制台是好好的，很久没有用了，不知怎么的nameserveradress变了，创建rocke...
RocketMQ如何处理消息丢失的问题,同步刷盘，异步刷盘，异步复制，同步双写
RocketMQ 消息持久化生产者向RocketMQ broker发送消息mq收到消息以后，会将消息持久化到硬盘，这样才能保证机器宕机重启后消息不丢失，仍然可以给消费者进行消费。这里有两种刷盘策略：同步刷盘、异步刷盘同步刷盘：也就是mq收到消息后，必须将消息持久化到硬盘以后才向Producer端返回...
Grafana+Promethues配置RocketMQ监控
背景 接前文，Promethues已经配置完毕，下面通过导入的Grafana的面板来配置RocketMQ监控页面 Dashboard 这里我们直接使用Grafana现成的面板配置 node_exporter：https://grafana.com/grafana/dashboards/1860 ro...
RocketMQ系列：rocketmq的运维控制台FAQ（陆续补充ing）
这里汇总rocketmq的控制台的一些常见问题： 1. consumer group这里TPS只显示master节点的消息TPS，如果是master-slave模式，从slave消费的TPS不会显示在这里。所以实际显示的TPS小于真实的TPS 2. 删除某个topic后，之前已经从topic消费的消...
RocketMQ——RocketMQ与JMS的辨析（杂谈）
RocketMQ其实不怎么遵循JMS标准NameServer用于收集其他角色的信息，里面存了许多列表，用于保存各角色的信息，Producer发送和Consumer消费信息都不直接与Broker打教导，而是先向NameServer询问具体要发往和消费的Topic在哪，回NameServer向二者返回该...
docker安装启动rocketMQ遇到的坑 broker内网
我用的镜像安装, 1 docker search rocketmq我拉取的是图中的第三个.启动nameserver命令docker run -d -p 9876:9876 --name rmqserver foxiswho/rocketmq:server-4.5.1启动broker命令docker ...
Spring Cloud Stream应用与自定义RocketMQ原理解析
概述Spring Cloud Stream 简介Spring Cloud Stream 是一个用来为微服务应用构建消息驱动能力的框架。它可以基于Spring Boot 来创建独立的，可用于生产的Spring 应用程序。他通过使用Spring Integration来连接消息代理中间件以实现消息事件驱...
搭建RocketMQ踩的坑- No name server address
1、按照apache官网的Simple Message Example，来写报错No name server address 推荐直接按照官网把源码下载下来，上面有例子官网贴出来的是缩略版 要知道namesrvAddr, producer.setNamesrvAddr(“192.168.0.103:...
RocketMQ安装部署所踩过最全的坑
我相信这篇文章应该是所有首次安装RocketMQ的人所踩过最全的坑。写在前面今天分享的这篇文章，可以说，绝对有用。因为我今天在安装RocketMQ时被整整搞了一个早上。太浪费时间了。而且网上关于这方面的资料太简单了。根据他们的步骤基本上都是以失败而告终的。在此，我想说（虽然我还是ＩＴ领域的一个小白）...
RocketMQ可视化工具RocketMQ-Console搭建实践
为方便测试，我基于Win10 64系统安装了RocketMQ(安装方法详见“RocketMQ 在win10 64安装遇到的问题及解决实践”)。研发测试时可以安装RocketMQ可视化工具RocketMQ-Console，利于观察。方法是1、从https://github.com/apache/roc...
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...