文件名称：tinymq:TinyMQ是建立在bbolt之上的小型轻量级持久队列
文件大小：8KB
文件格式：ZIP
更新时间：2024-03-30 13:29:54
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)