README

初始化

go get  github.com/yoozoo/protomq
protomq init

php项目需要先使用composer安装依赖

composer require google/protobuf
composer require spiral/roadrunner

go get github.com/spiral/roadrunner
go get -u github.com/golang/protobuf/protoc-gen-go

生成go 生产者客户端

./protomq.exe gen --lang=goproducer ./output_folder ./test.proto

生成go 消费者服务器端

./protomq.exe gen --lang=goconsumer ./output_folder ./test.proto

生成php 消费者服务器端详情在这里。另外php 消费者简单类型服务器端的文档在这里这里。

生成php 生产者客户端详情在这里。

protomq 命令行界面
- 自动下载protoc
- 内嵌protomq.proto
- 嵌套调用protoc
- protoc文件语法检查、错误提示
  - topic缺失、重复
  - proto命名空间检查
  - language命名空间检查
- CI
- 消息大小限制、检查
- 统计整合
- 示例 / 指南
集成Prometheus
kafka
- 自动控制partition？
php
- 客户端 / 生产者
- 处理器
- 支持7.X
- 能否支持 5.x？()
- 使用context传递key？
- go并发？
- 控制回收？
go
- 工作池
测试
- 大量fetch，但不commit
- 多个group
- 乱序commit: https://zhuanlan.zhihu.com/p/27408881