WMQ 是用 golang 基于 RabbitMQ 实现的消息中间件,在系统架构对解耦现有业务起到至关重要的作用,服务基于 HTTP的API方式具有跨语言的特点,接入十分简单.能够很好的解决并发控制,异步任务,以及消息订阅与分发.
更新内容:
-
更新了日志组件,解决了日志组组件导致 cpu 过高的问题.
-
修复连接池的一些小 bug.
WMQ 特点:
-
跨语言,基于HTTP协议.
-
高性能,测试环境下消息生产速率达到3000个/s,而且性能毫无下降,瓶颈出现在后端RabbitMQ上.
-
提供了web-ui管理系统,对服务进行管理
-
跨平台,运行简单,直接运行一个二进制文件.
-
支持集群部署,避免单点故障.
-
完全实现了RabbitMQ的fanout,topic,direct的消息模式,生产者可以按照需求生产不同routing key类型的消息,消费者在管理系统中可以随意订阅.
-
被动模式,一般情况下需要各种语言编写的程序与RabbitMQ建立持久的tcp连接,接受订阅的消息,这样的弊端很大,接入成本高,不易于维护."被动模式"解决了这个问题,消费者只需要设置routing key和一个消费的URL接口即可,然后有订阅的消息时,WMQ会推送消息到这个URL接口上,接口被动接受数据处理即可.
注：本文内容来自互联网，旨在为开发者提供分享、交流的平台。如有涉及文章版权等事宜，请你联系站长进行处理。