主页 / 问题 / 1432877
Accepted
anton_63
Asked:2022-07-25 19:54:03 +0800 CST2022-07-25 19:54:03 +0800 CST

Apache Camel 文件数

  • 772

有这样一条路线。每处理 100 个文件时需要显示一个日志。我不明白如何组织文件的数量。具有不同扩展名的文件，您需要显示这数百个文件的处理量+另一个处理时间......

public void configure() {
        from("file:data?noop=true")
                .choice()
                    .when().simple("${file:name} endsWith 'xml'")
                        .log("Xml файл обрабатывается процессором")
                        .process(xmlFileProcessor)
                        .log("Xml файл отправляется в очередь")
                    .to("activemq:test")
                    .when().simple("${file:name} endsWith 'txt'")
                        .log("Txt файл обрабатывается процессором")
                        .process(txtFileProcessor)
                        .log("Txt файл отправляется в очередь")
                    .to("activemq:test")
                        .endChoice()
                    .otherwise()
                        .log("Файл с каким-то расширением обрабатывается процессором")
                        .process(otherwiseFileProcessor)
                        .log("Файл с каким-то расширением отправляется в очередь invalide")
                    .to("activemq:invalid-queue")
                        .log("Выбрасывается исключение")
                        .throwException(new BadExpansion("Неверное расширение"))
                    .when(PredicateBuilder.constant((countXml + countTxt + countOther) % 100 == 0))
                        .log("Количество файлов 100")
                        .log("Количество файлов txt " + countTxt + "\n" +
                        "Количество файлов xml " + countXml + "\n" +
                        "Количество остальных файлов " + countOther + "\n" +
                        "Время обработки сообщений " )
                    .end();

随着时间的流逝，我根本不知道该怎么做，但是通过计数文件有这样一个想法，像这样为每个扩展实现流程类

public class XmlFileProcessor implements Processor {
public static long countXmlFile = 0;
@Override
public void process(Exchange exchange) {
    ++countXmlFile;
}

}

但它仅在类内递增。

java apache

1 个回答

  1. Best Answer

    一切都变得容易多了。有必要创建一个处理器类（而不是为每个扩展生成它自己的）并执行包含所有扩展的所有操作。或多或少像这样

    public class ExtensionProcessor implements Processor {

private static Logger logger = LoggerFactory.getLogger(Main.class);

private static final long BATCH_FILES = 100;
private static final String EXT_TXT = "txt";
private static final String EXT_XML = "xml";
private static final String EXT_ANOTHER = "ext_another";

private static Map<String, Long> countByTypeFiles;
private static long startTimeHandlingBatchFiles = 0;
private static long countFiles = 0;
private static boolean isStartHandlingBatchFiles = true;

static {
    countByTypeFiles = new HashMap<>();
    countByTypeFiles.put(EXT_TXT, 0L);
    countByTypeFiles.put(EXT_XML, 0L);
    countByTypeFiles.put(EXT_ANOTHER, 0L);
}

@Override
public void process(Exchange exchange) throws Exception {
    if(isStartHandlingBatchFiles) {
        startTimeHandlingBatchFiles = System.currentTimeMillis();
        isStartHandlingBatchFiles = false;
    }
    handlingMessage(exchange);
    countFiles++;

    if (countFiles % BATCH_FILES == 0){
        logger.info("------------------------------------------------");
        logger.info("Количество файлов txt " + countByTypeFiles.get(EXT_TXT));
        logger.info("Количество файлов xml " + countByTypeFiles.get(EXT_XML));
        logger.info("Количество остальных файлов " + countByTypeFiles.get(EXT_ANOTHER));
        logger.info("Время обработки сообщений " + (System.currentTimeMillis() - startTimeHandlingBatchFiles));
        logger.info("------------------------------------------------");
        isStartHandlingBatchFiles = true;
    }

}

private String getFileName(Exchange exchange) {
    return exchange.getIn().getHeader(Exchange.FILE_NAME).toString();
}

private String getExtensionFile(String fileName) {
    return FilenameUtils.getExtension(fileName);
}

private String getBody(Exchange exchange) {
    return exchange.getIn().getBody(String.class);
}

private void handlingMessage(Exchange exchange) {
    String fileName = getFileName(exchange);

    String extensionFile = getExtensionFile(fileName);

    if (extensionFile.equals(EXT_TXT) || extensionFile.equals(EXT_XML)) {
        incrementCountFiles(extensionFile);
    } else {
        incrementCountFiles(EXT_ANOTHER);
    }

    if (extensionFile.equals(EXT_TXT)) {
        String body = getBody(exchange);
        saveBodyMessageDB(body);
    }
}

private void incrementCountFiles(String extensionFile) {
    long count = countByTypeFiles.get(extensionFile);
    countByTypeFiles.put(extensionFile, ++count);
}


private void saveBodyMessageDB(String body) {
    PropertyLoader propertyLoader = new PropertyLoader(RESOURCES);
    try (Connection connection = DriverManager.getConnection(
            propertyLoader.getConnectionURL(),
            propertyLoader.getUser(),
            propertyLoader.getPassword())) {
        connection.setAutoCommit(false);
        try (PreparedStatement preparedStatement = connection.prepareStatement(SQL)) {
            preparedStatement.setString(1, body);
            preparedStatement.executeUpdate();
            connection.commit();
        } catch (SQLException e) {
            connection.rollback();
            e.printStackTrace();
        }
    } catch (SQLException | IOException e) {
        e.printStackTrace();
    }
}

    }

    • 0

相关问题