消息队列共0篇
消息队列
排序
golang微服务框架Kratos实现分布式任务队列
golang微服务框架Kratos实现分布式任务队列 **任务队列（Task Queue）**一般用于线程或计算机之间分配工作的一种机制。其本质是生产者消费者模型，生产者发送任务到消息队列，消费者负责处理任...
2年前
RocketMQ Linux单机测试：简易快速部署指南及Dashboard控制台部署
目录简介开始下载增加环境变量修改启动文件jvm大小修改rocketmq配置文件启动快速测试关闭Dashboard下载Dashboard已编译jar包网盘下载启动命令可能遇到的问题写在最后 简介 请注意，本博客仅供初...
2年前
从 Pulsar Client 的原理到它的监控面板
背景 前段时间业务团队偶尔会碰到一些 Pulsar 使用的问题，比如消息阻塞不消费了、生产者消息发送缓慢等各种问题。 虽然我们有个监控页面可以根据 topic 维度查看他的发送状态，比如速率、流量...
2年前
RocketMQ broker停写功能源码分析
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 在我们要平滑升级broker的时候，无损升级的最佳实践应该是 新broker启动 旧broker停写 旧broker...
2年前
博客专栏 | 深入浅出之透析RocketMQ原理及实战指南
本文正在参加「金石计划 . 瓜分6万现金大奖」 前提概要 大家好，经过了6个月的消失后，终究我还是回来了，带回来了很多干货，接下来第一份礼物干货就是【RocketMQ入门到精通】，但是RocketMQ...
2年前
RabbitMQ基础入门（上）
说实话，看视频来来回回学习了RabbitMQ也有两遍了，也有跟着敲代码，不过每次都是过了不久就忘记了如何使用，今天又来复习RabbitMQ的使用了，这次我跟着官方文档一个一个模型来，我不信我还能忘...
2年前
从源码角度聊聊RocketMQ 消息(文件)删除机制
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 入口 这里消息删除的源码入口其实不太好直接确定，我们可以通过启动broker的代码...
2年前
前端眼中的消息队列（NodeJs）
前端为什么要知道消息队列 可能有同学会疑惑，一个前端为什么要去知道后端的知识？安安心心的写自己的页面逻辑和前端界面不好吗？这肯定是好的，但是是建立在只写前端代码和没有打开BOSS招聘的...
2年前
RocketMQ消息轨迹产生的背景以及使用方式
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 背景 最近在维护RocketMQ经常会出现这种问题 消息发送方和接收方出现扯皮，消息发送方说我的消息已经...
2年前
RocketMQ 5.x broker注册到Nameserve源码分析
这里是weihubeats,觉得文章不错可以关注公众号小奏技术，文章首发。拒绝营销号，拒绝标题党 RocketMQ版本 5.1.0 背景 入口 这里源码入口我们就从broker启动开始查看吧，然后慢慢到NameServer 由...
2年前
Apache pulsar 技术系列– 消息重推的几种方式
导语 Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO replication）、快速扩容、灵活容错等特性。在很多场景下，用户需要通过 M...
2年前
消息队列 CKafka 跨洋数据同步性能优化
导语 本文主要介绍了 CKafka 在跨洋场景中遇到的一个地域间数据同步延时大的问题，跨地域延时问题比较典型，所以详细记录下来做个总结。 一. 背景 为了满足客户跨地域容灾、冷备的诉求，消息队...
2年前
解密消息队列：应用场景、优点与比较，揭秘Kafka的构成与消息发送过程
我正在参加「掘金·启航计划」 之前公司一直都在使用RocketMQ作为主要的三方中间件，现在全部要求切换为kafka，所以就此我们需要详细了解一下kafka的作用，使用方式，以及坑点。在开始讲述之前...
2年前
Redis系列14：使用List实现消息队列
Redis系列1：深刻理解高性能Redis的本质Redis系列2：数据持久化提高可用性Redis系列3：高可用之主从架构Redis系列4：高可用之Sentinel(哨兵模式）Redis系列5：深入分析Cluster 集群模式 追求性...
2年前
分布式流处理组件-理论篇：Broker
? 作者：谢先生。 2014年入行的程序猿。多年开发和架构经验。专注于Java、云原生、大数据等技术。从CRUD入行，负责过亿级流量架构的设计和落地，解决了千万级数据治理问题。 ? 微信公众号、B站...
2年前
【Pulsar学习笔记】架构初识
本篇主要介绍下Pulsar的分层架构及其优势 Pulsar 是基于云原生基础架构设计的一款消息队列，是Apache 软件基金会顶级项目。拥有诸多云原生应用特性，如无状态计算层、计算与存储分离，可以很好...
2年前
重试任务该怎么设计？
我正在参加「掘金·启航计划」 简介 重试任务在分布式系统中也是经常使用到的一种策略，它的主要作用是在分布式事务执行过程中，出现一些不可避免的异常时，为了确保整个流程的完整性，主动发起...
2年前
3分钟白话RocketMQ系列—— 如何发送消息
白话3分钟，快速了解RocketMQ如何发送消息。 看完如果不了解，欢迎来打我。 我们知道RocketMQ主要分为消息 生产、存储（消息堆积）、消费 三大块领域。 那接下来，我们白话一下，RocketMQ是如何...
2年前
基于 DTS 同步 MySQL 全增量数据至 CKafka，构建实时数仓的最佳实践
背景介绍 随着 IT 技术与大数据的不断发展，越来越多的企业开始意识到数据的价值，通过大数据分析，可以帮助企业更深入地了解用户需求、更好地洞察市场趋势。目前大数据分析在每个业务运营中都...
2年前
Apache Pulsar 技术系列 – GEO replication 中订阅状态的同步原理
导语 Apache Pulsar 是一个多租户、高性能的服务间消息传输解决方案，支持多租户、低延时、读写分离、跨地域复制（GEO Replication）、快速扩容、灵活容错等特性，GEO Replication 可以原生支持...
2年前