消息队列共0篇
消息队列
排序
RocketMQ消息轨迹产生的背景以及使用方式
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 最近在维护RocketMQ经常会出现这种问题 消息发送方和接收方出现扯皮，消息发送方说我的消息已经...
2年前
RocketMQ 5.x如何使用GRPC方式发送消费消息
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 我们都知道RocketMQ 5.x新增了proxy模式部署方式，也就是支持了GRPC的消费...
2年前
RocketMQ Linux单机测试：简易快速部署指南及Dashboard控制台部署
目录简介开始下载增加环境变量修改启动文件jvm大小修改rocketmq配置文件启动快速测试关闭Dashboard下载Dashboard已编译jar包网盘下载启动命令可能遇到的问题写在最后 简介 请注意，本博客仅供初...
2年前
RocketMQ 5.x broker注册到Nameserve源码分析
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 入口 这里源码入口我们就从broker启动开始查看吧，然后慢慢到NameServer 由...
2年前
从 Pulsar Client 的原理到它的监控面板
背景 前段时间业务团队偶尔会碰到一些 Pulsar 使用的问题，比如消息阻塞不消费了、生产者消息发送缓慢等各种问题。 虽然我们有个监控页面可以根据 topic 维度查看他的发送状态，比如速率、流量...
2年前谈谈 Kafka 的幂等性 Producer
使用消息队列，我们肯定希望不丢消息，也就是消息队列组件，需要保证消息的可靠交付。消息交付的可靠性保障，有以下三种承诺： 最多一次（at most once）：消息可能会丢失，但绝不会被重复发送...
2年前
RocketMQ 5.x延时消息源码分析(不包含时间轮)
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 首先说明本次源码分析仅分析时间轮之前的延时消息设计 现在的RocketMQ已经...
2年前
3分钟白话RocketMQ系列—— 如何发送消息
白话3分钟，快速了解RocketMQ如何发送消息。 看完如果不了解，欢迎来打我。 我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。 那接下来，我们白话一下，RocketMQ是如何...
2年前
RocketMQ发送消息还有这种坑？遇到SYSTEM_BUSY不重试？
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 最近线上的RocketMQ集群遇到了如下问题，业务方的小伙伴反馈问题，说出现了...
2年前
Apache pulsar 技术系列– 消息重推的几种方式
导语 Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO replication）、快速扩容、灵活容错等特性。在很多场景下，用户需要通过 M...
2年前
RocketMQ broker停写功能源码分析
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 在我们要平滑升级broker的时候，无损升级的最佳实践应该是 新broker启动 旧broker停写 旧broker...
2年前
Apache Pulsar 技术系列 – GEO replication 中订阅状态的同步原理
导语 Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO Replication）、快速扩容、灵活容错等特性，GEO Replication 可以原生支持...
2年前
3分钟白话RocketMQ系列—— 核心概念
白话3分钟，快速了解RocketMQ基础，包括适用场景，以及基本概念。 看完如果不了解，欢迎来打我。 关键字摘要 低延迟、高可用、高可靠、高并发 的消息中间件 适合在线业务 分为producer、consume...
2年前
golang微服务框架Kratos实现分布式任务队列
golang微服务框架Kratos实现分布式任务队列 **任务队列（Task Queue）**一般用于线程或计算机之间分配工作的一种机制。其本质是生产者消费者模型，生产者发送任务到消息队列，消费者负责处理任...
2年前
从源码角度聊聊RocketMQ 消息(文件)删除机制
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 入口 这里消息删除的源码入口其实不太好直接确定，我们可以通过启动broker的代码...
2年前
消息队列 CKafka 跨洋数据同步性能优化
导语 本文主要介绍了 CKafka 在跨洋场景中遇到的一个地域间数据同步延时大的问题，跨地域延时问题比较典型，所以详细记录下来做个总结。 一. 背景 为了满足客户跨地域容灾、冷备的诉求，消息队...
2年前
RocketMQ 5.0本地源码启动3Nameserve+2broker集群
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 由于RocketMQ 5.x主从同步的方式改动非常大，集群部署的方式也改动很大，所以打算本地启动一个...
2年前
消息队列20年：腾讯专家沉淀的MQ设计精要
腾小云导读 作者是腾讯 TDMQ 初创团队的成员，在多年的业务中台的实践中，也频繁地使用到了 MQ，比如最常见的消息推送，异常信息的重试等等，对消息队列有深刻的了解。此篇文章，作者会站在时间...
2年前
RabbitMQ基础入门（上）
说实话，看视频来来回回学习了RabbitMQ也有两遍了，也有跟着敲代码，不过每次都是过了不久就忘记了如何使用，今天又来复习RabbitMQ的使用了，这次我跟着官方文档一个一个模型来，我不信我还能忘...
2年前
消息队列黄金三剑客：RabbitMQ、RocketMQ和Kafka全面对决，谁是最佳选择？
1、应用场景 1.RabbitMQ： 适用于易用性和灵活性要求较高的场景 异步任务处理：RabbitMQ提供可靠的消息传递机制，适用于处理异步任务，例如将耗时的任务放入消息队列中，然后由消费者异步处理，...
2年前