WMQ v1.5 发布，go 实现的消息中间件

内容简介：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 消息中间件到底会不会丢消息
• 消息中间件面试题：如何保证消息不被重复消费

本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。