```markdown

# 高效数据采集利器：Fluency





## 项目简介

Fluency 是一个专为高效数据接入 Fluentd 和 Fluent Bit 打造的高性能日志记录库，同时也支持 AWS S3 和 Treasure Data。相比 fluent-logger-java，它在性能上实现了约 4 倍的提升，以极低延迟处理大量数据，保证了系统的高吞吐量。

## 技术剖析

- **异步刷新**：Fluency 使用异步方式来刷新缓存的数据，大大提升了数据处理速度。
- **TCP/UDP 心跳机制**：与 Fluentd 的心跳连接保持，确保通信稳定性。
- **故障转移**：支持多个 Fluentd 节点的切换，当主节点出现问题时，自动转到备用节点。
- **ack 应答模式**：可以启用或禁用 Fluentd 的确认应答模式。
- **TLS/SSL 支持**：提供安全加密的网络传输。
- **PackedForward 格式**：优化了数据传输效率。
- **本地备份**：在内存缓冲区的数据未发送时，将其备份到本地文件系统。

## 应用场景

- **大数据实时分析**：Fluentd 的广泛使用使得 Fluency 成为了实时数据流和日志收集的理想选择。
- **分布式系统监控**：在多节点环境中，Fluency 可用于集中收集和分析各个节点的日志信息。
- **云服务集成**：通过 AWS S3 或 Treasure Data，可以直接将数据存储和分析到云端。

## 项目特点

1. **卓越性能**：基于异步模型，显著提高日志记录效率。
2. **灵活性**：支持单个或多个 Fluentd 实例，具备故障转移功能。
3. **安全性**：内置 TLS/SSL 支持，保障数据传输的安全性。
4. **容错性强**：即使在异常情况下，也能备份数据并重新发送。
5. **易于使用**：简洁的 API 设计，快速集成到现有项目中。

## 安装与使用

Fluency 提供了 Gradle 和 Maven 的配置方法，只需简单几步即可导入项目。使用示例展示如何创建 Fluency 实例，以及发送事件：

```java
// 单一 Fluentd 实例（默认配置）
Fluency fluency = new FluencyBuilderForFluentd().build();

// 多个 Fluentd 实例，实现故障转移
List<InetSocketAddress> addresses = Arrays.asList(
        new InetSocketAddress(24224), new InetSocketAddress(24225));
Fluency fluency = new FluencyBuilderForFluentd().build(addresses);

Fluency 还提供了丰富的配置选项，如设置缓存大小、超时时间、错误处理等，以满足不同场景的需求。

要了解更多关于 Fluency 的详细信息和高级配置，请参阅项目文档。加入这个高效的日志处理行列，让您的数据采集工作更加得心应手！

GitHub 地址

这个 Markdown 文档详尽地介绍了 Fluency 的核心特性和应用场景，以及如何安装和使用这个库。它是吸引开发者尝试使用该项目的一个完美起点。