Эхлэл Бүгдийг харах Тусламж
Нэвтрэх
BP
/
async_queue
2
0
Салаа 0
Файлууд Асуудлууд 0 Хуулах хүсэлтүүд 0 Мэдлэгийн сан

异步消息任务框架
支持 失败重发
消息分发支持多种模式：1.频道下全发 2.频道下随机 3.频道下顺序发

Салаа: master
Салаанууд Тагууд
async_queue
ZIP TAR.GZ
Tao Zhang 2994583adb 版本升级 4 жил өмнө
.idea eeeef4e752 初始化 4 жил өмнө
demo 2994583adb 版本升级 4 жил өмнө
proto eeeef4e752 初始化 4 жил өмнө
proto_src eeeef4e752 初始化 4 жил өмнө
server eeeef4e752 初始化 4 жил өмнө
util eeeef4e752 初始化 4 жил өмнө
.gitignore eeeef4e752 初始化 4 жил өмнө
README.md eeeef4e752 初始化 4 жил өмнө
go.mod eeeef4e752 初始化 4 жил өмнө
go.sum eeeef4e752 初始化 4 жил өмнө
queued.go eeeef4e752 初始化 4 жил өмнө

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