yerfYar是一个运行于Linux系统的，易于使用的分布式面向消息的中间件，由Go语言开发。该项目的目标是提供一个通用的、用于存储任何类型事件或日志的持久中间存储缓冲区。
消息由换行符分隔，事件格式没有其他限制：可以是JSON、纯文本、Protobuf（使用“\”和换行符转义）等。
构建yerfYar需要go1.18.1以上版本。
1、在 https://golang.org/ 安装 Go
2、在终端中运行以下命令：$ go install -v github.com/yanyanran/yerfYar@latest
3、构建的二进制文件应位于“~/go/bin/yerfYar”，如果设置了“$GOPATH”，则应位于“$GOPATH/bin/yerfYar”。
可参考简单的Go客户端库：https://pkg.go.dev/github.com/YuriyNasretdinov/chukcha/client
1、开箱即用配置，数据持久化且不会意外丢失数据。
2、分布式，默认为异步复制。
3、明确确认已读取的数据。
1、默认情况下复制是异步的，可以选择等待写入的数据复制到至少N个其他服务器。
2、没有leaders和followers：所有chunk都被复制到集群中的服务器中，所有节点都是平等的
3、数据目录中的每个文件如下所示：<category>/<server_name>-chuckXXXXXXXX
4、集群中的每个实例都必须具有唯一的名称，并且该名称将用作该类别中所有文件的前缀。
5、客户端应该只连接到一个服务端实例并使用写入的chunk，因为所有数据都复制到了每个节点。
6、如果节点永远消失，超时后最后一个chunk将被标记为complete（已完成）。
1、数据被分割成块，并作为文件存储在磁盘上。每个服务器都拥有正在写入的块，并且每个单独块的所有权永远不会改变。这些文件被复制到集群中的所有其他服务器上。
2、reader明确确认已读取的数据，负责从适当的偏移量开始读取块。需要的话数据可以在设定的时间段后过期（TODO），当前默认情况下的数据永远不会过期。
1、最大消息大小的限制是1MB，否则无法再从磁盘提供结果。
2、处理磁盘空间或索引节点数量不足的情况。
3、确保服务器检查发送的事件是否为整行。
4、检查读取请求中的maxSize不超过16 MB。
5、为.deleted文件编写一个垃圾收集器，并在复制ack请求失败时建立一个回退机制来确认chunk
1、每条消息支持的最大大小为 1 MB。
2、每条消息必须用换行符 (\n) 分隔。
3、最大默认写入批量大小为 4 MB。
4、每个连接的最大内存消耗约为“（写入批量大小）* 2”（默认设置为 8 MB）。【TODO：如果在 HTTP 之上使用自定义协议，则可以显着降低每个连接的内存消耗】
5、打开连接数默认上限为262144。
默认情况下数据不会在每次写入时刷新到磁盘，但可以在服务器配置中或根据请求进行更改。
因此，数据持久性保证如下：
1、默认情况下，下面的情况可能会导致写入单个节点的数据丢失：
- 机器没有完全关闭，例如：发生内核崩溃或主机遇到任何其他硬件故障
- 机器完全丢失且再也没回到集群中
2、(TODO): 当 min_sync_replicas 大于 0 时，只有在以下情况下才会丢失数据：
- 超过“min_sync_replicas”的机器没有同时完全关闭
- 超过“min_sync_replicas”的机器完全丢失并且永远不会返回到集群
3、(TODO2): 当设置 sync_each_write=true 时，只有当机器的硬盘/SSD 出现故障时，数据才会丢失。
4、(TODO2): 当设置了 sync_each_write=true 且 min_sync_replicas 大于零时，只有超过 min_sync_replicas 机器完全丢失且不再重新加入集群时，数据才会丢失。