Skip to content

Latest commit

 

History

History
22 lines (18 loc) · 420 Bytes

README.md

File metadata and controls

22 lines (18 loc) · 420 Bytes

OhMyQueue

omq(OhMyQueue) is a distributed message queue

架构图

image

ohmq is a distributed message queue written in golang

DONE list:

  • Pub/Sub
  • 过期数据清理
  • backend storage使用rocks
  • 水平扩展

TODO list:

  • consumer group (load balance)
  • backend storage支持bitcask
  • cluster manager
  • 重构数据结构
  • 更改客户端连接逻辑