Wx_MQ 是一款运行于 Linux 操作系统，由 Golang 语言开发的分布式面向消息的中间件,能够实时存储和分发数据。
- 支持多种订阅模式（点对点和发布订阅），用户可根据不同应用场景选择消息消费模式
- 引入 Zookeeper 存储元数据，保证数据一致性和高可用
- 多种同步副本方式，根据 ack 机制选择同步方式
- 支持分布式，可以提高可扩展性和容错性
- 采用 SSTable 标记索引位置，加速消息索引查询
- 顺序读写磁盘，提高数据读写速率
Wx_MQ 使用 cloudwego 的 kitex 作为 rpc 框架，所以需要先安装 kitex
- 安装 Go：https://golang.org/
- 安装 kitex：go install github.com/cloudwego/kitex/tool/cmd/kitex@latest
- 安装 thriftgo：go install github.com/cloudwego/thriftgo@latest
可参考kitex
安装 Wx_MQ：
- 拉取 zhuMQ
git clone [email protected]:wxnzb/Wx_MQ.git
- 使用 kitex 生成 RPC 代码
cd Wx_MQ
kitex -module Wx_MQ operations.thrift
kitex -module Wx_MQ raftoperations.thrift