-
能够保证严格的消息顺序
-
提供丰富的消息拉取模式
-
高效的订阅者水平扩展能力
-
实时的消息订阅机制
-
亿级消息堆积能力
1.安装RocketMQ
1.1 安装环境git,Java,Maven
1
|
yum install git |
1
2
3
|
rpm -ivh jdk-7u51-linux-x64.rpm echo "exportJAVA_HOME=/usr/java/default" >> /etc/profile
source /etc/profile |
1
2
3
4
5
6
7
8
|
mkdir /usr/local/maven tar zxvf apache-maven- 3.2 . 1 -bin.tar.gz -C/usr/local/maven/
echo 'exportM2_HOME=/usr/local/maven/apache-maven-3.2.1' >> /etc/profile
echo 'export M2=$M2_HOME/bin' >>/etc/profile
echo 'export MAVEN_OPTS="-Xms256m-Xmx512m"' >> /etc/profile
echo 'export PATH=$M2:$PATH' >>/etc/profile
source /etc/profile mvn -v |
1.2 安装RocketMQ
1
2
3
4
5
|
wget https: //github.com/alibaba/RocketMQ/archive/v3.0.8-beta1.tar.gz
tar zxvf v3. 0.8 -beta1.tar.gz
cd rocketmq sh install.sh cd devenv |
2.RocketMQ部署
2.1 启动nameserver
1
|
nohup mqnamesrv & |
2.2 启动broker
1
|
nohup mqbroker -n "192.168.0.1:9876;192.168.0.2:9876" &
|
1
|
mqbroker -n "192.168.0.1:9876;192.168.0.2:9876"
|
1
|
exportNAMESRV_ADDR= 192.168 . 0.1 : 9876 ; 192.168 . 0.2 : 9876
|
2.3 关闭nameserver或broker
1
2
|
sh ./mqshutdown Useage: mqshutdown broker | namesrv |
2.4 Producer/Consumer指定Name Server地址
1
|
producer.setNamesrvAddr( "192.168.0.1:9876;192.168.0.2:9876" );
|
1
|
consumer.setNamesrvAddr( "192.168.0.1:9876;192.168.0.2:9876" );
|
1
|
-Drocketmq.namesrv.addr= 192.168 . 0.1 : 9876 ; 192.168 . 0.2 : 9876
|
1
|
exportNAMESRV_ADDR= 192.168 . 0.1 : 9876 ; 192.168 . 0.2 : 9876
|
2.5 Broker集群部署
1
|
nohup sh mqnamesrv & |
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-noslave/broker-a.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-noslave/broker-b.properties &
|
1
|
nohup sh mqnamesrv & |
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-async/broker-a.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-async/broker-b.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-async/broker-a-s.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-async/broker-b-s.properties &
|
1
|
nohup sh mqnamesrv & |
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-sync/broker-a.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-sync/broker-b.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-sync/broker-a-s.properties &
|
1
|
nohup sh mqbroker -n 192.168 . 1.1 : 9876 -c$ROCKETMQ_HOME/conf/2m-2s-sync/broker-b-s.properties &
|
相关推荐
接着是"RocketMQ部署日志-2019年5月24日.xlsx",这是一个记录了RocketMQ部署过程的日志文件,通常会记录每个步骤的时间戳、执行状态和可能出现的问题。这对于调试和优化部署过程非常有用,你可以根据日志中的信息...
RocketMQ是阿里巴巴开源的一款...至此,一个基本的RocketMQ部署已完成。在实际应用中,还需要考虑高可用、性能优化、监控报警等更多细节。通过调整配置、增加节点、部署集群,可以构建更稳定、高效的RocketMQ环境。
Apache RocketMQ是一款高性能、分布式的消息中间件,常用于大规模分布式系统中的消息传递。它支持发布/订阅模式和点对点模式的消息传递,并提供了高可用性和高吞吐量的特性。在Windows环境下部署RocketMQ,主要涉及...
RocketMQ,作为阿里巴巴开源的一款高性能、高可用、分布式的消息中间件,被广泛应用于消息传递、事件驱动、异步处理等多种场景。本教程将重点讨论如何在集群环境中部署RocketMQ。 首先,我们要理解RocketMQ的基本...
RocketMQ是一个开源的消息中间件,由阿里巴巴开源,并且是Apache顶级项目,广泛应用于高并发、高可靠的消息分发场景中。 首先,部署RocketMQ集群需要规划好集群的结构。通常,一个RocketMQ集群包括NameServer节点和...
总的来说,"宝塔部署RocketMQ+可视化面板"是一项涉及到Java环境搭建、消息中间件安装配置、可视化监控实施的工作。通过合理规划和细致操作,可以构建一个高效、稳定的RocketMQ消息服务,为业务系统的扩展和数据处理...
- **集群部署与管理**:配置集群,进行滚动升级、扩缩容等运维操作。 - **消息重试与死信队列**:理解消息重试机制,设置死信队列避免消息丢失。 - **监控与报警**:集成监控工具,设置报警阈值,实时监控系统...
分布式消息队列RocketMQ部署与监控
1. 消息可靠性: 2. 消息低延迟: 3. 每个消息⾄少投递⼀次: 4. 每个消息只消费⼀次: 5. Broker的Buffer满了怎么办?...12. RocketMq物理部署结构 13. RocketMq逻辑结构 14. RocketMq数据存储结构
RocketMQ,作为一款开源的消息中间件,源自阿里巴巴,并在2016年捐赠给了Apache软件基金会,成为顶级项目。RocketMQ的设计目标是提供低延迟、高可扩展性、高可靠性的分布式消息传递服务,适用于大数据领域的实时数据...
RocketMQ是一款由阿里巴巴开源的消息中间件,它在分布式系统中起着至关重要的作用,用于解耦应用程序、实现异步处理和提高系统的可扩展性。RocketMQ的设计理念是高可用、高吞吐量和低延迟,这使得它在大规模并发场景...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,专为大规模分布式系统设计,以高吞吐、低延迟、高可扩展性和高可靠性为目标。在3.2.6版本中,RocketMQ进一步优化了性能和稳定性,为企业级应用提供了强大的消息传递...
本文来自于csdn,文章分享了分布式消息中间件,主要基于JMS规范、Rocketmq的介绍、部署方式、特性的一些使用几大模块阐述。 今天要给大家分享的是分布式消息中间件。消息中间件主要是实现分布式系统中解耦、异步消息...
RocketMQ 是阿里巴巴中间件团队自研的一款高性能、高吞吐量、低延迟、高可用、高可靠(具备金融级稳定性)的分布式消息中间件。RocketMQ 的前世今生是 Metaq,Metaq 在阿里巴巴集团内部、蚂蚁金服、菜鸟等各业务中...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据领域,提供高可用、高可靠的消息传输服务。在3.5.8版本中,它支持双主双从的配置,这是一种增强系统容错性和高可用性的架构模式。接下来,我们将...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大数据、实时计算、微服务等领域。本文将详细介绍如何在Windows环境下安装RocketMQ,包括单机模式和集群模式,并且讲解如何进行后台服务注册。 **一、...
RocketMQ是阿里巴巴开源的一款分布式消息中间件,广泛应用于大规模分布式系统中的消息传递,提供高可用、高可靠的消息传输服务。本学习总结将深入探讨RocketMQ的核心概念、工作原理以及实战应用,帮助读者全面掌握这...
RocketMQ,一款开源的消息中间件,由阿里巴巴贡献并维护,它具有高可用、高并发、低延迟的特点,广泛应用于分布式系统中的消息传输。本安装文档将详细讲解如何简单搭建RocketMQ以及如何构建一个集群双主双从的异步...