排序
消息队列20年:腾讯专家沉淀的MQ设计精要
腾小云导读 作者是腾讯 TDMQ 初创团队的成员,在多年的业务中台的实践中,也频繁地使用到了 MQ,比如最常见的消息推送,异常信息的重试等等,对消息队列有深刻的了解。此篇文章,作者会站在时间...
RocketMQ 5.x延时消息源码分析(不包含时间轮)
这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发。拒绝营销号,拒绝标题党 RocketMQ版本 5.1.0 背景 首先说明本次源码分析仅分析时间轮之前的延时消息设计 现在的RocketMQ已经...
零拷贝原理以及实践
大家好,我是蓝胖子,零拷贝技术相信大家都有所耳闻,但是今天呢,我不仅会讲述零拷贝技术的原理,并将从实际代码出发,看看零拷贝技术在golang中的应用。现在让我们开始吧。 零拷贝原理 零拷贝...
RocketMQ 5.0本地源码启动3Nameserve+2broker集群
这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发。拒绝营销号,拒绝标题党 背景 由于RocketMQ 5.x主从同步的方式改动非常大,集群部署的方式也改动很大,所以打算本地启动一个...
Redis系列15:使用Stream实现消息队列(精讲)
Redis系列1:深刻理解高性能Redis的本质Redis系列2:数据持久化提高可用性Redis系列3:高可用之主从架构Redis系列4:高可用之Sentinel(哨兵模式)Redis系列5:深入分析Cluster 集群模式 追求性...
从 Pulsar Client 的原理到它的监控面板
背景 前段时间业务团队偶尔会碰到一些 Pulsar 使用的问题,比如消息阻塞不消费了、生产者消息发送缓慢等各种问题。 虽然我们有个监控页面可以根据 topic 维度查看他的发送状态,比如速率、流量...
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
DefaultMQPushConsumerImpl拉取消息 首先,DefaultMQPushConsumerImpl 是一个实现了 RocketMQ 的消费者客户端接口的类。该类的主要作用是从 RocketMQ 的 Broker 获取消息并进行消费。 主要可以...
消息队列 CKafka 跨洋数据同步性能优化
导语 本文主要介绍了 CKafka 在跨洋场景中遇到的一个地域间数据同步延时大的问题,跨地域延时问题比较典型,所以详细记录下来做个总结。 一. 背景 为了满足客户跨地域容灾、冷备的诉求,消息队...
MQ系列12:如何保证消息顺序性
MQ系列1:消息中间件执行原理MQ系列2:消息中间件的技术选型MQ系列3:RocketMQ 架构分析MQ系列4:NameServer 原理解析MQ系列5:RocketMQ消息的发送模式MQ系列6:消息的消费MQ系列7:消息通信,...
谈谈 Kafka 的幂等性 Producer
使用消息队列,我们肯定希望不丢消息,也就是消息队列组件,需要保证消息的可靠交付。消息交付的可靠性保障,有以下三种承诺: 最多一次(at most once):消息可能会丢失,但绝不会被重复发送...
解密消息队列:应用场景、优点与比较,揭秘Kafka的构成与消息发送过程
我正在参加「掘金·启航计划」 之前公司一直都在使用RocketMQ作为主要的三方中间件,现在全部要求切换为kafka,所以就此我们需要详细了解一下kafka的作用,使用方式,以及坑点。在开始讲述之前...
从源码角度聊聊RocketMQ 消息(文件)删除机制
这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发。拒绝营销号,拒绝标题党 RocketMQ版本 5.1.0 入口 这里消息删除的源码入口其实不太好直接确定,我们可以通过启动broker的代码...
Redis系列14:使用List实现消息队列
Redis系列1:深刻理解高性能Redis的本质Redis系列2:数据持久化提高可用性Redis系列3:高可用之主从架构Redis系列4:高可用之Sentinel(哨兵模式)Redis系列5:深入分析Cluster 集群模式 追求性...
RocketMQ 5.x broker注册到Nameserve源码分析
这里是weihubeats,觉得文章不错可以关注公众号小奏技术,文章首发。拒绝营销号,拒绝标题党 RocketMQ版本 5.1.0 背景 入口 这里源码入口我们就从broker启动开始查看吧,然后慢慢到NameServer 由...
博客专栏 | 深入浅出之透析RocketMQ原理及实战指南
本文正在参加「金石计划 . 瓜分6万现金大奖」 前提概要 大家好,经过了6个月的消失后,终究我还是回来了,带回来了很多干货,接下来第一份礼物干货就是【RocketMQ入门到精通】,但是RocketMQ...
golang微服务框架Kratos实现分布式任务队列
golang微服务框架Kratos实现分布式任务队列 **任务队列(Task Queue)**一般用于线程或计算机之间分配工作的一种机制。其本质是生产者消费者模型,生产者发送任务到消息队列,消费者负责处理任...
.Net全网最简RabbitMQ操作【强烈推荐】
【前言】 本文自1年前的1.0版本推出以来,已被业界大量科技公司采用。同时也得到了.Net圈内多位大佬的关注+推荐,文章也被多家顶级.Net/C#公众号转载。 现在更新到了7.0版本,更好的服务各位.Ne...
RocketMQ Linux单机测试:简易快速部署指南及Dashboard控制台部署
目录简介开始下载增加环境变量修改启动文件jvm大小修改rocketmq配置文件启动快速测试关闭Dashboard下载Dashboard已编译jar包网盘下载启动命令可能遇到的问题写在最后 简介 请注意,本博客仅供初...