如何在Mule 4 Custom Policy中检测non-repeatable-stream以避免读取payload？

要避免读取不可重复流类型的Payload（比如HTTP Listener接收的请求体），可以通过以下几种方式检测并处理：

1. 基于Payload类型与特性的核心检测逻辑 #

Mule 4中，不可重复流通常实现了org.mule.runtime.api.streaming.CursorStreamProvider接口，该接口提供的isRepeatable()方法可直接判断流是否支持重复读取。你可以在MEL表达式中做如下判断：

payload is org.mule.runtime.api.streaming.CursorStreamProvider and not payload.isRepeatable()

当表达式返回true时，说明当前Payload是不可重复流，此时必须避免读取它，防止后续流程无法获取数据。

2. 结合HTTP场景的快速判断 #

如果你的策略主要适配HTTP Listener的应用，还可以通过请求属性快速识别——HTTP请求的Payload默认就是不可重复流：

attributes is org.mule.runtime.http.api.domain.message.request.HttpRequestAttributes

你可以把两种判断结合，覆盖更多场景：

(attributes is org.mule.runtime.http.api.domain.message.request.HttpRequestAttributes) 
or (payload is org.mule.runtime.api.streaming.CursorStreamProvider and not payload.isRepeatable())

在自定义策略中落地逻辑 #

在策略的XML配置里，用<choice>组件根据检测结果分支处理：

<flow name="custom-policy-main-flow">
    <choice>
        <when expression="#[payload is org.mule.runtime.api.streaming.CursorStreamProvider and not payload.isRepeatable()]">
            <logger level="INFO" message="Skipping payload processing: detected non-repeatable stream"/>
            <!-- 直接传递请求，不执行任何Payload读取/处理逻辑 -->
        </when>
        <otherwise>
            <!-- 此处执行你的Payload处理逻辑 -->
            <logger level="INFO" message="Processing payload normally"/>
            <!-- 示例操作：<set-payload value="#[transform(payload)]"/> -->
        </otherwise>
    </choice>
</flow>

额外注意事项 #

• 不可重复流一旦被读取（比如通过payload as String转换），后续流程将无法再获取数据，必须严格跳过读取操作
• 若需要处理可重复流的Payload，建议先使用copy(payload)创建副本，再对副本操作，避免影响原始流

内容的提问来源于stack exchange，提问作者eitama