Apache camel CamelSftpSourceConnector拆分文件

Answer 1

您可以使用来自EIP模式的拆分器将消息拆分为更小的部分。一种简单的方法是使用bean，它具有接受exchange并返回消息列表的方法。

简单的例子：

from(SFTP_URI)
    .routeId("splitFileAndSendToKafka")
    .split(method(new MySplitter()))
        // ... do stuff
        .to(KAFKA_URI)
    .end()
    .log("file split and sent to kafka");

import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.impl.DefaultMessage;

public class MySplitter {

    public List<Message> splitExchange(Exchange exchange) {

        String body = exchange.getMessage().getBody(String.class);
        String[] parts = body.split(";");

        List<Message> messages = new ArrayList<>();
        for (int i = 0; i < parts.length; i++) {
            
            Message msg = new DefaultMessage(exchange.getContext());
            msg.setBody(parts[i]);
            msg.setHeader("partIndex", i);
            messages.add(msg);
        }
        return messages;
    }
}

（使用Camel2.x，所以Camel3.x可能会有一些变化）