# logship-processor

**Repository Path**: jthinking/logship-processor

## Basic Information

- **Project Name**: logship-processor
- **Description**: logship日志文件读取插件

- 支持单文件多线程读取
- 只支持文本文件读取
- 只支持单行类型日志文件读取
- **Primary Language**: Java
- **License**: MulanPSL-2.0
- **Default Branch**: master
- **Homepage**: None
- **GVP Project**: No

## Statistics

- **Stars**: 5
- **Forks**: 3
- **Created**: 2022-03-15
- **Last Updated**: 2024-10-23

## Categories & Tags

**Categories**: Uncategorized

**Tags**: None

## README

# logship-processor

## 描述

logship日志文件读取插件

- 支持单文件多线程读取
- 只支持文本文件读取
- 只支持单行类型日志文件读取

## Maven依赖

```
<dependency>
    <groupId>com.jthinking.common</groupId>
    <artifactId>logship-processor</artifactId>
    <version>0.0.1</version>
</dependency>
```

## 快速使用

```
// logFile 待读取的日志文件，每行一条日志
File logFile = new File("file.log");

// singleFileThreads 配置读取单个日志文件线程数，程序会将文件平分给每个线程
int singleFileThreads = 32;

// readBufferSize 文件读取缓存大小
int readBufferSize = 1024 * 1024 * 10;

// 读取文件
LogsProcessor.process(logFile, singleFileThreads, readBufferSize, line -> {
    // 处理一行日志 line
});
```