异步消息任务框架
支持 失败重发
消息分发支持多种模式：1.频道下全发 2.频道下随机 3.频道下顺序发
Tao Zhang
2994583adb
版本升级
|
4 years ago | |
|---|---|---|
| .idea | 4 years ago | |
| demo | 4 years ago | |
| proto | 4 years ago | |
| proto_src | 4 years ago | |
| server | 4 years ago | |
| util | 4 years ago | |
| .gitignore | 4 years ago | |
| README.md | 4 years ago | |
| go.mod | 4 years ago | |
| go.sum | 4 years ago | |
| queued.go | 4 years ago |
README.md
基于GRPC的任务队列管理
双向流
1 支持功能
- 任务发布
- 任务分发，支持多种分发模式 （广播、随机）
- 负载均衡
- 任务回执，支持多种回执模式，（原路返回、广播）
有回执的任务，支持超时自动回收，重新发布
指生成Bean protoc -I ./proto_src --go_out=./proto proto_src/ggclassefity.proto生成相应的服务接口 protoc -I ./proto_src --go_out=plugins=grpc:./proto proto_src/queue.proto