- 浏览: 211732 次
- 性别:
- 来自: 杭州
文章分类
最新评论
-
hus20120405:
很不错,我运行起来了
log4jdbc日志框架介绍 -
Roshomon:
牛叉 找了很多解决方案 你的OK了
plsql ora-12154 TNS 无法处理服务名 -
ackley:
赞!谢谢!
Cannot access NLS data files or invalid ...
前一篇文章http://zhenggm.iteye.com/admin/blogs/2306877写了rocketMQ的入门使用,是单节点的,这一篇写一下集群。
在讲集群搭建之前,先讲一下rocketMq的四种部署方式。
1. 单节点(即只有一个MQBroker)
优点:部署最简单,入门学习容易
缺点:可靠性相对其它部署方式都要差很多
2. 多节点(多个主,没有备)
优点:分布式,性能好
缺点:某个节点宕机会影响这个节点的数据无法及时处理,异步刷盘重启可能会丢失部分数据
3. 多节点(多主多备,主备异步)
优点:可靠性好,性能好
缺点:某个节点宕机,异步刷盘重启可能会丢失部分数据
4. 多节点(多主多备,主备同步)
优点:可靠性好,数据不会丢失
缺点:性能比主备异步略差
一、MQ broker分布式环境搭建(两个master, 没有slave)
1. 修改配置 conf\2m-noslave\broker-a.propertie,内容添加:listenPort=10911
conf\2m-noslave\broker-b.propertie,内容添加:listenPort=10922(因为是单机测试,所以需要修改端口,避免冲突)
2. 启动集群
Start /b mqnamesrv.exe > mqnamesrv.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-noslave\broker-a.properties" > mqbroker_a.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-noslave\broker-b.properties" > mqbroker_b.log
3. 确认启动情况
查看启动日志 mqbroker_a.log, mqbroker_b.log
4. 重新运行测试用例,并查看队列存储情况
mqadmin brokerStatus -b 192.168.180.15:10911 -n 192.168.180.15:9876(存了18条)
mqadmin brokerStatus -b 192.168.180.15:10922 -n 192.168.180.15:9876(存了12条)
二、MQ broker分布式环境搭建(两个master, 两个slave, 主备异步)
1. 修改配置
conf\2m-noslave\broker-a.propertie,内容添加:listenPort=10911
broker-a-s.properties,内容添加:listenPort=10811
broker-b.propertie,内容添加:listenPort=10922
broker-b-s.propertie,内容添加:listenPort=10822
2. 启动集群
Start /b mqnamesrv.exe > mqnamesrv.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-a.properties" > mqbroker_a.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-a-s.properties" > mqbroker_a_s.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-b.properties" > mqbroker_b.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-b-s.properties" > mqbroker_b_s.log
3. 确认启动情况
查看启动日志 mqbroker_a.log,mqbroker_a_s.log, mqbroker_b.log,mqbroker_b_s.log
4. 重新运行测试用例,并查看队列存储情况
mqadmin brokerStatus -b 192.168.180.15:10911 -n 192.168.180.15:9876(存了18条)
mqadmin brokerStatus -b 192.168.180.15:10811 -n 192.168.180.15:9876(存了18条)
mqadmin brokerStatus -b 192.168.180.15:10922 -n 192.168.180.15:9876(存了12条)
mqadmin brokerStatus -b 192.168.180.15:10822 -n 192.168.180.15:9876(存了12条)
5. 使用管理命令查看MQ消息
mqadmin queryMsgByKey -n 192.168.180.15:9876 -t TopicDemo -k OrderID0010
还有一堆命令就不列举了, 具体可度娘: RocketMq运维指令
在讲集群搭建之前,先讲一下rocketMq的四种部署方式。
1. 单节点(即只有一个MQBroker)
优点:部署最简单,入门学习容易
缺点:可靠性相对其它部署方式都要差很多
2. 多节点(多个主,没有备)
优点:分布式,性能好
缺点:某个节点宕机会影响这个节点的数据无法及时处理,异步刷盘重启可能会丢失部分数据
3. 多节点(多主多备,主备异步)
优点:可靠性好,性能好
缺点:某个节点宕机,异步刷盘重启可能会丢失部分数据
4. 多节点(多主多备,主备同步)
优点:可靠性好,数据不会丢失
缺点:性能比主备异步略差
一、MQ broker分布式环境搭建(两个master, 没有slave)
1. 修改配置 conf\2m-noslave\broker-a.propertie,内容添加:listenPort=10911
conf\2m-noslave\broker-b.propertie,内容添加:listenPort=10922(因为是单机测试,所以需要修改端口,避免冲突)
2. 启动集群
Start /b mqnamesrv.exe > mqnamesrv.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-noslave\broker-a.properties" > mqbroker_a.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-noslave\broker-b.properties" > mqbroker_b.log
3. 确认启动情况
查看启动日志 mqbroker_a.log, mqbroker_b.log
4. 重新运行测试用例,并查看队列存储情况
mqadmin brokerStatus -b 192.168.180.15:10911 -n 192.168.180.15:9876(存了18条)
mqadmin brokerStatus -b 192.168.180.15:10922 -n 192.168.180.15:9876(存了12条)
二、MQ broker分布式环境搭建(两个master, 两个slave, 主备异步)
1. 修改配置
conf\2m-noslave\broker-a.propertie,内容添加:listenPort=10911
broker-a-s.properties,内容添加:listenPort=10811
broker-b.propertie,内容添加:listenPort=10922
broker-b-s.propertie,内容添加:listenPort=10822
2. 启动集群
Start /b mqnamesrv.exe > mqnamesrv.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-a.properties" > mqbroker_a.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-a-s.properties" > mqbroker_a_s.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-b.properties" > mqbroker_b.log
start /b mqbroker.exe -n "192.168.180.15:9876" -c "..\conf\2m-2s-async\broker-b-s.properties" > mqbroker_b_s.log
3. 确认启动情况
查看启动日志 mqbroker_a.log,mqbroker_a_s.log, mqbroker_b.log,mqbroker_b_s.log
4. 重新运行测试用例,并查看队列存储情况
mqadmin brokerStatus -b 192.168.180.15:10911 -n 192.168.180.15:9876(存了18条)
mqadmin brokerStatus -b 192.168.180.15:10811 -n 192.168.180.15:9876(存了18条)
mqadmin brokerStatus -b 192.168.180.15:10922 -n 192.168.180.15:9876(存了12条)
mqadmin brokerStatus -b 192.168.180.15:10822 -n 192.168.180.15:9876(存了12条)
5. 使用管理命令查看MQ消息
mqadmin queryMsgByKey -n 192.168.180.15:9876 -t TopicDemo -k OrderID0010
还有一堆命令就不列举了, 具体可度娘: RocketMq运维指令
发表评论
文章已被作者锁定,不允许评论。
-
zookeeper docker 集群安装
2022-10-14 17:18 1331. 下载镜像 docker pull docker.io/z ... -
Kafka学习笔记【三】-JAVA调用示例
2018-05-29 08:35 5691. pom.xml <dependency> ... -
Kafka学习笔记【二】-安装
2018-05-24 08:20 354kafka的安装如下: 一、准备环境 1) 三台服务器 ... -
Kafka学习笔记【一】-原理
2018-05-18 09:23 249一、kafka的重要概念 1. kafka 分为 Produ ... -
rabbitMQ学习笔记【三】-haproxy部署 原创
2018-04-11 16:11 374一、下载 https://fossies.org/lin ... -
rabbitMQ学习笔记【二】-集群部署 原创
2018-04-03 19:40 397一、准备工作 三台机器hosts: 192.168.3 ... -
rabbitMQ学习笔记【一】-单机部署 原创
2018-03-19 16:04 405公司对外接入需要支持MQ,最终选定rabbitMQ.本文 ... -
HttpClient 学习笔记【原创】
2017-09-07 19:28 1871HttpClient 某些方法的作用梳理。本文的测试基于htt ... -
关于dubbo的思考【原创】
2016-09-21 08:23 1317最近在看dubbo的文档,有些内容结合自己的思考记录一下 1. ... -
dubbo http webservice 服务学习笔记【原创】
2016-09-11 19:12 6472学习了 dubbo rest服务之后,再使用dubbo htt ... -
dubbo rest 服务学习笔记(三)【原创】
2016-09-09 19:34 8743在配置过程中遇到两个 ... -
dubbo rest 服务学习笔记(二)【原创】
2016-09-09 19:21 1375采用dubbo客户端访问dubbo发布的rest服务,接上一篇 ... -
dubbo rest 服务学习笔记(一)【原创】
2016-09-09 19:07 6067dubbo是很好的服务治理工具,包含了注册,路由,监控 ... -
RocketMq数据处理
2016-06-27 08:58 609这篇讲实践中数据丢失、顺序幂等处理、性能压测,有时间再写 -
MS MQ 使用实践【原创】
2016-06-26 14:58 7651. 参照百度经验http://jingyan.baidu.c ... -
RocketMq学习笔记【原创】
2016-06-23 14:05 1576前段时间在实施分布式数据库的过程中,使用过rocketMQ, ... -
rest的调用 java 示例代码【原创】
2016-06-20 15:35 11151. 服务端示例代码(如何搭建rest服务,请看上一篇) ... -
jersey2 与 spring4 整合实践【原创】
2016-06-13 15:35 4970前几年用过jeysey,那都是1.x版本的,jersey2有很 ... -
java nio入门
2010-03-04 17:22 952首先了解下所谓的java nio是个什么东西! ... -
spring http invoker学习笔记
2010-01-04 16:58 3664概念 Spring HTTP invoker是spring框架 ...
相关推荐
RocketMQ学习笔记 1 RocketMQ学习笔记 1是关于Apache RocketMQ的学习笔记,涵盖了RocketMQ的基本概念、架构、消息模型、Producer和Consumer的基本概念、JMS规范等知识点。 1. 消息模型 在RocketMQ中,消息模型是...
RocketMQ学习笔记主要涵盖了消息队列(MQ)的相关知识,内容深入浅出,不仅包含理论知识,还融入了实战案例和源码分析,适用于希望掌握RocketMQ的开发者。 首先,RocketMQ是一个分布式、开源的消息中间件,它起源于...
RocketMQ学习笔记1 RocketMQ是Apache旗下的一个开源的消息队列系统,具有分布式、可靠、可扩展、高性能等特点。下面是对RocketMQ的学习笔记的总结。 分布式架构 RocketMQ原生支持分布式,解决了单点故障问题,...
rocketmq学习 rocketmq深入
尚硅谷提供的 RocketMQ 学习视频笔记旨在帮助初学者系统地掌握 RocketMQ 的核心概念和使用方法。 1. **MQ 简述** 消息队列(Message Queue,MQ)是一种异步通信机制,它在生产者和消费者之间充当了缓冲的角色,...
RocketMq 学习笔记 包含集群配置、顺序消费、事务、Filter组件配置以及使用,包含demo
"RocketMQ黑马笔记" RocketMQ是阿里巴巴开源的消息中间件,在阿里内部历经了双十一等很多高并发场景的考验,能够处理亿万级别的消息。2016年开源后捐赠给Apache,现在是Apache的一个顶级项目。目前RocketMQ在阿里云...
Docker Desktop下安装rocketmq
rocketmq自用笔记第一部分
Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习笔记Java学习...
《PFC2D学习笔记全集》是一份深入探讨PFC2D软件应用的资源集合,涵盖了该软件的多个核心方面。PFC2D(Particle Flow Code in Two Dimensions)是岩土力学和地质工程领域常用的一款离散元方法(DEM)软件,用于模拟...
希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf希沃白板学习笔记.pdf
Springcloud学习笔记.md,Springcloud学习笔记.md,Springcloud学习笔记.md,Springcloud学习笔记.md,Springcloud学习笔记.md,Springcloud学习笔记.md,Springcloud学习笔记.md,Springcloud学习笔记.md,Spring...
CCNA学习笔记 CCNA学习笔记 CCNA学习笔记
云的学习笔记-云的学习笔记系统-云的学习笔记系统源码-云的学习笔记管理系统-云的学习笔记管理系统java代码-云的学习笔记系统设计与实现-基于ssm的云的学习笔记系统-基于Web的云的学习笔记系统设计与实现-云的学习...
云的学习笔记-云的学习笔记系统-云的学习笔记系统源码-云的学习笔记管理系统-云的学习笔记管理系统java代码-云的学习笔记系统设计与实现-基于ssm的云的学习笔记系统-基于Web的云的学习笔记系统设计与实现-云的学习...
人工智能学习笔记,人工智能学习笔记,人工智能学习笔记人工智能学习笔记,人工智能学习笔记,人工智能学习笔记人工智能学习笔记,人工智能学习笔记,人工智能学习笔记人工智能学习笔记,人工智能学习笔记,人工智能...