搜索结果
查询Tags标签： RocketMQ，共有 213条记录-
docker 上部署RocketMQ
docker 上部署RocketMQ RocketMQ 是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点 MQ好处： 1.应用解耦 2.流量削锋： 请求流量瞬间猛增，可能会把系统压垮。MQ可以将请求缓存起来，分散到很长一段时间去处理。提高系统的稳定性。 3.数据分发 缺点：…
2022/7/15 6:21:17 人评论 次浏览 -
RocketMQ
转自 https://blog.csdn.net/qq_21040559/article/details/122703715 1 介绍RocketMQ作为一款纯java、分布式、队列模型的开源消息中间件，支持事务消息、顺序消息、批量消息、定时消息、消息回溯等。 1.1 RocketMQ 特点支持发布/订阅（Pub/Sub）和点对点（P2P）消息模型 …
2022/6/21 23:21:47 人评论 次浏览 -
【RocketMQ】NameServer的启动
NameServer是一个注册中心，Broker在启动时向所有的NameServer注册，生产者Producer和消费者Consumer可以从NameServer中获取所有注册的Broker列表，并从中选取Broker进行消息的发送和消费。 NameServer的启动类是NamesrvStartup，主要做了两件事情：调用createNamesrvCon…
2022/6/8 23:20:24 人评论 次浏览 -
RocketMQ——总结（一）
官网：https://rocketmq.apache.org/ 源码地址：https://github.com/apache/rocketmq一、RocketMQ的优点 1、天然支持集群模式、负载均衡、水平扩展能力 2、上亿级别的消息堆积能力 3、采用零拷贝的原理、顺序写盘、随机读（借鉴kafka） 4、丰富的API使用，支持顺序消息，…
2022/5/4 23:15:42 人评论 次浏览 -
RocketMQ orderly和concurrently 消费的区别
orderly：SUSPEND_CURRENT_QUEUE_A_MOMENT：在本地重试，先判断重新消费次数有没有达到最大值(consumer定义的时候传入，不传为Integer最大值)，如果没达到，重试次数+1，放入消费池，1秒（默认）之后再消费，直到达到最大消费次数。发送到重试队列（这个时候必然会进入死…
2022/4/7 6:22:50 人评论 次浏览 -
RocketMQ-Streams架构设计浅析
*作者：倪泽，RocketMQ 资深贡献者， RocketMQ-Streams 维护者之一，阿里云技术专家。 * RocketMQ-Streams 是一款轻量级流处理引擎，应用以SDK 的形式嵌入并启动，即可进行流处理计算，不依赖于其他组件，最低1核1G可部署，在资源敏感场景具有很大优势。同时它支持 UTF/U…
2022/4/6 23:19:59 人评论 次浏览 -
RocketMQ 延迟消息（定时消息）4.9.3 版本优化 异步投递支持
1. 概述 在 RocketMQ 4.9.3 版本中，@Git-Yang 对延迟消息做了很大的优化，大幅度提升了延迟消息的性能。 其中，PR#3287 将原先用来启动周期性任务的 Timer 改为使用 ScheduledExecutorService，将多延迟等级下同时发送延迟消息的性能提升了 3+ 倍。 本文主要讲解的是另一…
2022/3/21 6:29:37 人评论 次浏览 -
RocketMQ(分布式消息队列)
RocketMQ MQ(Message Queue):消息队列 基本概念 消息模型（Message Model）: RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以…
2022/2/25 23:30:34 人评论 次浏览 -
rocketMq和kafka消息推拉模式
https://segmentfault.com/a/1190000023854950 rocketMq的推模式，默认每5s检查是否有新消息，另外在处理commitLog消息分发到Message Queue的时候，会唤醒消息请求处理操作，所以对于消息的响应是比较及时的。
2022/2/25 23:22:27 人评论 次浏览 -
Linux 云服务安装和部署rocketmq4.9.2版本
参考地址 https://rocketmq.apache.org/docs/quick-start/目录 1、安装jdk 2、安装rocketmq( maven 已编译版本) 3、修改rocketMq 配置安装环境：1、JDK1.8+；2、Maven 3.2.X；3、Git4、4g+ free disk for Broker server一、安装jdkjava官网地址:https://www.oracle.com/j…
2022/2/22 7:25:29 人评论 次浏览 -
RocketMQ(二) - NameServer路由元信息分析
RocketMQ(二) - NameServer路由元信息分析上一篇详细分析了 NameServer的启动流程 (不包括底层服务端的启动， 仅限于 NamesrvController层面的启动)。 这一篇 主要 针对NameServer在RocketMQ中的角色原理做介绍。我们知道 RocektMQ中的组件分为： producer、consumer、br…
2022/2/21 6:26:41 人评论 次浏览 -
1.MQ 的相关概念
目录1.MQ 的相关概念1.1什么是 MQ1.2为什么要用 MQ1.2.1流量消峰1.2.2应用解耦1.2.3异步处理1.3MQ 的分类1.3.1ActiveMQ1.3.2Kafka1.3.3RocketMQ1.3.4RabbitMQ1.3.5kafka、activemq、rabbitmq、rocketmq优点和缺点 1.MQ 的相关概念 1.1什么是 MQ MQ(message queue)，从字面…
2022/2/16 23:43:14 人评论 次浏览 -
Apache RocketMQ + Hudi 快速构建 Lakehouse
本文目录背景知识 大数据时代的构架演进 RocketMQ Connector&Stream Apache Hudi 构建Lakehouse实操本文标题包含三个关键词：Lakehouse、RocketMQ、Hudi。我们先从整体Lakehouse架构入手，随后逐步分析架构产生的原因、架构组件特点以及构建Lakehouse架构的实操部分。…
2022/2/16 6:12:15 人评论 次浏览 -
rocketmq核心源码分析第二十三篇一顺序消息
文章目录 顺序消息使用demo源码分析 总结顺序消息 使用demo 通过MessageQueueSelector对mqs进行选择一般按业务维度保障分区顺序 defaultMQProducer.send(msg,new MessageQueueSelector(){public MessageQueue select(List<MessageQueue> mqs, Message msg, Object …
2022/2/8 17:14:40 人评论 次浏览 -
在本机搭建集群环境：简便快速 不需要处理端口开放等防火墙设置前提条件：修改好JVM参数，比如将JVM的Xms等参数调小（默认4GB）。 在本机装好rocketMQ并成功运行（可以通过本地单机起nameserver服务，跑官方提供的demo验证）创建NameServer集群 复制原RocketMQ包 原有Roc…
2022/2/3 23:12:38 人评论 次浏览
