rocketmq单机搭建请参考:http://blog.csdn.net/loongshawn/article/details/51086876
可以使用rocketmq-console来监控rocketmq服务器消费情况
下面来讲解如何配置rocketmq消息队列集群部署和监控:
目前在Github上可下载最新的安装包alibaba-rocketmq-3.2.6.tar
下载地址:https://github.com/alibaba/RocketMQ
一,RocketMQ简介
================================================
RocketMQ是一款分布式,队列模型的消息中间件,具有以下特点:
1.支持严格的消息顺序;
2.支持Topic与Queue两种模式;
3.亿级消息堆积能力;
4.比较友好的分布式特性;
5.同事支持Push与Pull方式消费消息
===============================================
二,服务器分布
===============================================
1.相关说明
2.hosts信息添加
#vi /etc/hosts
3.系统环境
CentOS6.8
4.总体架构
========================================
三,RocketMQ安装与配置
========================================
1、JDK安装
下载linux版本的jdk:http://download.oracle.com/otn-pub/java/jdk/8u121-b13/e9e7ea248e2c4826b92b3f075a80e441/jdk-8u121-linux-x64.tar.gz
解压安装包:
#tar -zxvf jdk-8u121-linux-x64.tar.gz
2.RocketMQ安装
下载:https://github.com/alibaba/RocketMQ/releases
①解压安装包
#tar -zxvf alibaba-rocketmq-3.2.6.tar.gz
②建立软连接
#ln -s /applicaiton/alibaba-rocketmq /opt/alibaba-rocketmq
3.环境变量设置
#vi /etc/profile
#source /etc/profile 使环境变量生效
4.hosts文件配置
CentOS1,CentOS2, CentOS3配置一样,如下:
5.RocketMQ配置
①Master1服务器
#vi /opt/alibaba-rocketmq/conf/2m-noslave/broker-a.properties
②Master2服务器
#vi /opt/alibaba-rocketmq/conf/2m-noslave/broker-b.properties
③Master3服务器
#vi /opt/alibaba-rocketmq/conf/2m-noslave/broker-c.properties
6.启动服务器
①启动NameServer[Master1, Master2, Master]
#cd /opt/alibaba-rocketmq/bin
#nohup sh mqnamesrv &
②启动BrokerServer A[Master1]
#cd /opt/alibaba-rocketmq/bin
# nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties &
③启动BrokerServer B[Master2]
#cd /opt/alibaba-rocketmq/bin
# nohup sh mqbroker -c ../conf/2m-noslave/broker-b.properties &
④启动BrokerServer C[Master3]
#cd /opt/alibaba-rocketmq/bin
# nohup sh mqbroker -c ../conf/2m-noslave/broker-c.properties &
#netstat -ntlp
关闭nameserver broker执行的命令
#mqshutdown namesrv
#mqshutdown broker
4.安装启动rocketmq管理控制台,可以查看rocketmq集群信息
rocketmq主题信息
参考:http://blog.csdn.net/lang_man_xing/article/details/47447797
相关推荐
Rocket MQ.xmind
【Rocket MQ 使用排查指南1】 Rocket MQ 是一款由阿里云基于 Apache RocketMQ 构建的分布式消息中间件,设计目标是实现低延迟、高并发、高可用和高可靠性。它适用于分布式应用系统的异步解耦和削峰填谷场景,支持...
云运维工程师从入门到精通,6个要点掌握Rocket MQ 原理,5步教程快速入门Rocket MQ ,100+常见问题排查精解
这个视频是龙果 的rocket mq视频,讲的非常不错。分为上下两个系列。直接用txt 打开后。里边是百度云资源
- **Broker集群搭建:** 提供了搭建Broker集群的步骤和注意事项。 - **Broker重启对客户端的影响:** 讨论了Broker重启时对客户端的影响及其应对措施。 #### 4. NameServer使用指南 - **NameServer的作用:** 解释了...
在这个“my ali rocket mq学习demo”中,我们有两个关键的Java源文件:Consumer.java和Producer.java,它们分别代表了消息队列中的生产者和消费者角色。 首先,我们来了解一下RocketMQ的基本概念: 1. **生产者...
主要是针对消息中间件及其应用的介绍, rocketmq是阿里巴巴开源的一款分布式的消息中间件,是实现分布式系统中解耦、异步消息、流量销锋、日志处理等。
1111111111111111
【TongLINKQ与MQ对比分析】 在IT行业中,消息中间件是企业级应用的关键组件,用于在不同系统之间高效地传递数据。本报告对比分析了两款知名的消息中间件产品——IBM的WebSphere MQ(简称MQ)和北京东方通科技公司的...
在这个“rocketchat聊天服务器 v1.3.5.zip”压缩包中,您将找到搭建和运行RocketChat服务器所需的所有资源。 1. **Rocketchat服务器版本1.3.5**: 这个版本号表示的是RocketChat的特定更新迭代,通常每个新版本...
一个基于Rocket MQ的不同数据库之间数据实时同步的平台 watcher为监视数据更新的windows service 配置文件: 1.\Config\producerconfig.json -- rocket mq的生产者配置,用来将从数据库查询出来的数据推送到mq以便...
团队沟通与协作:Rocket.Chat 提供实时聊天、频道、私人群组等功能,促进团队成员之间的沟通与协作,使得团队可以更加高效地共同工作。 跨平台支持:Rocket.Chat 支持多种平台,包括Web、移动设备和桌面应用程序,...
在这个“rocketchat聊天服务器 v2.4.14.zip”压缩包中,您将找到搭建和运行Rocketchat服务器所需的所有组件。 首先,我们来详细了解一下Rocketchat的核心特性: 1. **实时通信**:Rocketchat基于WebSocket技术,...
RocketChat是一款开源的即时通讯平台,它提供了类似Slack的功能,但允许用户在自己的服务器上部署,从而确保数据的安全性和隐私。v3.14.3是该软件的一个特定版本,可能包含了修复的问题、增强的功能以及对现有特性的...
包含了IBM的MQ初始化,发送,接收的工具类,方便极了,可直接放入到项目中。
9. **Rocket.Chat**:这个文件可能是服务器的主程序或者启动脚本,用于运行和管理Rocketchat服务。用户需要正确配置和启动这个文件,才能开始使用聊天服务器。 总结起来,Rocketchat v3.8.4是一个适用于企业或个人...
Rest Restful 基于rocket服务搭建代码 代码包含的实践用例: 1. restful post, get, put, delete方法 2. 基于rocket的中间层开发,用于日志处理 3. docker部署开发用的postgres 4. async 函数开发 5. async 函数递归...
3. **服务器架构**:作为一个聊天服务器,RocketChat需要处理大量的并发连接和数据传输,因此其背后可能采用了高性能的服务器架构,如Node.js的事件驱动模型,以及可能使用了MongoDB作为数据库存储用户信息和聊天...