yoozoo/protomq

dev-master 2019-04-23 03:12 UTC

Requires

• spiral/goridge: ^2.1
• spiral/roadrunner: ^1.3

MIT

• ChenFang

README

初始化

go get  github.com/yoozoo/protomq
protomq init

php

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

composer require google/protobuf
composer require spiral/roadrunner

• https://github.com/protocolbuffers/protobuf/tree/master/php

go

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 生产者客户端详情在这里。

TODO

• 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