miniqueue:一个简单的单一二进制消息队列

时间:2024-06-03 22:59:55
【文件属性】:

文件名称:miniqueue:一个简单的单一二进制消息队列

文件大小:41KB

文件格式:ZIP

更新时间:2024-06-03 22:59:55

golang queue message broker Go

迷你队列 一个使用HTTP / 2的愚蠢的简单单一二进制消息队列。 大多数消息传递工作负载不需要大量数据,无止境的功能或无限扩展。 相反,如果做一些简单的事情,他们可能会更好。 MiniQueue就是这样。 简单,高性能的队列。 您可以将字节发布到主题,并确保您的使用者将收到您发布的内容,仅此而已。 特征 操作简单 速度非常快,请参阅 无限扩展 多个主题 HTTP / 2 发布 订阅 致谢 执着的 普罗米修斯指标[WIP] 原料药 POST /publish/:topic ,其中正文包含要发布到该主题的字节。 curl -X POST https://localhost:8080/publish/foo --data " helloworld " POST /subscribe/:topic以\n分隔流消息 client → server: "INIT" server → c


【文件预览】:
miniqueue-master
----flushwriter.go(369B)
----Dockerfile(283B)
----testdata()
--------localhost.pem(2KB)
--------localhost-key.pem(2KB)
----.gitignore(11B)
----main.go(2KB)
----README.md(7KB)
----server_test.go(14KB)
----bench.out(282B)
----value.go(617B)
----.github()
--------workflows()
----main_test.go(167B)
----consumer_test.go(847B)
----consumer.go(2KB)
----broker.go(3KB)
----server_mock.go(2KB)
----examples()
--------exponential_backoff()
--------bench_consume()
--------workers()
--------echo()
----LICENSE(1KB)
----go.mod(446B)
----store_mock.go(14KB)
----store_test.go(14KB)
----testutils_test.go(7KB)
----.golangci.yaml(20B)
----broker_test.go(803B)
----go.sum(6KB)
----server.go(8KB)
----Makefile(1018B)
----store.go(21KB)
----response.go(680B)

网友评论