Apache Camel路由结束时如何清除SFTP组件的LRUCache缓存

你可以通过以下两种方式主动清空SFTP组件的幂等LRU缓存：

方式一：直接从SFTP端点获取IdempotentRepository调用清空 #

你可以通过CamelContext获取对应SFTP端点实例，转换类型后拿到内部的幂等缓存，直接调用cleanUp()方法清空，示例代码如下：

import org.apache.camel.CamelContext;
import org.apache.camel.component.file.remote.SftpEndpoint;
import org.apache.camel.support.LRUCache;
import javax.annotation.Resource;

public class SftpCacheCleanUtil {
    @Resource
    private CamelContext camelContext;

    public void clearSftpIdempotentCache(String sftpEndpointUri) {
        // 获取对应SFTP端点实例
        SftpEndpoint sftpEndpoint = camelContext.getEndpoint(sftpEndpointUri, SftpEndpoint.class);
        // 转换为LRUCache类型，默认开启idempotent=true时使用的就是LRUCache实现
        LRUCache<?, ?> idempotentCache = (LRUCache<?, ?>) sftpEndpoint.getIdempotentRepository();
        // 清空缓存
        idempotentCache.cleanUp();
    }
}

你可以在路由的onCompletion结束回调处理器中调用该方法，即可在路由执行完成后自动清空缓存，无需重启服务。

方式二：自定义幂等仓库自行持有实例（耦合度更低） #

你也可以在定义路由时主动声明自定义的LRUCache作为幂等仓库，自行持有实例引用，需要清空时直接调用方法即可，避免和端点逻辑耦合，示例代码如下：

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.support.LRUCache;
import org.springframework.context.annotation.Bean;
import org.springframework.stereotype.Component;

@Component
public class SftpTestRoute extends RouteBuilder {
    // 自行持有LRU缓存实例
    private final LRUCache<String, String> idempotentCache = new LRUCache<>(1000);

    // 注册到Spring上下文，供Camel组件引用
    @Bean(name = "sftpIdempotentCache")
    public LRUCache<String, String> sftpIdempotentCache() {
        return idempotentCache;
    }

    @Override
    public void configure() throws Exception {
        // 路由执行结束自动清空缓存
        onCompletion().process(exchange -> idempotentCache.cleanUp());

        from("sftp://你的SFTP连接配置?idempotent=true&idempotentRepository=#sftpIdempotentCache")
                // 你的业务处理逻辑
                .to("bean:businessProcessService");
    }

    // 也可以对外暴露清空方法，在需要的场景主动调用
    public void cleanCache() {
        idempotentCache.cleanUp();
    }
}

如果仅本地测试使用，你也可以直接将idempotent参数设置为false关闭幂等校验，无需处理缓存清空逻辑，上线时再开启即可。

内容的提问来源于stack exchange，提问作者Zx binhjy xZ