自定义 Advice 类

除了提供的建议类前面描述过,您还可以实现自己的建议类。虽然您可以提供任何 org.aopalliance.aop.Advice 的实现(通常是 org.aopalliance.intercept.MethodInterceptor),但我们通常建议您继承 o.s.i.handler.advice.AbstractRequestHandlerAdvice。这样做的好处是可以避免编写低级的面向方面编程代码,并提供一个专门针对此环境使用的起点。

子类需要实现 doInvoke() 方法,其定义如下

/**
 * Subclasses implement this method to apply behavior to the {@link MessageHandler} callback.execute()
 * invokes the handler method and returns its result, or null).
 * @param callback Subclasses invoke the execute() method on this interface to invoke the handler method.
 * @param target The target handler.
 * @param message The message that will be sent to the handler.
 * @return the result after invoking the {@link MessageHandler}.
 * @throws Exception
 */
protected abstract Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) throws Exception;

回调参数是为了避免直接处理 AOP 的子类而提供的便利。调用 callback.execute() 方法会调用消息处理器。

target 参数是为那些需要为特定处理器维护状态的子类提供的,也许可以通过使用以目标为键的 Map 来维护该状态。此功能允许将相同的建议应用于多个处理器。RequestHandlerCircuitBreakerAdvice 使用此建议为每个处理器保留断路器状态。

message 参数是发送到处理器的消息。虽然建议在调用处理器之前无法修改消息,但它可以修改有效负载(如果它具有可变属性)。通常,建议会使用该消息进行日志记录或在调用处理器之前或之后将消息副本发送到其他位置。

返回值通常是 callback.execute() 返回的值。但是,建议确实具有修改返回值的能力。请注意,只有 AbstractReplyProducingMessageHandler 实例会返回值。以下示例显示了一个扩展 AbstractRequestHandlerAdvice 的自定义建议类

public class MyAdvice extends AbstractRequestHandlerAdvice {

    @Override
    protected Object doInvoke(ExecutionCallback callback, Object target, Message<?> message) throws Exception {
        // add code before the invocation
        Object result = callback.execute();
        // add code after the invocation
        return result;
    }
}

除了 execute() 方法外,ExecutionCallback 还提供了一个附加方法:cloneAndExecute()。此方法必须在调用可能在 doInvoke() 的单个执行中被多次调用时使用,例如在 RequestHandlerRetryAdvice 中。这是必需的,因为 Spring AOP org.springframework.aop.framework.ReflectiveMethodInvocation 对象通过跟踪链中最后一个调用的建议来维护状态。必须为每次调用重置此状态。

有关更多信息,请参阅ReflectiveMethodInvocation Javadoc。