资源入站通道适配器建立在 Spring 的抽象之上,以支持跨各种实际类型的底层资源(如文件、URL 或类路径资源)的更大灵活性。 因此,它类似于文件入站通道适配器,但比文件入站通道适配器更通用。ResourceSpring中文文档

资源入站通道适配器

资源入站通道适配器是一个轮询适配器,用于创建其有效负载是对象集合的轮询适配器。MessageResourceSpring中文文档

Resource对象根据属性指定的模式进行解析。 然后,解析对象的集合将作为有效负载发送到适配器的通道。 这是资源入站通道适配器和文件入站通道适配器之间的一个主要区别:后者缓冲对象并按 .patternResourceMessageFileFileMessageSpring中文文档

以下示例显示了一个简单的配置,该配置查找类路径上可用的包中以“properties”扩展名结尾的所有文件,并将它们作为 a 的有效负载发送到名为“resultChannel”的通道:things.thing1MessageSpring中文文档

<int:resource-inbound-channel-adapter id="resourceAdapter"
               channel="resultChannel"
               pattern="classpath:things/thing1/*.properties">
    <int:poller fixed-rate="1000"/>
</int:resource-inbound-channel-adapter>

资源入站通道适配器依赖于策略接口来解析提供的模式。 它默认为当前 . 但是,您可以通过设置属性来提供对自己实现的实例的引用,如以下示例所示:org.springframework.core.io.support.ResourcePatternResolverApplicationContextResourcePatternResolverpattern-resolverSpring中文文档

<int:resource-inbound-channel-adapter id="resourceAdapter"
               channel="resultChannel"
               pattern="classpath:things/thing1/*.properties"
               pattern-resolver="myPatternResolver">
    <int:poller fixed-rate="1000"/>
</int:resource-inbound-channel-adapter>

<bean id="myPatternResolver" class="org.example.MyPatternResolver"/>

您可能有一个用例,需要进一步筛选由 . 例如,您可能希望防止已解析的资源再次出现在已解析资源的集合中。 另一方面,您的资源可能会经常更新,并且您确实希望再次获取它们。 换言之,定义附加筛选器和完全禁用筛选都是有效的用例。 您可以提供自己的策略接口实现,如以下示例所示:ResourcePatternResolverorg.springframework.integration.util.CollectionFilterSpring中文文档

public interface CollectionFilter<T> {

    Collection<T> filter(Collection<T> unfilteredElements);

}

接收未筛选元素(在前面的示例中是对象)的集合,并返回相同类型的筛选元素的集合。CollectionFilterResourceSpring中文文档

如果使用 XML 定义适配器,但未指定筛选器引用,则资源入站通道适配器将使用缺省实现 。 该默认筛选器的实现类为 。 它会记住在上一次调用中传递的元素,以避免多次返回这些元素。CollectionFilterorg.springframework.integration.util.AcceptOnceCollectionFilterSpring中文文档

若要注入自己的实现,请使用该属性,如以下示例所示:CollectionFilterfilterSpring中文文档

<int:resource-inbound-channel-adapter id="resourceAdapter"
               channel="resultChannel"
               pattern="classpath:things/thing1/*.properties"
               filter="myFilter">
    <int:poller fixed-rate="1000"/>
</int:resource-inbound-channel-adapter>

<bean id="myFilter" class="org.example.MyFilter"/>

如果不需要任何筛选,甚至想要禁用默认策略,请为 filter 属性提供一个空值(例如,CollectionFilterfilter="")Spring中文文档