/PDMQ

Pengge-Distributed-Message-Queue 自己实现的消息队列

Primary LanguageGo

PDMQ

由于最近在学习go语言,并且nsq是go语言编写的一个分布式消息队列中间件,用来处理每天数十亿级别的消息推送。
NSQ 具有分布式和去中心化拓扑结构,该结构具有无单点故障、故障容错、高可用性以及能够保证消息的可靠传递的特征,
是一个成熟的、已在大规模生成环境下应用的产品。

第一步:认识NSQ

image

第二步:PDMQD的基本功能实现

1.PDMQD 跟nsq 一致,是采用go语言进行编写,这样能够最大化契合nsq的代码开发模式
2.实现最基本的生产者与消费者的交互以及消息的投递
  - 具体是:pdmqd 实现 tcp ,http 两种协议的监听,
  - consumer保持与pdmqd的连接
  - 支持API 的消息投递
  - 支持多种配置加载 终端配置>默认配置文件配置
3.消息分发与nsq完全相同,分为topic->channel->consumer形式
4.发送的时所有消息使用统一的消息结构体(这与nsq 略有不同,并且消息体也不相同)

第三步:如何安装与使用

查看INSTALL