如何拆分日志文件(logfile)中的消息并将拆分字段存储到变量中

首先明确有效日志行的字段结构，每行业务日志用|作为分隔符，拆分后可得到5个核心字段：

• 日志前缀：固定业务标识部分
• 任务类型：固定为BATCH_PAYMENT
• 执行时间：格式为yyyy-MM-dd HH:mm:ss
• 处理数量：整型数值
• 执行结果：Success/失败状态值

方案1：split直接拆分（实现最简单，适合格式稳定场景） #

直接用|分割字符串，过滤无效行后直接取对应位置的字段赋值即可，修改后的代码如下：

import java.util.*;
import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.InputStreamReader;
import java.nio.charset.StandardCharsets;

public class Test{

    public static void main (String[] args)throws Exception{
        demoReadall();
    }

    public static void demoReadall(){
        // 用try-with-resources自动关闭流，避免资源泄漏
        try (FileInputStream fstream = new FileInputStream("RunningSystem.log");
             BufferedReader br = new BufferedReader(new InputStreamReader(fstream, StandardCharsets.UTF_8))){
             
            String strLine;
            while ((strLine = br.readLine()) != null)   {
                // 过滤掉第一行的logfile无效行、以及不符合|分隔规则的行
                if (strLine.equals("logfile") || !strLine.contains("|")) {
                    continue;
                }
                // 注意|是正则特殊字符，需要转义
                String[] fields = strLine.split("\\|");
                if (fields.length != 5) {
                    continue;
                }
                // 赋值到变量
                String taskType = fields[1].trim();
                String executeTime = fields[2].trim();
                Integer handleCount = Integer.valueOf(fields[3].trim());
                String status = fields[4].trim();
                
                // 测试输出，可替换为自己的业务逻辑
                System.out.printf("任务类型：%s，执行时间：%s，处理条数：%d，状态：%s%n", 
                        taskType, executeTime, handleCount, status);
            }
        } catch (Exception e) {
            System.err.println("Error: " + e.getMessage());
        }
    }
}

方案2：正则全匹配（更严谨，支持过滤脏数据） #

如果日志里存在很多格式不统一的行，可以用正则精准匹配需要的字段，避免split下标越界问题，核心代码修改部分：

// 定义正则，编译放到循环外提升性能
Pattern pattern = Pattern.compile("^.+?\\|(?<taskType>.+?)\\|(?<executeTime>\\d{4}-\\d{2}-\\d{2} \\d{2}:\\d{2}:\\d{2})\\|(?<count>\\d+)\\|(?<status>.+)$");
Matcher matcher;
while ((strLine = br.readLine()) != null)   {
    matcher = pattern.matcher(strLine);
    if (matcher.find()) {
        String taskType = matcher.group("taskType");
        String executeTime = matcher.group("executeTime");
        Integer handleCount = Integer.valueOf(matcher.group("count"));
        String status = matcher.group("status");
        // 后续业务逻辑
    }
}

补充优化建议 #

• 可以自定义一个PaymentLog实体类，把拆分后的字段都封装到对象里，方便后续批量存储、处理
• 如果后续需要解析时间做统计，可以用LocalDateTime把executeTime字符串转成时间类型
• 生产环境建议加解析失败的日志打印，记录异常行内容，方便排查格式问题

内容的提问来源于stack exchange，提问作者3Tom