内容简介：NSQProxy是Golang开发的NSQ和Worker之间的中间件，根据数据库配置，负责消息转发。 在唱吧内部使用2年，高效稳定的处理着每日数十亿条消息。现将其开源，并定版本为v1.0.0。 NSQProxy启动后，接受NSQD队列的内容，...
NSQProxy是Golang开发的NSQ和Worker之间的中间件，根据数据库配置，负责消息转发。
在唱吧内部使用2年，高效稳定的处理着每日数十亿条消息。现将其开源，并定版本为v1.0.0。
NSQProxy启动后，接受NSQD队列的内容，然后通过HTTP/FastCGI/CBNSQ等协议转发给Worker机执行。流程图如下：
我们使用VUE开发了管理后台，方便对消费者进行配置和管控，如图：
解决的问题
- 各Topic执行机器可配
- 各Topic消费速度可配
- 各Worker机协议可配
- HTTP：将消息发送给配好的URL。
- FastCGI：将消息发送给配置的服务端，如PHP-FPM。
- CBNSQ：自定义的基于TCP的文本协议。
- 可视化界面管理
- 队列积压超出阈值报警
- 散乱在各处的消费者集中化管理
- 通过网络分发，无需安装.so等扩展库，因此无需修改线上环境
部署
Golang编写，部署及其简单，下载release可执行的二进制文件，直接在机器上运行即可。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持 码农网
猜你喜欢:
- IJPay 0.8 版本发布，兼容低版本 JDK
- fastjson 1.2.55 版本发布，Bug 修复版本
- Apache Ignite 2.9.1 版本发布，小版本更新
- Swoole v4.6.1 版本发布，Bug 修复版本
- Swoole v4.6.2 版本发布，Bug 修复版本
- Swoole v4.6.4 版本发布，Bug 修复版本
本站部分资源来源于网络，本站转载出于传递更多信息之目的，版权归原作者或者来源机构所有，如转载稿涉及版权问题，请联系我们。
