`
weigang.gao
  • 浏览: 491015 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

rocket MQ服务器搭建

 
阅读更多

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

 

  • 大小: 28.3 KB
  • 大小: 2 KB
  • 大小: 20.7 KB
  • 大小: 78 KB
  • 大小: 6.8 KB
  • 大小: 4.6 KB
  • 大小: 16.9 KB
  • 大小: 19.3 KB
  • 大小: 18.9 KB
  • 大小: 16.9 KB
  • 大小: 49.2 KB
  • 大小: 71.9 KB
分享到:
评论

相关推荐

    Rocket MQ.xmind

    Rocket MQ.xmind

    Rocket MQ 使用排查指南1

    【Rocket MQ 使用排查指南1】 Rocket MQ 是一款由阿里云基于 Apache RocketMQ 构建的分布式消息中间件,设计目标是实现低延迟、高并发、高可用和高可靠性。它适用于分布式应用系统的异步解耦和削峰填谷场景,支持...

    Rocket MQ 使用排查指南.zip

    云运维工程师从入门到精通,6个要点掌握Rocket MQ 原理,5步教程快速入门Rocket MQ ,100+常见问题排查精解

    rocket mq 视频(龙果)

    这个视频是龙果 的rocket mq视频,讲的非常不错。分为上下两个系列。直接用txt 打开后。里边是百度云资源

    Rocket MQ 用户指南 v3.0.4

    - **Broker集群搭建:** 提供了搭建Broker集群的步骤和注意事项。 - **Broker重启对客户端的影响:** 讨论了Broker重启时对客户端的影响及其应对措施。 #### 4. NameServer使用指南 - **NameServer的作用:** 解释了...

    my ali rocket mq学习demo

    在这个“my ali rocket mq学习demo”中,我们有两个关键的Java源文件:Consumer.java和Producer.java,它们分别代表了消息队列中的生产者和消费者角色。 首先,我们来了解一下RocketMQ的基本概念: 1. **生产者...

    Rocket MQ 消息中间件

    主要是针对消息中间件及其应用的介绍, rocketmq是阿里巴巴开源的一款分布式的消息中间件,是实现分布式系统中解耦、异步消息、流量销锋、日志处理等。

    rocket mq window 111111111111111111111111111

    1111111111111111

    TongLINKQ与MQ对比分析报告.doc

    【TongLINKQ与MQ对比分析】 在IT行业中,消息中间件是企业级应用的关键组件,用于在不同系统之间高效地传递数据。本报告对比分析了两款知名的消息中间件产品——IBM的WebSphere MQ(简称MQ)和北京东方通科技公司的...

    rocketchat聊天服务器 v1.3.5.zip

    在这个“rocketchat聊天服务器 v1.3.5.zip”压缩包中,您将找到搭建和运行RocketChat服务器所需的所有资源。 1. **Rocketchat服务器版本1.3.5**: 这个版本号表示的是RocketChat的特定更新迭代,通常每个新版本...

    DataSync:一个基于Rocket MQ的不同数据库之间数据实时同步的平台

    一个基于Rocket MQ的不同数据库之间数据实时同步的平台 watcher为监视数据更新的windows service 配置文件: 1.\Config\producerconfig.json -- rocket mq的生产者配置,用来将从数据库查询出来的数据推送到mq以便...

    使用Docker部署Web在线聊天室Rocket.Chat

    团队沟通与协作:Rocket.Chat 提供实时聊天、频道、私人群组等功能,促进团队成员之间的沟通与协作,使得团队可以更加高效地共同工作。 跨平台支持:Rocket.Chat 支持多种平台,包括Web、移动设备和桌面应用程序,...

    rocketchat聊天服务器 v3.8.4.zip

    9. **Rocket.Chat**:这个文件可能是服务器的主程序或者启动脚本,用于运行和管理Rocketchat服务。用户需要正确配置和启动这个文件,才能开始使用聊天服务器。 总结起来,Rocketchat v3.8.4是一个适用于企业或个人...

    rocketchat聊天服务器 v2.4.14.zip

    在这个“rocketchat聊天服务器 v2.4.14.zip”压缩包中,您将找到搭建和运行Rocketchat服务器所需的所有组件。 首先,我们来详细了解一下Rocketchat的核心特性: 1. **实时通信**:Rocketchat基于WebSocket技术,...

    rocketchat聊天服务器 v3.14.3.zip

    RocketChat是一款开源的即时通讯平台,它提供了类似Slack的功能,但允许用户在自己的服务器上部署,从而确保数据的安全性和隐私。v3.14.3是该软件的一个特定版本,可能包含了修复的问题、增强的功能以及对现有特性的...

    MQ工具类java

    包含了IBM的MQ初始化,发送,接收的工具类,方便极了,可直接放入到项目中。

    Rest Restful 基于rocket服务搭建代码

    Rest Restful 基于rocket服务搭建代码 代码包含的实践用例: 1. restful post, get, put, delete方法 2. 基于rocket的中间层开发,用于日志处理 3. docker部署开发用的postgres 4. async 函数开发 5. async 函数递归...

    rocketchat聊天服务器 v3.11.1.zip

    3. **服务器架构**:作为一个聊天服务器,RocketChat需要处理大量的并发连接和数据传输,因此其背后可能采用了高性能的服务器架构,如Node.js的事件驱动模型,以及可能使用了MongoDB作为数据库存储用户信息和聊天...

Global site tag (gtag.js) - Google Analytics