源码分析RocketMQ之消息消费重试机制
本文主要关注业务方在消息消费失败后，返回ConsumeConcurrentlyStatus.RECONSUME_LATER,专业术语：业务方每条消息消费后要告诉MQ消费者一个结果(ack,message back)，触发MQ消息消费重试机制，然后MQ消费者需要反馈给MQ(Broker)本文主要针对的...
RocketMQ源码解析之消息生产者（异步发送）
1.前言我们在《RocketMQ源码解析之消息生产者（同步发送与单向发送）》一文中解析了RocketMQ生产者同步发送消息与单向发送消息，这个异步发送消息其实很多地方与同步发送一样，不过有一点是你在编程的时候需要提供SendCallback 对象，用来发送响应来的时候进行回调使用，我们知道同步发送是...
阿里技术行 | Apache RocketMQ 首届开发者沙龙报名启动！
RocketMQ是阿里巴巴在2012年开源的第三代分布式消息引擎，由阿里中间件（Aliware）团队维护。2016年11月28日，阿里巴巴宣布将开源分布式消息引擎RocketMQ捐赠给Apache基金会，成为Apache 孵化项目。7月1日，阿里技术行走进北京，带你与阿里中间件大牛零距离接触！本次活...
rocketmq 同步刷盘和异步刷盘以及主从复制之同步复制和异步复制你理解了吗
同步刷盘、异步刷盘RocketMQ的消息是存储到磁盘上的，这样既能保证断电后恢复，又可以让存储的消息量超出内存的限制。RocketMQ为了提高性能，会尽可能地保证磁盘的顺序写。消息在通过Producer写入RocketMQ的时候，有两种写磁盘方式：1）异步刷盘方式：在返回写成功状态时，消息可能只是...
rocketmq控制台搭建（rocketmq-console）
背景：我通过mq发送数据，消费者没有消费到，为了查看mq的消费记录1. 下载开源的rocketmq-externals项目https://github.com/apache/rocketmq-externals2. 找到rocketmq-console，先编辑一下rocketmq-console里面...
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...