WMQ基于 RabbitMQ 实现的消息中间件

WMQ 是用 Golang 编写的基于 RabbitMQ 实现的消息中间件，在系统架构对解耦现有业务起到至关重要的作用，服务基于 HTTP 的 API 方式具有跨语言的特点，接入十分简单。能够很好的解决并发控制，异步任务，以及消息订阅与分发.工作原理架构图如下：

特点:

• 跨语言，基于 HTTP 协议。

• 高性能，测试环境下消息生产速率达到3000个/s，而且性能毫无下降，瓶颈出现在后端 RabbitMQ 上。

• 提供了 web-ui 管理系统，对服务进行管理。

• 跨平台，运行简单，直接运行一个二进制文件。

• 支持集群部署，避免单点故障。

• 完全实现了 RabbitMQ 的 fanout、topic、direct 的消息模式,生产者可以按照需求生产不同 routing key 类型的消息，消费者在管理系统中可以随意订阅。

• 被动模式，一般情况下需要各种语言编写的程序与 RabbitMQ 建立持久的 tcp 连接，接受订阅的消息，这样的弊端很大，接入成本高，不易于维护。"被动模式"解决了这个问题，消费者只需要设置 routing key 和一个消费的 URL 接口即可,，然后有订阅的消息时，WMQ 会推送消息到这个 URL 接口上，接口被动接受数据处理即可。