NSQProxy NSQProxy启动后，接受NSQD内容，然后通过HTTP / FastCGI / CBNSQ等协议转发给Worker机执行。在唱吧内部使用2年，高效稳定的处理着每日数十亿条消息。 解决的问题 各主题执行机器可配 各主题消费速度可配 各工人机协议可配 HTTP：将消息发送给配好的URL。 FastCGI：将消息发送给配置的服务端，如PHP-FPM。 CBNSQ：自定义的基于TCP的文本协议。 可视化界面管理 体积积压超过阈值报警 散乱在处境的消费者集中化管理 通过网络分发