消息队列共0篇
消息队列
排序
Apache Pulsar 技术系列 – GEO replication 中订阅状态的同步原理
导语 Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO Replication）、快速扩容、灵活容错等特性，GEO Replication 可以原生支持...
2年前
分布式流处理组件-理论篇：Broker
? 作者：谢先生。 2014年入行的程序猿。多年开发和架构经验。专注于Java、云原生、大数据等技术。从CRUD入行，负责过亿级流量架构的设计和落地，解决了千万级数据治理问题。 ? 微信公众号、B站...
2年前
RocketMQ消息轨迹产生的背景以及使用方式
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 最近在维护RocketMQ经常会出现这种问题 消息发送方和接收方出现扯皮，消息发送方说我的消息已经...
2年前
【Pulsar学习笔记】架构初识
本篇主要介绍下Pulsar的分层架构及其优势 Pulsar 是基于云原生基础架构设计的一款消息队列，是Apache 软件基金会顶级项目。拥有诸多云原生应用特性，如无状态计算层、计算与存储分离，可以很好...
2年前
RocketMQ broker停写功能源码分析
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 在我们要平滑升级broker的时候，无损升级的最佳实践应该是 新broker启动 旧broker停写 旧broker...
2年前
Kafka两种集群详解和搭建教程
Kafka是一个能够支持高并发以及流式消息处理的消息中间件，并且Kafka天生就是支持集群的，今天就主要来介绍一下如何搭建Kafka集群。 Kafka目前支持使用Zookeeper模式搭建集群以及KRaft模式（即...
2年前
重试任务该怎么设计？
我正在参加「掘金·启航计划」 简介 重试任务在分布式系统中也是经常使用到的一种策略，它的主要作用是在分布式事务执行过程中，出现一些不可避免的异常时，为了确保整个流程的完整性，主动发起...
2年前
Apache pulsar 技术系列– 消息重推的几种方式
导语 Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO replication）、快速扩容、灵活容错等特性。在很多场景下，用户需要通过 M...
2年前
微服务中「组件」集成
目录一、简介二、缓存管理三、消息队列四、搜索引擎五、定时任务六、数据存储七、参考源码 有品：There is no silver bullet； 一、简介 在微服务工程的技术选型中，会涉及到很多组件的集成，最...
2年前
消息队列黄金三剑客：RabbitMQ、RocketMQ和Kafka全面对决，谁是最佳选择？
1、应用场景 1.RabbitMQ： 适用于易用性和灵活性要求较高的场景 异步任务处理：RabbitMQ提供可靠的消息传递机制，适用于处理异步任务，例如将耗时的任务放入消息队列中，然后由消费者异步处理，...
2年前
RocketMQ发送消息还有这种坑？遇到SYSTEM_BUSY不重试？
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 最近线上的RocketMQ集群遇到了如下问题，业务方的小伙伴反馈问题，说出现了...
2年前
前端眼中的消息队列（NodeJs）
前端为什么要知道消息队列 可能有同学会疑惑，一个前端为什么要去知道后端的知识？安安心心的写自己的页面逻辑和前端界面不好吗？这肯定是好的，但是是建立在只写前端代码和没有打开BOSS招聘的...
2年前
RabbitMQ基础入门（上）
说实话，看视频来来回回学习了RabbitMQ也有两遍了，也有跟着敲代码，不过每次都是过了不久就忘记了如何使用，今天又来复习RabbitMQ的使用了，这次我跟着官方文档一个一个模型来，我不信我还能忘...
2年前
3分钟白话RocketMQ系列—— 如何发送消息
白话3分钟，快速了解RocketMQ如何发送消息。 看完如果不了解，欢迎来打我。 我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。 那接下来，我们白话一下，RocketMQ是如何...
2年前【深入浅出RocketMQ原理及实战】「底层原理挖掘系列」透彻剖析贯穿RocketMQ的消息消费长轮训机制体系的原理分析
DefaultMQPushConsumer 使用系统控制读取操作的DefaultMQPushConsumer可以自动调用传入的处理方法来处理收到的消息。通过设置各种参数和传入处理消息的函数，使用DefaultMQPushConsumer的主要目...
2年前
消息队列20年：腾讯专家沉淀的MQ设计精要
腾小云导读 作者是腾讯 TDMQ 初创团队的成员，在多年的业务中台的实践中，也频繁地使用到了 MQ，比如最常见的消息推送，异常信息的重试等等，对消息队列有深刻的了解。此篇文章，作者会站在时间...
2年前
RocketMQ 5.x延时消息源码分析(不包含时间轮)
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 首先说明本次源码分析仅分析时间轮之前的延时消息设计 现在的RocketMQ已经...
2年前
零拷贝原理以及实践
大家好，我是蓝胖子，零拷贝技术相信大家都有所耳闻，但是今天呢，我不仅会讲述零拷贝技术的原理，并将从实际代码出发，看看零拷贝技术在golang中的应用。现在让我们开始吧。 零拷贝原理 零拷贝...
2年前
RocketMQ 5.0本地源码启动3Nameserve+2broker集群
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 由于RocketMQ 5.x主从同步的方式改动非常大，集群部署的方式也改动很大，所以打算本地启动一个...
2年前
Redis系列15：使用Stream实现消息队列（精讲）
Redis系列1：深刻理解高性能Redis的本质Redis系列2：数据持久化提高可用性Redis系列3：高可用之主从架构Redis系列4：高可用之Sentinel(哨兵模式）Redis系列5：深入分析Cluster 集群模式 追求性...
2年前