这篇文章，我们聊聊消息队列中非常重要的最佳实践之一：消费幂等。1 基础概念消费幂等是指：当出现 RocketMQ 消费者对某条消息重复消费的情况时，重复消费的结果与消费一次的结果是相同的，并且多次消费并未对业务系统产生任何负面影响。例如，在支付场景下，消费者消费扣款消息，对一笔订单执行扣款操
这篇文章，我们聊一聊 RocketMQ 的消息轨迹设计思路。查询消息轨迹可作为生产环境中排查问题强有力的数据支持 ，也是研发同学解决线上问题的重要武器之一。1 基础概念消息轨迹是指一条消息从生产者发送到 Broker , 再到消费者消费，整个过程中的各个相关节点的时间、状态等数据汇聚而成的完整
很多业务场景里，我们都需要发送短信，比如登陆验证码、告警、营销通知、节日祝福等等。这篇文章，我们聊聊 Java 应用中如何优雅的发送短信。1 客户端/服务端两种模式Java 应用中发送短信通常需要使用短信服务提供商提供的短信 API 。我们经常使用的短信渠道有：阿里云、腾讯云、华为云、亿美
本文主要是测试Ckafka的性能如何，作为一款商用的消息中间件，从消息的接收和处理，以及监控维度查看消息中间件的使用方便程度，比起自己搭建一个kafka的框架来说有什么省心的地方和优点缺点。
Hope is a good thing, maybe the best of things, and no good thing ever dies.希望是件美丽的东西，也许是最好的东西，而美好的东西是永远不会消逝的。大家好，我是勇哥 。1024 , 程序员节，圆了我一个小小的梦。花
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障
MQ系列1：消息中间件执行原理MQ系列2：消息中间件的技术选型MQ系列3：RocketMQ 架构分析MQ系列4：NameServer 原理解析MQ系列5：RocketMQ消息的发送模式MQ系列6：消息的消费MQ系列7：消息通信，追求极致性能 MQ系列8：数据存储，消息队列的高可用保障
这篇文章，笔者想聊聊 RocketMQ 最佳实践之一：保证订阅关系一致。订阅关系一致指的是同一个消费者 Group ID 下所有 Consumer 实例所订阅的 Topic 、Tag 必须完全一致。如果订阅关系不一致，消息消费的逻辑就会混乱，甚至导致消息丢失。1 订阅关系演示首先我们展示正确
文章目录前言架构设计名词说明生产10000数据总共耗时消费10000数据总共耗时最后单条消息消耗需要异步接收异步消费测试代码5000数据测试异步接收异步消费1万数据测试异步接收异步消费3万数据测试异
中间件
这次操作差点把自己送走
这次操作差点把自己送走起因自从RabbitMQ的版本从3.9.8升级到3.11.15之后就一直没有消停过，这不监控又在呼唤了。集群中的一个节点磁盘的增速超过了阈值，查看服务器进七天的磁盘使用量一直在缓慢的增长，不是一个好的预兆，如果一直增长下去就会触发集群的磁盘空间阻塞，这是最致命的，一旦由于磁
canal 是阿里知名的开源项目，主要用途是基于 MySQL 数据库增量日志解析，提供增量数据订阅和消费。这篇文章，我们手把手向同学们展示使用 canal 将 MySQL 增量数据同步到 ES 。1 集群模式图中 server 对应一个 canal 运行实例 ，对应一个 JVM 。ser
联系我们
