背景相信大家看到这个文章对消息服务器已经不陌生了，笔者也是在平日无聊想着自己编写一套关于RockerMQ的消息灰度框架的时候，准备本地搭建一个RockerMQ服务环境时遇到了一个头疼的问题。在执行RockerMQ官网的Topic创建的时候（shbin/mqadminupdatetopic-nlocalhost:9876-tTestTopic），出现了报错 /Library/Internet:Nosuchfileordirectory。报错分析在整个启动rockermq的NameServer和Broker的时候都是很顺利的，只是 bin/mqadminupdatetopic执行命令报错，报错内容
背景相信大家看到这个文章对消息服务器已经不陌生了，笔者也是在平日无聊想着自己编写一套关于RockerMQ的消息灰度框架的时候，准备本地搭建一个RockerMQ服务环境时遇到了一个头疼的问题。在执行RockerMQ官网的Topic创建的时候（shbin/mqadminupdatetopic-nlocalhost:9876-tTestTopic），出现了报错 /Library/Internet:Nosuchfileordirectory。报错分析在整个启动rockermq的NameServer和Broker的时候都是很顺利的，只是 bin/mqadminupdatetopic执行命令报错，报错内容
大家好，我是三友，我又来了~~最近仍然畅游在RocketMQ的源码中，这几天刚好翻到了消费者的源码，发现RocketMQ的对于push消费方式的实现简直太聪明了，所以趁着我脑子里还有点印象的时候，赶紧来写一篇文章，来掰扯一下，防止过两天就忘得一干二净了。MQ消费方式消费方式就是指消费者如何从MQ中获取到消息，分为两种方式，push（推方式）和pull（拉方式）。1、push（推方式）push，顾名思义，就是推的意思。就是当MQ收到生产者产生的消息的时候，会主动将消息推送到消费者进行消费，这种模式就叫push，也就是MQ将消息推给到消费者的意思。push模式push这种模式的好处就是响应快，消息
大家好，我是三友，我又来了~~最近仍然畅游在RocketMQ的源码中，这几天刚好翻到了消费者的源码，发现RocketMQ的对于push消费方式的实现简直太聪明了，所以趁着我脑子里还有点印象的时候，赶紧来写一篇文章，来掰扯一下，防止过两天就忘得一干二净了。MQ消费方式消费方式就是指消费者如何从MQ中获取到消息，分为两种方式，push（推方式）和pull（拉方式）。1、push（推方式）push，顾名思义，就是推的意思。就是当MQ收到生产者产生的消息的时候，会主动将消息推送到消费者进行消费，这种模式就叫push，也就是MQ将消息推给到消费者的意思。push模式push这种模式的好处就是响应快，消息
1、RocketMQ安装测试1.1下载解压下载地址：https://rocketmq.apache.org/release-notes/rocketmq-all-5.0.0-bin-release.zip下载后上传到服务器；解压命令#unziprocketmq-all-5.0.0-bin-release.zip1.2启动测试RocketMQ默认配置是比较好的，这样可以直接应用于生产环境，所以如果机器内存较小，启动会因为内存不足失败，为了避免后面启动失败，选择先修改其内存大小，一般阿里云服务器是满足不了默认内存。手动调整JVM的配置，单位从g改为m1.2.1启动nameserver1.2.1.1
1、RocketMQ安装测试1.1下载解压下载地址：https://rocketmq.apache.org/release-notes/rocketmq-all-5.0.0-bin-release.zip下载后上传到服务器；解压命令#unziprocketmq-all-5.0.0-bin-release.zip1.2启动测试RocketMQ默认配置是比较好的，这样可以直接应用于生产环境，所以如果机器内存较小，启动会因为内存不足失败，为了避免后面启动失败，选择先修改其内存大小，一般阿里云服务器是满足不了默认内存。手动调整JVM的配置，单位从g改为m1.2.1启动nameserver1.2.1.1
安装服务器需要开放9876、10909、10911三个端口下载二进制包：RocketMQ并解压到指定目录启动#启动namesrv$nohupshbin/mqnamesrv&#验证namesrv是否启动成功$tail-f~/logs/rocketmqlogs/namesrv.logTheNameServerbootsuccess...#先启动broker$nohupshbin/mqbroker-nlocalhost:9876&#验证broker是否启动成功,比如,broker的ip是192.168.1.2然后名字是broker-a$tail-f~/logs/rocketmqlogs/Bro
安装服务器需要开放9876、10909、10911三个端口下载二进制包：RocketMQ并解压到指定目录启动#启动namesrv$nohupshbin/mqnamesrv&#验证namesrv是否启动成功$tail-f~/logs/rocketmqlogs/namesrv.logTheNameServerbootsuccess...#先启动broker$nohupshbin/mqbroker-nlocalhost:9876&#验证broker是否启动成功,比如,broker的ip是192.168.1.2然后名字是broker-a$tail-f~/logs/rocketmqlogs/Bro
大家好，我是三友~~这篇文章我准备来聊一聊RocketMQ消息的一生。不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑：消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高可用的？消息是在什么时候会被清除？...本文就通过探讨上述问题来探秘消息在RocketMQ中短暂而又精彩的一生。如果你还没用过RocketMQ，可以看一下这篇文章RocketMQ保姆级教程核心概念NameServer：可以理解为是一个注册中心，主要是用来保存topic路由信息，管理Broker。在NameServe
大家好，我是三友~~这篇文章我准备来聊一聊RocketMQ消息的一生。不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑：消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高可用的？消息是在什么时候会被清除？...本文就通过探讨上述问题来探秘消息在RocketMQ中短暂而又精彩的一生。如果你还没用过RocketMQ，可以看一下这篇文章RocketMQ保姆级教程核心概念NameServer：可以理解为是一个注册中心，主要是用来保存topic路由信息，管理Broker。在NameServe
