当前位置: 首页 > 知识库问答 >
问题:

Spring Integration-入站文件endpoint。如何正确处理文件?

越勇
2023-03-14
<int-file:inbound-channel-adapter id="filesIn"
        directory="file:${incomingDir}" 
        filename-pattern="*.txt" 
        prevent-duplicates="true">
    <int:poller id="poller" fixed-delay="5000"/>
    </int-file:inbound-channel-adapter>

    <int:splitter input-channel="filesIn" 
        ref="filesSplitterService"
        method="splitFilesToReportContent"
        output-channel="reportProcessIn"
     />

     <int:channel id="reportProcessIn"/>

     <int:chain input-channel="reportProcessIn" output-channel="reportProcessOut">    
        <int:service-activator ref="reportProcessorService" method="readReportMetaData" />
        <int:service-activator ref="reportProcessorService" method="saveReportFileInFileSystem" />
        <int:service-activator ref="reportProcessorService" method="saveReportMetaDataInDB" />
    </int:chain>

     <int:channel id="reportProcessOut"/>


    <bean id="filesSplitterService" class="com.app.integration.FilesSplitter"/>

    <bean id="reportProcessorService" class="com.app.reporting.integration.ReportProcessor"/>

org.springframework.integration.MessageDeliveryException:Dispatcher没有订阅者

>

  • 我不需要聚合拆分的元素。在数据库中保存元数据后,流就我而言是完成的。

    但是,我想在使用原始文件后,将它移动到其他目录,该文件是我拆分为报表文件的主文件。我怎么能把这个逻辑结合起来呢?文件:出站通道似乎是这样做的方法,但我不明白怎么做。

    public List<ReportContent> splitFilesToReportContent(File file){
    } 
    
    public ReportContent readReportMetaData(ReportContent reportContent) {
    
    
    }
    
    
    
    public ReportContent saveReportFileInFileSystem(ReportContent reportContent) {
    
    
        }
    
    public ReportContent saveReportMetaDataInDB(ReportContent reportContent) {
    
    
        }
    
  • 共有1个答案

    翟棋
    2023-03-14

    1.我得到以下异常...org.springframework.integration.MessageDeliveryException

    我想您已经错过了文件:Outbound-Channel-Adapter定义。

    2.但是,我想在使用原始文件后将它移动到其他目录,该文件是我拆分为报表文件的主文件。我怎么能把这个逻辑结合起来呢?

     类似资料:
    • 我正在处理IDE中制作一个Java处理项目,并希望将其传播到多个PDE(处理源代码)文件中。 我无法使用导入将Java处理源代码文件导入为Java类文件。 <代码>配置。pde <代码>项目。pde 返回导入项目/配置无法解析 分别为。 我必须先编译PDE文件吗?是否可以将处理IDE设置为每次运行都自动执行? 太长,读不下去了 拥有此项目文件夹: 如何使用配置中的函数和变量。项目中的pde。pde

    • 我存储用户收藏夹到json文件,但我得到以下错误: 未处理的异常:类型“\u InternalLinkedHashMap” 我将以下数据添加到文件中: 代码是: 我很困惑,不知道如何解决这个问题。

    • 我之前习惯这样引入,但https://unpkg.com偶尔会出现访问不了的情况,就会导致样式出不来。于是我把这份样式文件下载下来,一些icon,图标之类的东西会显示不出来。所以大家是怎么引入的?

    • 我试图在我的项目中做一些设置。我在将文本文件中的值输入JFrame时遇到问题。更具体地说,我有一个JFrame。从这个JFrame中,我打开另一个名为的JFrame,其中是文本文件中带有值“”的JTextField。当我将值更改为“”并点击保存按钮时,它会将文本文件重写为“”并处理JFrame。直到现在一切都很好。 当我想再次打开JFrame时,它用旧值""打开它。但是当我关闭两个JFrames并

    • 问题内容: 我正在Ruby中创建哈希,并希望以正确的格式将其写入JSON文件。 这是我的代码: 这是结果文件的内容: 我正在使用Sinatra(不知道哪个版本)和Ruby v 1.8.7。 如何以正确的JSON格式将其写入文件? 问题答案: 需要JSON库,并使用。 您的temp.json文件现在看起来像: