Skip to content

Latest commit

 

History

History

pmq

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 
 
 

pmq

1、基于内存Queue实现生产和消费API(已经完成) 1)创建内存Queue,作为底层消息存储 2)定义Topic,支持多个Topic 3)定义Producer,支持Send消息 4)定义Consumer,支持Poll消息

2、去掉内存Queue,设计自定义Queue,实现消息确认和消费offset 1)自定义内存Message数组模拟Queue。 2)使用指针记录当前消息写入位置。 3)对于每个命名消费者,用指针记录消费位置

设计思路

  • 1、基于内存Queue实现生产和消费API
  • 2、去掉内存Queue,设计自定义Queue,实现消息确认和消费offset