RabbitMQ - 元视角

编程语言

七种武器：延迟队列的原理和实现总结本文探讨了延迟队列的概念和实现方式，从DelayQueue介绍到具体的实现方式包括Java的DelayQueue、.NET中的PriorityQueue、基于Redis的Key过期机制和ZSet结构、使用Quartz实现延时任务、以及基于RabbitMQ实现延迟队列等。文章指出延迟队列适用于需要延迟执行的场合，提到延时满足是一种高级快乐，有助于培养和付出。各种实现方式都展示了不同的延迟队列应用场景和技术实现，为读者深入了解延迟队列提供了丰富的参考和思路。

DelayQueue Quartz Redis RabbitMQ

2022-03-07

数据存储

利用 MySQL 的 Binlog 实现数据同步与订阅(下)：EventBus 篇这篇博客总结了关于利用MySQL的Binlog实现数据同步与订阅的过程。通过Python-Mysql-Replication项目读取Binlog并解析，然后将其发布到EventBus中，在.NET Core中提供Web API接口实现发布功能。针对不同事件编写对应的EventHandler来订阅这些Binlog，实现事件驱动。介绍了自定义序列化器解决JSON序列化问题，以及注册EventHandler和EventBus的步骤。最终实现了数据同步与订阅的想法，展示了Python读取Binlog、.NET Core消费Binlog和RabbitMQ Dashboard的效果。整个过程中，通过Binlog和EventBus实现了事件系统的统一调度，简化了事件处理流程，提高系统接口的吞吐性能。

Binlog RabbitMQ MySQL

2020-07-31

数据存储

利用 MySQL 的 Binlog 实现数据同步与订阅(中)：RabbitMQ 篇本文深入探讨了事件总线(EventBus)的概念、设计和实现，通过实现一个基于 RabbitMQ 的 EventBus，展示了发布-订阅模式在分布式系统中的应用。文章首先阐述了 EventBus 的设计原则和核心组件，包括事件发布、订阅与退订接口，以及事件处理器的注册机制。接着，通过具体的代码示例，详细解释了基于 RabbitMQ 的 EventBus 实现，包括消息的发布、订阅与取消订阅，以及事件处理流程。此外，文章还讨论了 RabbitMQ 的一些高级特性，如消息的持久化、死信机制、重试与超时策略，以及四种交换器模式。最后，作者对 EventBus 在领域驱动设计(DDD)中的作用进行了总结，并预告了下一篇博客将介绍如何通过 Python-Mysql-Replication 实现 Binlog 的发布。

RabbitMQ EventBus 事件订阅

2020-07-15

标签：RabbitMQ