时间戳

首页 > 技术文章 > RocketMQ的单节点环境搭建

RocketMQ的单节点环境搭建

niCong 2022-05-30 22:28 原文

1 介绍
RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。

1.1 RocketMQ 特点
支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型

在一个队列中可靠的先进先出（FIFO）和严格的顺序传递 （RocketMQ可以保证严格的消息顺序，而ActiveMQ无法保证）

支持拉（pull）和推（push）两种消息模式

pull其实就是消费者主动从MQ中去拉消息，而push则像rabbit MQ一样，是MQ给消费者推送消息。但是RocketMQ的push其实是基于pull来实现的。
它会先由一个业务代码从MQ中pull消息，然后再由业务代码push给特定的应用/消费者。其实底层就是一个pull模式

单一队列百万消息的堆积能力 （RocketMQ提供亿级消息的堆积能力，这不是重点，重点是堆积了亿级的消息后，依然保持写入低延迟）

支持多种消息协议，如 JMS、MQTT 等

分布式高可用的部署架构,满足至少一次消息传递语义（RocketMQ原生就是支持分布式的，而ActiveMQ原生存在单点性）

提供 docker 镜像用于隔离测试和云集群部署

提供配置、指标和监控等功能丰富的 Dashboard

1.2 RocketMQ 优势
目前主流的 MQ 主要是 RocketMQ、kafka、RabbitMQ，其主要优势有：

支持事务型消息（消息发送和 DB 操作保持两方的最终一致性，RabbitMQ 和 Kafka 不支持）
支持结合 RocketMQ 的多个系统之间数据最终一致性（多方事务，二方事务是前提）
支持 18 个级别的延迟消息（Kafka 不支持）
支持指定次数和时间间隔的失败消息重发（Kafka 不支持，RabbitMQ 需要手动确认）
支持 Consumer 端 Tag 过滤，减少不必要的网络传输（即过滤由MQ完成，而不是由消费者完成。RabbitMQ 和 Kafka 不支持）
支持重复消费（RabbitMQ 不支持，Kafka 支持）
2 RocketMQ 基本概念
RocketMQ主要有四大核心组成部分：NameServer、Broker、Producer以及Consumer四部分

 

 

2.1 NameServer
Name Server是一个几乎无状态节点，可集群部署，节点之间无任何信息同步。

NameServer 是整个 RocketMQ 的“大脑” ，它是 RocketMQ 的服务注册中心，所以 RocketMQ 需要先启动 NameServer 再启动 Rocket 中的 Broker。

2.1.1 NameServer作用
名称服务器（NameServer）用来保存 Broker 相关元信息并给 Producer 和 Consumer 查找Broker 信息。NameServer 被设计成几乎无状态的，可以横向扩展，节点之间相互之间无通信，通过部署多台机器来标记自己是一个伪集群。

每个 Broker 在启动的时候会到 NameServer 注册，Producer 在发送消息前会根据 Topic 到NameServer 获取到 Broker 的路由信息，进而和Broker取得连接。Consumer 也会定时获取 Topic 的路由信息。所以从功能上看应该是和 ZooKeeper 差不多，据说 RocketMQ 的早期版本确实是使用的ZooKeeper ，后来改为了自己实现NameServer

 

rocketmq 的官网  https://rocketmq.apache.org/docs/quick-start/ 要学习或者需要搭建环境的可以提前看一下

按照官网的命令来就不会有太大的问题

前提：

更多细节：

Prerequisite

The following softwares are assumed installed:

  1. 64bit OS, Linux/Unix/Mac is recommended;(Windows user see guide below)
  2. 64bit JDK 1.8+;
  3. Maven 3.2.x;
  4. Git;
  5. 4g+ free disk for Broker server

 

 

RocketMQ服务搭建　　
下载RocketMQ源码 ： Apache Download Mirrors
解压 ：rocketmq-all-4.9.2-bin-release.zip
unzip rocketmq-all-4.9.2-bin-release.zip
如果没有 unzip 命令 安装 yum install unzip

 修改 bin/runserver.sh 

   因为 RocketMQ  JAVA_OPT 设置的默认参数较大，需要根据实际情况修改

JAVA_OPT="${JAVA_OPT} -server –Xms128m –Xmx128m –Xmn128m"

 

 修改 bin/runbroker.sh 

   因为 RocketMQ  JAVA_OPT 设置的默认参数较大，需要根据实际情况修改

   JAVA_OPT="${JAVA_OPT} -server –Xms128m –Xmx128m –Xmn128m"

 

修改 conf/broker.conf

添加：

autoCreateTopicEnable=true
brokerIP1=192.168.117.108

启动NameServer
nohup sh bin/mqnamesrv &

启动mqbroker
nohup sh bin/mqbroker -n 192.168.117.108:9876 -c conf/broker.conf &

 

再就是测试一下是否可以正常的接收发送消息

export NAMESRV_ADDR=localhost:9876

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

停止服务

./bin/mqshutdown broker
./bin/mqshutdown namesrv

 

推荐阅读