-
能够保证严格的消息顺序
-
提供丰富的消息拉取模式
-
高效的订阅者水平扩展能力
-
实时的消息订阅机制
-
亿级消息堆积能力
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+集群部署
分布式消息队列RocketMQ部署与监控
1. 消息可靠性: 2. 消息低延迟: 3. 每个消息⾄少投递⼀次: 4. 每个消息只消费⼀次: 5. Broker的Buffer满了怎么办?...12. RocketMq物理部署结构 13. RocketMq逻辑结构 14. RocketMq数据存储结构
本文来自于csdn,文章分享了分布式消息中间件,主要基于JMS规范、Rocketmq的介绍、部署方式、特性的一些使用几大模块阐述。 今天要给大家分享的是分布式消息中间件。消息中间件主要是实现分布式系统中解耦、异步消息...
本文来自于jianshu,文章介绍了RocketMQ网络架构图以及RocketMQ发送普通消息的全流程解读等相关内容。摘要:使用客户端发送一条消息很Easy,在...RocketMQ分布式消息队列的网络部署架构图如下图所示(其中,包含了生产
RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点: 能够保证严格的消息顺序; 提供丰富的消息拉取模式; 高效的订阅者水平扩展能力; 实时的消息订阅机制; 亿级消息堆积能力;
阿里开源中间件RocketMQ-3.5.8,已完成编译,可直接部署应用。
安装、集群部署、运维、监控等) 3. 掌握消息的可靠性、幂等性、顺序消息、延迟消息、事务消息等进阶的知识,以及大规模生产 环境中的使用经验,轻松应对各种复杂的业务场景 4. 掌握顶级开源消息中间件核心源码,...
本文来自于jianshu,文章介绍了Rocketmq、kafka、Rabbitmq的详细对比,RocketMQ集群部署等相关内容。一、MQ背景&选型 消息队列作为高并发系统的核心组件之一,能够帮助业务系统解构提升开发效率和系统稳定性。主要...
当前使用较多的消息中间件有RabbitMQ、RocketMQ、ActiveMQ、Kafka、ZeroMQ、MetaMQ等。本套视频以Apache的ActiveMQ作为切入点,分为基础/实战/面试上中下三大部分,带你从零基础入门到熟练掌握ActiveMQ,能够结合...
RocketMQ插件部署
RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特性: 支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型 在一个队列中可靠的先进先出(FIFO)和严格的顺序传递 支持拉(pull)和推(push...
RcoketMQ 是一款低延迟、高可靠、可伸缩、易于使用的消息中间件。具有以下特性: 支持发布/订阅(Pub/Sub)和点对点(P2P)消息模型 在一个队列中可靠的先进先出(FIFO)和严格的顺序传递 支持拉(pull)和推...
RocketMQ是一款高可靠、高吞吐量、可伸缩、易于部署和管理的分布式消息中间件,可以用来实现消息的异步传输、解耦、削峰填谷等功能。具体来说,RocketMQ可以用于以下场景: 事件驱动架构:RocketMQ可以用来将事件...
主要介绍了Window搭建部署RocketMQ步骤详解,RocketMq是一个由阿里巴巴开源的消息中间件,脱胎去阿里每部使用的MetaQ,在设计上借鉴了Kafka。,需要的朋友可以参考下
今天要给大家分享的是分布式消息中间件。消息中间件主要是实现分布式系统中解耦、异步消息、流量销锋、日志处理等...现在生产中用的最多的消息队列有Activemq,rabbitmq,kafka,rocketmq等。分布式消息队列学习必备
最近在写项目中,需要使用rocketmq作为消息中间件,这还是我第一次使用rocketmq消息中间件,但没想到这个使用过程却是困难重重,以下就是我们在这次使用rocketmq中遇到的问题总结。 环境:在阿里云上安装rocketmq...
RocketMQ是一款开源的分布式消息中间件,由阿里巴巴公司于2012年开始开发。它具有高可用性、高性能、可靠性强、功能丰富等特点,广泛应用于电商、金融、物流、互联网和大数据等领域。 RocketMQ整体架构分为Producer...