我正在嘗試通過 Sftp 并使用 Spring Integration SftpOutboundGateway 方法刪除多個(gè)文件。我正在使用 QueueChannel 進(jìn)行請(qǐng)求和響應(yīng)。另外，我將采用異步方式，以便我可以提交多個(gè)請(qǐng)求。我最近還添加了一個(gè)錯(cuò)誤通道?，F(xiàn)在的問題是我的第一個(gè)請(qǐng)求是一個(gè)不存在的文件，所以我很高興收到“2：沒有這樣的文件”異常消息。但一旦發(fā)生這種情況，其他請(qǐng)求就會(huì)陷入困境。
1 回答
holdtom
TA貢獻(xiàn)1805條經(jīng)驗(yàn) 獲得超10個(gè)贊
好的?？雌饋砟愕膯栴}是你沒有捕獲異常來繼續(xù)。
請(qǐng)參閱async以下選項(xiàng)ServiceActivatingHandler：
/**
* Allow async replies. If the handler reply is a {@link ListenableFuture}, send
* the output when it is satisfied rather than sending the future as the result.
* Ignored for return types other than {@link ListenableFuture}.
* @param async true to allow.
* @since 4.3
*/
public final void setAsync(boolean async) {
因此，僅當(dāng)從目標(biāo)實(shí)現(xiàn)返回a （或 Reactive ）時(shí)，它才真正是異步的。這不是事實(shí)。因此，您的網(wǎng)關(guān)定義是正確的方法。盡管您需要從中返回一些內(nèi)容，但這將是網(wǎng)關(guān)調(diào)用的返回。否則我們就會(huì)陷入等待回復(fù)或錯(cuò)誤的境地。ListenableFuturePublsiherhandleRequestMessage()SftpOutboundGatewayerrorChannel = "sftp.error.channel"sftpErrorHandler
添加回答
舉報(bào)
0/150
提交
取消