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
cli- 自动下载
protoc
- 内嵌
protomq.proto
- 嵌套调用
protoc
- protoc文件语法检查、错误提示
- topic缺失、重复
- proto namespace检查
- language namespace检查
- CI
- 消息大小限制、检查
- 统计整合
- example / guide
- 自动下载
- 集成Prometheus
- kafka
- 自动控制partition?
- php
- client / producer
- handler
- 支持7.X
- 能否支持 5.x?()
- 使用context传递key?
- go并发?
- 控制回收?
- go
- worker pool
- 测试
- 大量fetch,但不commit
- 多个group
- 乱序commit: https://zhuanlan.zhihu.com/p/27408881