关于 RocketMQ 事务消息的正确打开方式 → 你学废了吗

开心一刻 昨晚和一哥们一起吃夜宵,点了几瓶啤酒 不一会天空下起了小雨,哥们突然道:糟了 我:怎么了 哥们:外面下雨了,我老婆还在等着我去接她 他给了自己一巴掌,说道:真他妈不是个东西 我心想:哥们真是个好丈夫 很快他补充道:喝酒怎么能分心呢 我一口啤酒直接笑喷而出 知识回顾 本文不讲什么是 Rock ... »

RocketMQ源码详解 | Consumer篇 · 其一:消息的 Pull 和 Push

概述 当消息被存储后,消费者就会将其消费。 这句话简要的概述了一条消息的最总去向,也引出了本文将讨论的问题: 消息什么时候才对被消费者可见? 是在 page cache 中吗?还是在落盘后?还是像 Kafka 一样维护了一个 ISR 队列,等到副本都将消息也落盘后才可见? 消息如何到达消费者手里? ... »

rocketmq广播消息的(五)

一、简介 广播消费指的是:一条消息被多个consumer消费,即使这些consumer属于同一个ConsumerGroup,消息也会被ConsumerGroup中的每个Consumer都消费一次,广播消费中ConsumerGroup概念可以认为在消息划分方面无意义。 二、代码 /** * 发布订阅消 ... »

rocketmq有序消息的(四)

opic的有序消息已经成为mq的标配。而RocketMQ中是这样区分消息类型的, 普通消息也叫做无序消息,简单来说就是没有顺序的消息,而有序消息就是按照一定的先后顺序的消息类型。举个例子,producer 依次发送 order id 为 1、2、3 的消息到 broker,consumer 接到的消 ... »

RocketMQ 5.0 POP 消费模式探秘

POP 作为一种全新的消费模式,解决了 Push 模式的一些痛点,使客户端无状态,更加轻量,消费逻辑也基本都收敛到了 Broker,对多语言的支持十分的友好。在 API 层面也与 Push 完成了融合,继承了 Push API 的简单易用,同时实现了 Push,POP 之间的自由切换。 ... »

alisystemsoftware

深入剖析 RocketMQ 源码 - 消息存储模块

消息队列是一种服务间异步通信方式,广泛应用于微服务架构设计中的解耦、异步、削峰等场景。消息在被处理和删除之前一直存储在队列上。RocketMQ 是 2012 年阿里巴巴开源的第三代分布式消息中间件,本文主要从源码角度讲述 RocketMQ 存储模块如何设计。 ... »

vivotech

RocketMQ Consumer 启动时都干了些啥?

可能我们对 RocketMQ 的消费者认知乍一想很简单,就是一个拿来消费消息的客户端而已,你只需要指定对应的 Topic 和 ConsumerGroup,剩下的就是只需要: 接收消息处理消息 就完事了。 简略消费模型 当然,可能在实际业务场景下,确实是这样。但是如果我们不清楚 Consumer 启动 ... »

detectiveHLH

消息队列扫盲(RocketMQ 入门)

消息队列扫盲 消息队列顾名思义就是存放消息的队列,队列我就不解释了,别告诉我你连队列都不知道似啥吧? 所以问题并不是消息队列是什么,而是 消息队列为什么会出现?消息队列能用来干什么?用它来干这些事会带 »

xzsj

基于消息队列 RocketMQ 的大型分布式应用上云最佳实践

Apache RocketMQ 作为阿里巴巴开源的支撑万亿级数据洪峰的分布式消息中间件,在众多行业广泛应用。在选型过程中,开发者一定会关注开源版与商业版的业务价值对比。 那么,今天就围绕着商业版本的消息队列 RocketMQ和开源版本 RocketMQ 进行比较,并结合实践中场景全面展示大型分布式应... ... »

alisystemsoftware

RocketMQ源码详解 | Broker篇 · 其二:文件系统

概述 在 Broker 的通用请求处理器将一个消息进行分发后,就来到了 Broker 的专门处理消息存储的业务处理器部分。本篇文章,我们将要探讨关于 RocketMQ 高效的原因之一:文件结构的良好设计与对 Page Cache 的极致"压榨"。 文件系统的结构设计 在 RocketMQ 的 Bro ... »

RocketMQ介绍与云服务器安装

RocketMQ 介绍与概念 在github上的说法来看: Apache RocketMQ是一个分布式消息传递和流媒体平台,具有低延迟,高性能和可靠性,万亿级容量和灵活的可扩展性。它提供了多种功能: »

wadmwz

RocketMQ源码详解 | Broker篇 · 其一:线程模型与接收链路

概述 在上一节 RocketMQ源码详解 | Producer篇 · 其二:消息组成、发送链路 中,我们终于将消息发送出了 Producer,在短暂的 tcp 握手后,很快它就会进入目的 Broker。这次我们来自底向上的看下 Broker 端是如何接收然后分发处理消息,同时了解 RocketMQ ... »

RocketMQ(一)——简介 - Bertha然

阿里巴巴有2大核心的分布式技术,一个是OceanBase,另一个就是RocketMQ。之前项目用过ActiveMQ,不论成熟度还是广泛度,ActiveMQ绝对是彪悍致极。而最近的项目,用的是Rocke »

1013wang

SpringCloud+RocketMQ实现分布式事务

随着互联网公司的微服务越来越多,分布式事务已经成为了我们的经常使用的。所以我们来一步一步的实现基于RocketMQ的分布式事务。接下来,我们将要做的主题写出来。 RocketMQ的分布式事务结构和说明 搭建RocketMQ步骤 事务场景,然后准备工程,运行代码 一、RocketMQ的分布式事务结构和 ... »

huangqingshi

阿里云服务器(ECS)上搭建rocketmq - 金色的鱼儿

搭建准备 阿里云服务器ECS一台 阿里云服务器的系统为CentOs7.8 阿里云安全组自定义添加规则9876端口 连接远程服务器的工具(比如说XShell,MobaXtrem) 云服务器已装环境jdk »

it-deepinmind