我需要覆盖 mule SFTP 入站端点的默认行为。我有骡子流来从 SFTP 位置选择文件并进行一些更改并发送到第三方服务。我在文件上传中没有控制器。因此可能同时存在多个文件。
我需要在那里实施节流机制。例如：Mule 流程需要在一次投票中选择最旧的 10 个文件。所以我打算覆盖 mule SFTP 客户端的默认行为来实现这一点。我正在使用 JAVA。
【问题讨论】：
标签： mule sftp mule-component
您可以利用 Transport Service Override：实现您自己的 SftpMessageReceiver 并配置您的 SFTP 连接器以使用此自定义组件，例如：
<sftp:connector name="sftp-connector" ... />
...
<service-overrides messageReceiver="com.mycomp.MySftpMessageReceiver" />
</sftp:connector>
我建议您为正在使用的 Mule 版本覆盖现有接收器的 poll() 函数。对于 Mule 3.9，它将检索所有文件并为每个找到的文件调用 routeFile()。您可以实现自己的poll()，它将选择 10 个最近的文件并重现相同的行为。我不会在这里提供完整的代码示例，但是您可以从现有功能（检索、锁定、路由）中获得灵感来实现自己的功能。例如：
public class MySftpMessageReceiver extends SftpMessageReceiver {
...
@Override
public void poll() throws Exception {
//poll 10 oldest files
//...
//route them
for (String file : files){
//...
routeFile(file);
}
}
...
}
注意覆盖现有的SftpMessageReceiver 只是一种方法。这个想法是实现您自己的MessageReceiver 并使用上述服务覆盖。
编辑：根据@NNishanthi Wickramasinghe 请求检索私有SftpReceiverRequesterUtil：您可以创建自己的实例或检索由超级构造函数创建的实例。
查看代码，您可以看到它是使用受保护的createSftpReceiverRequesterUtil() 函数创建的，并受构造函数影响到私有字段。你可以在你自己的构造函数中调用这个函数做重复这个行为，或者为了避免重复重写这个方法来检索实例化的对象并将它影响到你自己的字段，例如：
private SftpReceiverRequesterUtil sftpRRUtil = null;
...
@Override
protected SftpReceiverRequesterUtil createSftpReceiverRequesterUtil(InboundEndpoint endpoint) {
sftpRRUtil = super.createSftpReceiverRequesterUtil(endpoint);
return sftpRRUtil;
}
【讨论】：