Apache Camel路由全流程JUnit测试启动后异常，求参考示例

看来你在Apache Camel路由的测试中遇到了启动正常但运行时崩溃的问题，报错是ArrayIndexOutOfBoundsException，指向FileTest7.java第61行的lambda表达式。我之前也碰到过类似的数组越界问题，大多是因为输入数据格式不符合预期导致的，给你一些排查思路、修复示例和参考方向：

首先聚焦报错的第61行，你大概率是在操作数组时访问了超出其长度的索引。先检查这几个点：

• 你处理的test.txt文件内容是不是有格式异常的行？比如按分隔符（逗号、空格等）拆分后，某些行的字段数量不足；
• Customer.java的对象转换逻辑是不是依赖固定长度的数组，没有做边界校验？

举个常见的错误场景示例（对应你报错的代码逻辑）：

from("file:src/test/resources?fileName=test.txt")
    .split(body().tokenize("\n"))
    .process(exchange -> {
        String line = exchange.getIn().getBody(String.class);
        String[] parts = line.split(",");
        // 如果某行没有逗号，parts长度为1，取parts[1]就会触发数组越界
        Customer customer = new Customer();
        customer.setName(parts[0]);
        customer.setEmail(parts[1]); // 这里就是报错的第61行
        exchange.getIn().setBody(customer);
    })
    .to("mock:result");

给代码加上边界校验和异常处理，避免单个错误行导致整个路由崩溃：

import org.apache.camel.Exchange;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class FileTest7 {
    private static final Logger log = LoggerFactory.getLogger(FileTest7.class);

    public void configure() throws Exception {
        from("file:src/test/resources?fileName=test.txt")
            .split(body().tokenize("\n"))
            .process(exchange -> {
                String line = exchange.getIn().getBody(String.class);
                // 先跳过空行
                if (line == null || line.trim().isEmpty()) {
                    // 标记这条消息停止路由
                    exchange.setProperty(Exchange.ROUTE_STOP, Boolean.TRUE);
                    return;
                }
                String[] parts = line.split(",");
                // 检查字段数量是否符合要求
                if (parts.length < 2) {
                    log.warn("Skipping invalid line (insufficient fields): {}", line);
                    exchange.setProperty(Exchange.ROUTE_STOP, Boolean.TRUE);
                    return;
                }
                // 正常转换Customer对象
                Customer customer = new Customer();
                customer.setName(parts[0].trim());
                customer.setEmail(parts[1].trim());
                exchange.getIn().setBody(customer);
            })
            .to("mock:result");
    }
}

测试时要覆盖异常场景，确保路由能处理格式错误的输入：

import org.apache.camel.test.junit5.CamelTestSupport;
import org.junit.jupiter.api.Test;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.List;
import static org.hamcrest.MatcherAssert.assertThat;
import static org.hamcrest.Matchers.hasItem;
import static org.hamcrest.Matchers.hasLevel;

public class FileTest7Test extends CamelTestSupport {
    private static final Logger log = LoggerFactory.getLogger(FileTest7Test.class);

    @Test
    public void testRouteWithInvalidLines() throws Exception {
        // 模拟包含正常行、错误行和空行的测试内容
        String testContent = "Alice,alice@example.com\nBob\n\nCharlie,charlie@example.com";
        template.sendBody("file:src/test/resources", testContent);
        
        // 验证只有2条正常消息被处理
        getMockEndpoint("mock:result").expectedMessageCount(2);
        assertMockEndpointsSatisfied();
        
        // 验证错误日志是否生成
        List<LoggingEvent> logEvents = logger.getLoggingEvents();
        assertThat(logEvents, hasItem(hasLevel(org.slf4j.event.Level.WARN)));
    }
}

如果需要更统一的异常管理，可以用Camel的onException()机制，把错误消息路由到专门的处理通道：

public void configure() throws Exception {
    // 全局捕获数组越界异常
    onException(ArrayIndexOutOfBoundsException.class)
        .log("Failed to process line: ${body}, error: ${exception.message}")
        .handled(true) // 标记异常已处理，避免向上传播
        .to("file:src/test/resources/error-lines?fileName=invalid-records.txt&fileExist=Append");

    from("file:src/test/resources?fileName=test.txt")
        .split(body().tokenize("\n"))
        .process(exchange -> {
            String line = exchange.getIn().getBody(String.class);
            String[] parts = line.split(",");
            Customer customer = new Customer();
            customer.setName(parts[0].trim());
            customer.setEmail(parts[1].trim());
            exchange.getIn().setBody(customer);
        })
        .to("mock:result");
}

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