如何在Spring集成路由器中使用SpEL读取有效负载和头内容

Question

我的项目中的技术

Spring Boot 2
Spring Integration (XML style)
Java 8
Tomcat 9.x/Liberty 19.0.0.1

作为我的Spring集成项目（带有入站http网关的REST API，它接受XML输入并生成XML输出）的一部分，我正在编写以下组件：

1. 一个服务激活器，它对传入的XML的XSD执行基本验证。
2. 如果验证成功，则构建POJO（构建器模式Java对象），并将名为isError的布尔实例变量/属性设置为true。
3. 如果验证不成功，则构建POJO（构建器模式Java对象）时使用名为isError的布尔实例变量/属性设置为false。
4. 构建POJO后，它被包装成一个Message并发送到一个输出通道。
5. 有一个路由器组件，它从输出信道获取消息，并根据有效负载/POJO中isError属性的值来决定目标路由/信道。

POJO类的草稿（实际上，POJO将有更多的属性，但对于我们的示例，保持简短）：

public class Composite {
    private Boolean isError;

    private Composite(CompositeBuilder compositeBuilder) {
            this.isError = miCompositeBuilder.isError;
        }

    public boolean isError() {
            return isError;
        }

    //Builder
    public static class CompositeBuilder {
        private Boolean isError;

        public CompositeBuilder(Boolean isError) {
            this.isError = isError;
        }      

        public Composite build() {
            return new Composite(this);
        }
    }
}

XML中的验证器服务激活器组件：

<!-- SERVICE ACTIVATOR FOR REQUEST VALIDATION -->
    <int:service-activator ref="myService"
                           method="validateMYRequest"
                           input-channel="myGatewayRequests"
                           output-channel="compositesPostRequestValidation" />

XML格式的路由器组件：

<!-- ROUTER POST-REQUEST VALIDATION -->
    <int:router input-channel="compositesPostRequestValidation" expression="payload.isError">
        <int:mapping value="true" channel="upstreamResponses"/>
        <int:mapping value="false" channel="downstreamValidatedRequests"/>
    </int:router>

最后是我的问题，在这个“路由器”里，

>

问题1）SpEL表达式（payload.isError）似乎有问题，因为我在调用路由器时遇到了一个异常，如下所示：

组织。springframework。表示斯佩尔。SpelEvaluationException:EL1008E:在类型为“com”的对象上找不到属性或字段“isError”。安博。重新取样。果心模型复合“-可能不公开或无效？在org。springframework。表示斯佩尔。阿斯特。PropertyOrFieldReference。readProperty（PropertyOrFieldReference.java:217）~[spring-expression-5.1.5.RELEASE.jar:5.1.5.RELEASE]。。。

你能告诉我如何访问复合POJO中的布尔“isError”属性吗？这是假设发送到路由器的消息是消息

• 问题2）如果我希望在将其发送到路由器之前将isError属性作为消息头（String）容纳（而不是将其作为复合POJO中的布尔属性使用），是否有一个表达式来访问它？

Answer 1

看起来支付是MIComated而不是Comated。

在任何情况下，SpEL都使用JavaBean约定；因此isError（）是布尔属性错误的getter。所以payload.error应该可以工作（只要MIComrix公开它）。或者可以使用payload.isError（）。

如果它在头中，表达式将是headers['myHeader']。