rocketmq学习杂记

rocketmq总体架构图，来源于 https://rocketmq.apache.org/docs/rmq-arc/，可参考：

1.本地部署遇到的问题： rocketmq默认配置对内存要求较高，启动会有问题， /xxxx/distribution/target/apache-rocketmq/bin/runserver.sh /xxxx/distribution/target/apache-rocketmq/bin/runbroker.sh

2.杂记参考：http://blog.csdn.net/quhongwei_zhanqiu/article/details/39142693

1.消息过滤，在broker中，可以按照consumer的要求做过滤，较少了网络传输。

2.rocketmq使用长轮询的方式，保证消息的实时性。 ** 基于拉模式拉取消息，consumer做负载均衡并通过长轮询向broker拉消息。

3.producer向队列发送消息，队列集合称为 Topic，

4.rocketmq的网络部署特点： 1.name server 是一个无状态节点，可集群部署，节点之间无任何信息同步。 nameserver启动后，每隔10s轮询查询清理失效的broker链接。

2.broker 有主备之分，
3.producer 可与 name server集群中的一个节点(随机选择) 建立 长连接，定期从 name server 取 topic 路由信息，并向提供 topic服务的master 建立长连接，且定时向 master 发送心跳，producer 完全无状态，集群部署。consumer也是与 nameserver 的一个节点 建立 长链接，定期从 nameserver 取 topoic信息，并向提供 topic服务的master 建立长链接，且定时发送心跳，
4.  consumer：
拉取消费的方式：1.push：consumer通过长轮询 拉取消息后，回调MessageListener接口实现完成消费，应用系统只要MessageListener完成业务逻辑即可。这种模式用的最多。2.pull：完全由业务系统去控制，定时拉取消息，指定队列消费
启动流程：1.订阅topic，Map存储top对应的订阅对象。2.注册消息消费的监听器，复制代码

转载于:https://juejin.im/post/5a4492fe6fb9a045023bf085

rocketmq学习杂记相关推荐

RocketMQ学习笔记（7）----RocketMQ的整体架构
1. RocketMQ主要的9个模块,如图: 2. 模块介绍 1. rocketmq-common:通用的常量枚举,基类方法或者数据结构,按描述的目标来分包,通俗易懂.报名有admin,consume ...
2020年，RocketMQ面试题 -面试题驱动RocketMQ学习
本文是<从 0 开始带你成为消息中间件实战高手>内容总结,版权问题,特此声明本篇文章持续更新,大概有上百道题,用这些题来驱动RocketMQ学习,在面试中也会脱颖而出!! 15 解决订单 ...
JavaEE 企业级分布式高级架构师（二十）RocketMQ学习笔记（2）
RocketMQ学习笔记进阶篇消息样例普通消息消息发送发送同步消息发送异步消息单向发送消息三种发送方式的对比消费消息顺序消息如何保证顺序顺序的实现 MessageListene ...
Fortran学习杂记(一)
Fortran学习杂记(一) 1. 内置函数 1) 数值运算常见:- abs( ) - aimag( ) -conj( ) -max( ) ** -min( ) - mod(a, b) - real ...
51单片机学习杂记——基于STC89C52RC
51单片机学习杂记--基于STC89C52RC 我是看的b站郭天祥老师的课,说实话,我觉得我能力不是很够,所以记得很杂.废物了属于是. 接下来就是正文了基本的元器件以及字母符号含义: 电容:帮助晶振 ...
RocketMQ学习笔记（8）----RocketMQ的Producer API简介
在RocketMQ中提供了三种发送消息的模式: 1.NormalProducer(普通) 2.OrderProducer(顺序) 3.TransactionProducer(事务) 下面来介绍一下pr ...
Python日常学习杂记
Python日常学习杂记 python -c 的作用在命令行里执行python时,如果加上 -c,即 python -c xxx 那么,xxx就被当做一条指令(command)来执行,否则,就当做脚 ...
RocketMQ学习笔记
RocketMQ学习笔记文章目录 RocketMQ学习笔记前言为什么要使用消息队列? 解耦异步削峰使用了消息队列会有什么缺点? 消息队列如何选型? 如何保证消息队列是高可用的? 如何保证消 ...
rocketmq 组监听_最全的RocketMQ学习指南，程序员必备的中间件技能
一.简介 RocketMq是阿里开发出来的一个消息中间件,后捐献给Apache.官网上是这样介绍的: Apache RocketMQ™ is a unified messaging engine, l ...

rocketmq学习杂记

rocketmq学习杂记相关推荐

最新文章

热门文章