fstream:将消息流写入文件

时间:2021-04-15 16:20:27
【文件属性】:
文件名称:fstream:将消息流写入文件
文件大小:7KB
文件格式:ZIP
更新时间:2021-04-15 16:20:27
Go 流 fstream是用于在二进制文件队列中收集/读取输入消息的简单解决方案。 每个文件包含1分钟内收到的所有消息。 文件格式: ... 消息大小存储在uint16值中。 所有文件都保存在所选目录中,并且具有与以下000000,000001,000002等相似的名称。名称000000跟在名称999999之后。当前文件名存储在idx文件中。 Writer保存最后10000个文件,然后删除较旧的文件。 当存在大量事件且无法即时处理它们或使用诸如RabbitMQ之类的解决方案时,fstream很有用。 对于统计信息聚合和后续处理非常有效。 安装 go get "github.com/belfinor/fstream" 作家的例子 package main import ( "bufio" "os" "string
【文件预览】:
fstream-master
----go.mod(193B)
----LICENSE(1KB)
----go.sum(1KB)
----writer.go(2KB)
----README.md(2KB)
----const.go(236B)
----test()
--------.gitignore(6B)
--------writer.go(525B)
--------reader.go(563B)
----reader.go(3KB)

网友评论