Spring集成-聚合和转换

Question

在我的用例中，最简单的集成组件安排是什么：

1. 接收来自多个来源和多种格式的消息（所有消息都是JSON序列化对象）。
2. 将消息存储在缓冲区中最多10秒（聚合）
3. 通过不同的类属性getter（例如class1.someId（），class2.otherId（），...）
4. 释放所有分组的消息并转换为新的聚合消息。

到目前为止（第1点和第2点），我正在使用聚合器，但不知道3）处的问题是否有现成的解决方案或者我必须尝试转换每条消息并检查对象的类型是否为class1，然后使用correlationstrategy someId，如果是class2，则使用otherId。

对于问题4.）-我可以手动编码一些东西-但是转换器似乎是一个很好的组件，我只是不知道是否有像聚合转换器这样的东西，我可以为每个输入类型指定映射规则。

更新

像这样的东西：

class One{
    public String getA(){ return "1"; }
}

class Two{
    public Integer getB(){ return 1; }
}

class ReduceTo{
    public void setId(Integer id){}
    public void setOne(One one){}
    public void setTwo(Two two){}
}

public class ReducingAggregator {


    @CorrelationStrategyMethod
    public String strategy(One one){
        return one.getA();
    }

    @CorrelationStrategyMethod
    public String strategy(Two two){
        return two.getB().toString();
    }

    @AggregatorMethod
    public void reduce(ReduceTo out, One in){
        out.setId(Integer.valueOf(in.getA()));
        out.setOne(in);
    }

    @AggregatorMethod
    public void reduce(ReduceTo out, Two in){
        out.setId(in.getB());
        out.setTwo(in);
    }
}

我想注释的用例与当前的Spring不同。RediceTo可以是包括集合在内的任何对象。在config中，我们可以指定第一次传递时应该是空列表还是其他东西（例如java流中的减少）。

Answer 1

不确定您希望看到什么现成的解决方案。这是你的类，也是你的方法。框架如何对其做出决策？

嗯，是的，你需要实现Cor的策略。或者你可以考虑使用ExpressionEvalue atingCor的策略，不要写Java代码：-）。

请详细说明您希望看到的开箱即用功能。

聚合变换器完全封装在Aggregator的MessageGroupProcess函数中。默认情况下，它是DefaultAggregatingMessageGroupProcess。是的，您可以自己或再次编写代码-使用ExpressionEvalue atingMessageGroupProcess并且不要再次编写Java代码：-）