排序
重试任务该怎么设计?
我正在参加「掘金·启航计划」 简介 重试任务在分布式系统中也是经常使用到的一种策略,它的主要作用是在分布式事务执行过程中,出现一些不可避免的异常时,为了确保整个流程的完整性,主动发起...
【Pulsar学习笔记】架构初识
本篇主要介绍下Pulsar的分层架构及其优势 Pulsar 是基于云原生基础架构设计的一款消息队列,是Apache 软件基金会顶级项目。拥有诸多云原生应用特性,如无状态计算层、计算与存储分离,可以很好...
基于 DTS 同步 MySQL 全增量数据至 CKafka,构建实时数仓的最佳实践
背景介绍 随着 IT 技术与大数据的不断发展,越来越多的企业开始意识到数据的价值,通过大数据分析,可以帮助企业更深入地了解用户需求、更好地洞察市场趋势。目前大数据分析在每个业务运营中都...
何时使用Kafka而不是RabbitMQ
Kafka 和 RabbitMQ 都是流行的开源消息系统,它们可以在分布式系统中实现数据的可靠传输和处理。Kafka 和 RabbitMQ 有各自的优势和特点,它们适用于不同的场景和需求。本文将比较 Kafka 和 Rabb...
博客专栏 | 深入浅出之透析RocketMQ原理及实战指南
本文正在参加「金石计划 . 瓜分6万现金大奖」 前提概要 大家好,经过了6个月的消失后,终究我还是回来了,带回来了很多干货,接下来第一份礼物干货就是【RocketMQ入门到精通】,但是RocketMQ...
解密消息队列:应用场景、优点与比较,揭秘Kafka的构成与消息发送过程
我正在参加「掘金·启航计划」 之前公司一直都在使用RocketMQ作为主要的三方中间件,现在全部要求切换为kafka,所以就此我们需要详细了解一下kafka的作用,使用方式,以及坑点。在开始讲述之前...
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息顺序消费和并发消费机制体系的原理分析
DefaultMQPushConsumerImpl拉取消息 首先,DefaultMQPushConsumerImpl 是一个实现了 RocketMQ 的消费者客户端接口的类。该类的主要作用是从 RocketMQ 的 Broker 获取消息并进行消费。 主要可以...
零拷贝原理以及实践
大家好,我是蓝胖子,零拷贝技术相信大家都有所耳闻,但是今天呢,我不仅会讲述零拷贝技术的原理,并将从实际代码出发,看看零拷贝技术在golang中的应用。现在让我们开始吧。 零拷贝原理 零拷贝...
【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息消费长轮训机制体系的原理分析
DefaultMQPushConsumer 使用系统控制读取操作的DefaultMQPushConsumer可以自动调用传入的处理方法来处理收到的消息。通过设置各种参数和传入处理消息的函数,使用DefaultMQPushConsumer的主要目...
前端眼中的消息队列(NodeJs)
前端为什么要知道消息队列 可能有同学会疑惑,一个前端为什么要去知道后端的知识?安安心心的写自己的页面逻辑和前端界面不好吗?这肯定是好的,但是是建立在只写前端代码和没有打开BOSS招聘的...
微服务中「组件」集成
目录一、简介二、缓存管理三、消息队列四、搜索引擎五、定时任务六、数据存储七、参考源码 有品:There is no silver bullet; 一、简介 在微服务工程的技术选型中,会涉及到很多组件的集成,最...
Kafka两种集群详解和搭建教程
Kafka是一个能够支持高并发以及流式消息处理的消息中间件,并且Kafka天生就是支持集群的,今天就主要来介绍一下如何搭建Kafka集群。 Kafka目前支持使用Zookeeper模式搭建集群以及KRaft模式(即...
分布式流处理组件-理论篇:Broker
? 作者:谢先生。 2014年入行的程序猿。多年开发和架构经验。专注于Java、云原生、大数据等技术。从CRUD入行,负责过亿级流量架构的设计和落地,解决了千万级数据治理问题。 ? 微信公众号、B站...
MQ系列13:消息大量堆积如何为解决
MQ系列1:消息中间件执行原理MQ系列2:消息中间件的技术选型MQ系列3:RocketMQ 架构分析MQ系列4:NameServer 原理解析MQ系列5:RocketMQ消息的发送模式MQ系列6:消息的消费MQ系列7:消息通信,...
.Net全网最简RabbitMQ操作【强烈推荐】
【前言】 本文自1年前的1.0版本推出以来,已被业界大量科技公司采用。同时也得到了.Net圈内多位大佬的关注+推荐,文章也被多家顶级.Net/C#公众号转载。 现在更新到了7.0版本,更好的服务各位.Ne...
Redis系列14:使用List实现消息队列
Redis系列1:深刻理解高性能Redis的本质Redis系列2:数据持久化提高可用性Redis系列3:高可用之主从架构Redis系列4:高可用之Sentinel(哨兵模式)Redis系列5:深入分析Cluster 集群模式 追求性...
MQ系列12:如何保证消息顺序性
MQ系列1:消息中间件执行原理MQ系列2:消息中间件的技术选型MQ系列3:RocketMQ 架构分析MQ系列4:NameServer 原理解析MQ系列5:RocketMQ消息的发送模式MQ系列6:消息的消费MQ系列7:消息通信,...
Redis系列15:使用Stream实现消息队列(精讲)
Redis系列1:深刻理解高性能Redis的本质Redis系列2:数据持久化提高可用性Redis系列3:高可用之主从架构Redis系列4:高可用之Sentinel(哨兵模式)Redis系列5:深入分析Cluster 集群模式 追求性...