WMQ是用Golang编写的基于RabbitMQ实现的消息中间件，在系统架构对解耦现有业务起到至关重要的作用，服务基于HTTP的API方式具有跨语言的特点，接入十分简单。能够很好的解决并发控制，异步任务，以及消息订阅与分发.工作原理架构图如下：
特点:
跨语言，基于HTTP协议。
高性能，测试环境下消息生产速率达到3000个/s，而且性能毫无下降，瓶颈出现在后端RabbitMQ上。
提供了web-ui管理系统，对服务进行管理。
跨平台，运行简单，直接运行一个二进制文件。
支持集群部署，避免单点故障。
完全实现了RabbitMQ的fanout、topic、direct的消息模式,生产者可以按照需求生产不同routingkey类型的消息，消费者在管理系统中可以随意订阅。
被动模式，一般情况下需要各种语言编写的程序与RabbitMQ建立持久的tcp连接，接受订阅的消息，这样的弊端很大，接入成本高，不易于维护。"被动模式"解决了这个问题，消费者只需要设置routingkey和一个消费的URL接口即可,，然后有订阅的消息时，WMQ会推送消息到这个URL接口上，接口被动接受数据处理即可。
评论