定制费用、定制服务、网站定制、RocketMQ、404、环境、网站开发、ROMS、小红书、点击
消息存储 消息存储核心类 private final MessageStoreConfig messageStoreConfig; //消息配置属性 private final CommitLog...
来源：博客园 2025-05-20 09:29 69
NameServer 架构设计 消息中间件的设计思路一般是基于主题订阅发布的机制，消息生产者（Producer）发送某一个主题到消息服务器，消息服务器负责将消息持久化存储，消息消费者（Consume...
来源：博客园 2025-05-19 09:29 37
消息存储 分布式队列因为有高可靠性的要求，所以数据要进行持久化存储。 消息生成者发送消息 MQ收到消息，将消息进行持久化，在存储中新增一条记录 返回ACK给生产者 MQ push 消息给对应的消...
来源：博客园 2025-05-15 09:29 53
RocketMQ篇之-消息存储 目录RocketMQ篇之-消息存储（前置）消息存储交互流程（一）存储系统1. 内存存储2. 关系型数据库存储3. 文件存储（二）消息的存储和发送1. 消息存储（顺序写...
来源：博客园 2025-01-20 16:29 93
延迟消息延迟等级官方默认设置了18哥延迟等级1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h发送延迟消息：按照默认顺序1-18数字就对应上面的延迟时间Messagemsg=newMessage(TOPIC,TAG,"O...
来源：博客园 2024-10-06 21:29 93
情况说明在SpringBoot中集成了RocketMQ，实践过程中，通过RocketMQDashBoard观察，生产者可以正常将进行消息提交；通过日志及DashBoard观察，消费者成功在RocketMQ中进行了注册和订阅且观察到了消费者启动的日志行。问题是消费者依旧不会自动消费生产者提交的消息【....
来源：博客园 2024-09-16 00:29 91
1行业背景基金公司核心业务主要分为:投研线业务，即投资管理和行业研究业务，体现基金公司核心竞争力市场线业务，即基金公司利用自身渠道和市场能力完成基金销售并做好客户服务随互联网技术发展，基金销售渠道更加多元化，线上成为基金销售重要渠道。相比传统基金客户，线上渠道具有客户基数大，水平参差不齐...
来源：博客园 2024-08-27 22:29 56
前言由于个人学习测试需要，想要在debian11环境下，使用podman搭建一个简单的单节点rocketmq，搭建过程比较繁琐，所以记录下来留作后续参考。由于对rocketmq镜像不熟悉，有些配置可能存在错误，会在后续有能力优化时继续更新此文档。后续可能会补充podman-compose实现...
来源：博客园 2024-07-08 15:29 79
目录前言一、初识RocketMQ1.1基本模型二、基本概念2.1Producer2.2Consumer2.3Topic2.4Tag2.5Message2.6Broker2.7PullConsumer2.8ProducerGroup2.9ConsumerGroup2.10OrderedMessage三...
来源：博客园 2024-06-25 08:29 62
从零手写实现mq详细介绍一下rocketmqRocketMQ是由阿里巴巴开发的分布式消息队列系统，它是一个低延迟、高可靠、高吞吐量的消息中间件。RocketMQ最初是作为阿里巴巴的内部项目进行开发的，后来成为了Apache软件基金会下的顶级项目，以Apache许可证2.0发布，使其成为一个开...
来源：博客园 2024-02-29 22:29 58
Hopeisagoodthing,maybethebestofthings,andnogoodthingeverdies.希望是件美丽的东西，也许是最好的东西，而美好的东西是永远不会消逝的。大家好，我是勇哥。1024,程序员节，圆了我一个小小的梦。花了半年时间，我写了一本电子书，书名是：《...
来源：博客园 2023-10-24 02:00 90
在RocketMQ5.0以前，有两种集群部署模式，分别为主从模式（Master-Slave模式）和Dledger模式。主从模式主从模式中分为Master和Slave两个角色，集群中可以有多个Master节点，一个Master节点可以有多个Slave节点。Master节点负责接收生产者发送的写入请.....
来源：博客园 2023-10-16 10:00 99
Pop模式消费和消息粒度负载均衡在RocketMQ5.0之前，消费有两种方式可以从Broker获取消息，分别为Pull模式和Push模式。Pull模式：消费需要不断的从阻塞队列中获取数据，如果没有数据就等待，这个阻塞队列中的数据由消息拉取线程从Broker拉取消息之后加入的，所以Pull模式下...
来源：博客园 2023-10-13 10:30 87
为了向云原生演进，提高资源利用和弹性能力，RocketMQ在5.0进行了架构的调整与升级，先来看新特性之一，增加了Proxy层。增加Proxy代理层计算存储分离计算存储分离是一种分层架构，将计算层与存储层分开。计算层指的是一些消耗计算资源的功能模块比如协议解析、消费管理等，存储指的是数据存储...
来源：博客园 2023-10-11 13:30 93
RocketMQ在开启Dledger时，使用DLedgerCommitLog，其他情况使用的是CommitLog来管理消息的存储。在Dledger模式下，消息写入时Leader节点还需要将消息转发给Follower节点，有过半的节点响应成功，消息才算写入成功。Leader消息写入Dledger下.....
来源：博客园 2023-10-07 09:30 89
全局有序在RocketMQ中，如果使消息全局有序，可以为Topic设置一个消息队列，使用一个生产者单线程发送数据，消费者端也使用单线程进行消费，从而保证消息的全局有序，但是这种方式效率低，一般不使用。局部有序假设一个Topic分配了两个消息队列，生产者在发送消息的时候，可以对消息设置一个路由...
来源：博客园 2023-09-20 11:00 87
一致性首先来看RocketMQ的第一个特性-事务消息，事务消息是RocketMQ与一致性相关的特性，也是RocketMQ有别于其他消息队列的最具区分度的特性。以大规模电商系统为例，付款成功后会在交易系统中订单数据库将订单状态更新为已付款。然后交易系统再发送一条消息给RocketMQ，Rock...
来源：开源中国 2023-09-04 18:30 72
作者：隆基一致性首先来看RocketMQ的第一个特性-事务消息，事务消息是RocketMQ与一致性相关的特性，也是RocketMQ有别于其他消息队列的最具区分度的特性。以大规模电商系统为例，付款成功后会在交易系统中订单数据库将订单状态更新为已付款。然后交易系统再发送一条消息给RocketMQ...
来源：开源中国 2023-08-29 12:00 62
本文将从技术角度了解RocketMQ的云原生架构，了解RocketMQ如何基于一套统一的架构支撑多元化的场景。文章主要包含三部分内容。首先介绍RocketMQ5.0的核心概念和架构概览；然后从集群角度出发，从宏观视角学习RocketMQ的管控链路、数据链路、客户端和服务端如何交互；最后介绍消息队列....
来源：开源中国 2023-08-17 14:00 78
标签：RocketMq5.Dashboard；一、简介RocketMQ因其架构简单、业务功能丰富、具备极强可扩展性等特点被广泛应用，比如金融业务、互联网、大数据、物联网等领域的业务场景；二、环境部署1、编译打包1、下载5.0版本源码包rocketmq-all-5.0.0-source-...
来源：博客园 2023-08-17 09:30 68
手机查看
