【文件属性】:
文件名称:tinymq:TinyMQ是建立在bbolt之上的小型轻量级持久队列
文件大小:8KB
文件格式:ZIP
更新时间:2021-03-10 19:43:14
Go
TinyMQ
TinyMQ是建立在bbolt之上的小型轻量级持久队列。
安装
go get github.com/superiss/tinymq
例子
文件
经纪人
// Broker
type Broker struct {
mu * sync. Mutex
db * bbolt. DB
queues map [ string ] * Queue
notify chan * notification
errs chan error
}
broker.NewQueue()
创建一个新队列。 以名称字符串,autoStart bool作为参数
broker.GetQueue()
查找并返回队列(如果不存在则返回错误)。
broker.Errors()
经纪人错误的渠道。
broker.Close()
关闭TinyMQ,必须在程序结束时调用它。
队列
/
【文件预览】:
tinymq-main
----utils.go(307B)
----go.mod(140B)
----go.sum(678B)
----lane.go(767B)
----message.go(1KB)
----queue.go(7KB)
----broker.go(3KB)
----_example()
--------main.go(833B)
--------demo.go(2KB)
----README.md(2KB)