aopclient.java

一个非常好的FRAMWRK!是一个外国组织做的!不!

/**
 * Copyright 2003-2005 the original author or authors.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at

       http://www.apache.org/licenses/LICENSE-2.0

  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */

package com.jdon.aop;

import java.lang.reflect.Method;
import java.util.List;

import org.aopalliance.intercept.MethodInvocation;

import com.jdon.aop.joinpoint.AdvisorChainFactory;
import com.jdon.aop.reflection.MethodConstructor;
import com.jdon.aop.reflection.ProxyMethodInvocation;
import com.jdon.bussinessproxy.meta.MethodMetaArgs;
import com.jdon.bussinessproxy.target.TargetServiceFactory;
import com.jdon.container.access.TargetMetaRequest;
import com.jdon.util.Debug;

/**
 * Aop Client
 * @author <a href="mailto:[e-mail]">banq</a>
 *
 */
public class AopClient {

  private final static String module = AopClient.class.getName();

  private AdvisorChainFactory advisorChainFactory;

  private TargetServiceFactory targetServiceFactory;
  
  private MethodConstructor methodConstructor;

  public AopClient(AdvisorChainFactory advisorChainFactory,
                  
                   TargetServiceFactory targetServiceFactory) {
    this.advisorChainFactory = advisorChainFactory;
    this.targetServiceFactory = targetServiceFactory;
    this.methodConstructor = new MethodConstructor();
  }

  /**
   * 
   * different target service has its Interceptor instance
   *  and  MethodInvocation instance
   * 
   */
  public Object invoke(TargetMetaRequest targetMetaRequest,
                       MethodMetaArgs methodMetaArgs) throws
      Throwable {
    Debug.logVerbose(" enter AOP invoker for:" +targetMetaRequest.getTargetMetaDef().getClassName()
            +" method:" + methodMetaArgs.getMethodName(), module);
    
    Object result = null;
    MethodInvocation methodInvocation = null;
    try {
      List chain = advisorChainFactory.create(targetMetaRequest.getTargetMetaDef());
      Object[] args = methodMetaArgs.getArgs();
      Method method = methodConstructor.createMethod(targetServiceFactory, targetMetaRequest, methodMetaArgs);
      methodInvocation = new  ProxyMethodInvocation(chain, targetMetaRequest, targetServiceFactory, method, args);      
      Debug.logVerbose(" MethodInvocation will proceed ... ", module);
      result = methodInvocation.proceed();
    } catch (Exception ex) {
      Debug.logError(ex, module);
      throw new Exception(ex);
    } catch (Throwable ex) {
      throw new Throwable(ex);
    }
    return result;
  }
  
  public Object invoke(TargetMetaRequest targetMetaRequest,
          Method method, Object[] args) throws Throwable {
      Debug.logVerbose(" enter AOP invoker2 for:" +targetMetaRequest.getTargetMetaDef().getClassName()
              +" method:" + method.getName(), module);

      
      Object result = null;
      MethodInvocation methodInvocation = null;
      try {
        List chain = advisorChainFactory.create(targetMetaRequest.getTargetMetaDef());
        methodInvocation = new  ProxyMethodInvocation(chain, targetMetaRequest, targetServiceFactory, method, args);      
        Debug.logVerbose(" MethodInvocation will proceed ... ", module);
        result = methodInvocation.proceed();
      } catch (Exception ex) {
        Debug.logError(ex, module);
        throw new Exception(ex);
      } catch (Throwable ex) {
        throw new Throwable(ex);
      }
      return result;
      
  }

}