文件名称：kueue:一个基于 NSQ 的简单生产者和消费者包装器
文件大小：5KB
文件格式：ZIP
更新时间：2024-07-29 02:02:21
Go
奎厄 基于 NSQ 的简单生产者和消费者包装器。 特征 发布任何类型的消息 支持延迟作业 在生产者池中 工人保姆可以照顾多个消费者 用法 生产者 import ( "time" "github.com/heroicyang/kueue" ) kueue . SetupProducers ( nsqdAddr , poolSize ) // publish any type of message kueue . Publish ( "topic" , 0 , topicStruct ) // publish a delayed message kueue . Publish ( "delayedTopic" , 1 * time . Hour , topicStruct ) 消费者 import ( "encoding/json" "github.com/
【文件预览】：
kueue-master
----handler.go(1KB)
----job.go(429B)
----producer.go(1KB)
----consumer.go(1KB)
----LICENSE(1KB)
----README.md(1KB)
----worker.go(1KB)
----.gitignore(266B)