Mule回滚异常策略中maxRedeliveryAttempts无限重试问题

首先得明确：你配置的maxRedeliveryAttempts是针对当前流实例内的重试，也就是当异常发生时，在同一个mock-flow实例里尝试重新执行处理逻辑。但你的场景是把失败消息发送到Kafka，再重新触发一个全新的mock-flow实例来处理——这相当于每次都是一个“新请求”，原来的重试次数计数根本不会被继承，所以才会无限循环。

要解决这个问题，你需要自己跟踪跨实例的重试次数，具体步骤如下：

1. 在消息中添加重试次数属性 #

在mock-flow的最开始，添加一个变量来记录当前的重试次数。如果是首次处理，就初始化为0；如果是从Kafka过来的重试消息，就读取已有的次数并加1：

<flow name="mock-flow">
    <!-- 初始化或更新重试次数 -->
    <set-variable variableName="retryCount" value="#[if (message.inboundProperties.containsKey('retryCount')) (message.inboundProperties['retryCount'] + 1) else 0]" doc:name="Set Retry Count"/>
    <!-- 你的原有逻辑：调用微服务等 -->
    <http:request ... />
    <!-- 异常处理 -->
    <rollback-exception-strategy maxRedeliveryAttempts="0" doc:name="Rollback Exception Strategy">
        <!-- 先判断重试次数是否超过阈值 -->
        <choice doc:name="Check Retry Limit">
            <when expression="#[vars.retryCount &lt; 3]"> <!-- 这里设置你想要的最大重试次数，比如3次 -->
                <!-- 发送到Kafka时，带上重试次数属性 -->
                <kafka:produce doc:name="Produce to Kafka">
                    <kafka:message>
                        <kafka:headers>
                            <kafka:header key="retryCount" value="#[vars.retryCount]"/>
                        </kafka:headers>
                        <kafka:payload value="#[payload]"/>
                    </kafka:message>
                    <kafka:topic value="your-retry-topic"/>
                </kafka:produce>
            </when>
            <otherwise>
                <!-- 超过重试次数，进入死信逻辑，比如记录日志或发送到死信队列 -->
                <logger level="ERROR" message="Message failed after #[vars.retryCount] retries, sending to dead letter queue"/>
                <kafka:produce doc:name="Produce to Dead Letter Queue">
                    <kafka:topic value="your-dead-letter-topic"/>
                </kafka:produce>
            </otherwise>
        </choice>
    </rollback-exception-strategy>
</flow>

2. 调整回滚异常策略的maxRedeliveryAttempts #

因为我们已经用自定义的重试次数来控制跨实例的重试，所以把回滚策略的maxRedeliveryAttempts设为0，避免流内的额外重试（如果你不需要流内重试的话）。如果还需要流内重试，可以保持原来的数值，但要注意流内重试和跨实例重试的总和不要超过你的预期。

关键原理说明 #

• 流内重试（maxRedeliveryAttempts）：是在同一个消息处理实例中，重新执行流的逻辑，重试次数由Mule内部跟踪。
• 跨实例重试（通过Kafka）：每次都是新的消息实例，必须通过消息属性（比如header或variable）来传递重试次数，才能在新的流实例中判断是否继续重试。

这样配置后，当重试次数达到你设定的阈值（比如3次），消息就会被发送到死信队列，不会再无限循环了。

内容的提问来源于stack exchange，提问作者Hari K Murthy