MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 1 介绍 前面的章节我学习了 NameServer的原理，消息的生产发送，以及消息
MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 1 介绍 在之前的章节中，我们介绍了消息的发送
MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障 1
MQ系列1：消息中间件执行原理 MQ系列2：消息中间件的技术选型 MQ系列3：RocketMQ 架构分析 MQ系列4：NameServer 原理解析 MQ系列5：RocketMQ消息的发送模式 MQ系列6：消息的消费 MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障 M
何谓家装？过去，人们辗转于各大家装城，购买时下流行的家具装饰，参考各类“过来人”和设计师的意见，糅杂一些样板间风格，依靠想象拼凑一个设计方案。而今天，在年轻一代的消费群体心中，家装的意义正发生深刻改变：要自由定义，坚决悦己，实用与美观兼得；要猫与鱼，花与叶，喜欢的音乐，收藏的手办都有自己的天地；要一
从录音带、MP3到专业的耳机、音箱，随着音乐消费方式的不断升级，音乐创作的专业“门槛”也在AI技术的加持下逐渐大众化，创作者的创新设计、创作频率也在持续增强，能降低创作门槛且智能化的创作工具就显得尤为重要。 怀揣着“人人都能玩点音乐”的初衷，唱鸭搭建了自己的音乐社区，希望为普通用户提供智能有趣的音乐
当下，汽车行业已慢慢由曾经的增量市场逐步转变为存量市场。更年轻的消费群体偏好、更精准智能的营销投放策略和强势入局的新能源汽车等因素都在推动着汽车行业的不断发展。对于汽车厂商和垂域媒体来说，进行丰富的人群洞察与用户分层，能挖掘更多用户生命周期内的价值。 联合建模，精准拉新 随着电商与短视频的快速发展，
CDC CDC 是 Change Data Capture(变更数据获取)的简称。核心思想是，监测并捕获数据库的变动（包括数据或数据表的插入、更新以及删除等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 CDC 的种类 CDC 主要分为基于查询和基于 Binl
一篇解决 —— 报税系统的分析与解决方案 中国征税税种极为广泛，包括所得税（企业所得税和个人所得税）、间接税（增值税和消费税）、与房地产相关的税（土地增值税、房产税、耕地占用税和城镇土地使用税）和其它税种等。对于大部分个人来说，报税可能并不是十分繁杂。但对于企业来说，在不断演变的税收环境下，企业需要
最近在新发布某个项目上线时，每次重启都会收到机器的 CPU 使用率告警，查看对应监控，持续时长达 5 分钟，对于服务重启有很大风险。而该项目有非常多 Consumer 消费，服务启动后会有大量线程去拉取消息处理逻辑，通过多次 Jstack 输出线程快照发现有很多 BLOCKED 状态线程，此文主要记录分析 BLOCKED 原因。
如果你的MQ消息要从Kafka切换到RocketMQ且不停机，怎么做？在让这个MQ消息调用第三方发奖接口，但无幂等字段又怎么处理？今天小傅哥就给大家分享一个关于MQ消息在这样的场景中的处理手段。 这是一种比较特例的场景，需要保证切换的MQ消息不被两端同时消费，并且还需要在一段消费失败后的MQ还可以继
INFINI Labs 产品又更新啦~，包括 Easysearch v1.8.0、Gateway、Console、Agent、Loadgen v1.25.0。本次各产品更新了很多亮点功能，如 Easysearch 新增数据写入限流功能，可实现节点、分片级限流；Gateway 修复数据迁移过程中因消费
Kafka 是一个分布式流处理平台和消息系统，用于构建实时数据管道和流应用。它最初由 LinkedIn 开发，后来成为 Apache 软件基金会的顶级项目。 Kafka 特点是高吞吐量、分布式架构、支持持久化、集群水平扩展和消费组消息消费，具体来说： 高吞吐量：Kafka 具有高性能和低延迟的特性，
短剧高温下，谈谈AIGC的助攻路线。 短剧，一个席卷全球的高温赛道。 以往只是踏着霸总题材，如今，内容循着精品化、IP化的自然发展风向，给内容、制作、平台等产业全链都带来新机，也让短剧消费走向文化深处，触发更大的社会渲染力。 从国内到全球，短剧行业亦然乘风。业内预测分析，2027年海外微短剧市场规模
CDC是(Change Data Capture变更数据获取)的简称。 核心思想是，监测并捕获数据库的变动（包括数据 或 数据表的插入INSERT、更新UPDATE、删除DELETE等），将这些变更按发生的顺序完整记录下来，写入到消息中间件中以供其他服务进行订阅及消费。 ## Flink CDC的设
https://zhuanlan.zhihu.com/p/128552232 导读 上一篇写了共享存储的概述以及一个简单的案例演示。这一篇就写一下PV和PVC。 PV是对底层网络共享存储的抽象，将共享存储定义为一种“资源”，比如Node也是容器应用可以消费的资源。PV由管理员创建和配置，与共享存储的
摘要：本文由葡萄城技术团队于博客园原创并首发。转载请注明出处：[葡萄城官网](https://www.grapecity.com.cn/)，葡萄城为开发者提供专业的开发工具、解决方案和服务，赋能开发者。 前一段时间淘宝出了一个“淘宝人生”的模块，可以看从注册淘宝账号至今的消费记录，仔细想了想，现在微
作者：胡济麟 1、背景介绍 1.1 直播业务特点 互联网视频直播是一种消息媒介形态，提供时产时消的内容，经过多年，已经发展出秀场、游戏、电商、体育等多种业务形态。主要特点是：内容实时产生实时消费，对时效性要求更高；流媒体内容占用带宽大，对网络质量要求更苛刻；一人生产、多人消费，带宽规模大。直播 CD
为了向云原生演进，提高资源利用和弹性能力，RcoketMQ在5.0进行了架构的调整与升级，先来看新特性之一，增加了Proxy层。 增加Proxy代理层 计算存储分离 计算存储分离是一种分层架构，将计算层与存储层分开。 计算层指的是一些消耗计算资源的功能模块比如协议解析、消费管理等，存储指的是数据存储
Kafka 和传统的消息系统(也称作消息中间件)都具备系统解耦、冗余存储、流量削峰、缓冲、异步通信、扩展性、可恢复性等功能。与此同时，Kafka 还提供了大多数消息系统难以实现的消息顺序性保障及回溯消费的功能。
