半年多以前写过一篇《300 行代码实现一个消息队列》，实现了一个最简单的消息队列，能够把消息事件放到异步去处理。但随着业务的发展，简单的异步处理已经不能满足需求了：一条消息需要被多个不同的消费者消费。

按照原先的消息队列设计，要实现这个需求，要么是多注册几个队列，生产者往多个队列发消息；要么是在消费者那多开几个协程去分别处理。但这两种方案都高耦合，很不优雅。

优雅的方案应该是引入一个负责转发消息的中间层，生产者只需要将消息发给这个中间层，再由中间层转发给不同的队列（消费者），这个中间层我们称为 Exchange

- 阅读剩余部分 -