fstream:将消息流写入文件

【文件属性】：

文件名称：fstream:将消息流写入文件

文件大小：7KB

文件格式：ZIP

更新时间：2024-05-05 10:07:07

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)