内容简介：WMQ 是用 golang 基于 RabbitMQ 实现的消息中间件,在系统架构对解耦现有业务起到至关重要的作用,服务基于 HTTP的API方式具有跨语言的特点,接入十分简单.能够很好的解决并发控制,异步任务,以及消息订阅与分发. 更新...
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接口上,接口被动接受数据处理即可.
【声明】文章转载自：开源中国社区 [http://www.oschina.net]
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
猜你喜欢:
- 消息中间件面试题：消息中间件的高可用
- 消息中间件RocketMQ消息发送
- 消息中间件面试题：消息丢失怎么办？
- 消息中间件面试题：如何保证消息的顺序性
- 刨根问底，Kafka 消息中间件到底会不会丢消息
- 消息中间件面试题：如何保证消息不被重复消费
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
