spring aop 切面编程

import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.apache.commons.lang.SerializationException;
import org.apache.commons.lang.SerializationUtils;
import org.aspectj.lang.JoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.AfterReturning;
import org.aspectj.lang.annotation.Aspect;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import cn.cbsw.entity.QyBumen;
import cn.cbsw.rabbitmq.RbChannel;
import cn.cbsw.rabbitmq.RbConnection;
import cn.cbsw.redis.token.TokenModel;
import cn.cbsw.tool.StringUtils;
import cn.cbsw.tran.daoimp.DanweiDao;

import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;

/**
 * 定义发送数据切面
 * @author Administrator
 *
 */
@Aspect // for aop
@Component // for auto scan
public class DataSend {

    private static String host = "127.0.0.1";    //haproxy在71的8100端口
    
    @Autowired
    DanweiDao danweiDao;
    
     /**
     * 返回通知：目标方法正常执行完毕时执行以下代码
     * @param jp
     * @param result
     */
    @AfterReturning(value="execution(* cn.cbsw.tran.serviceimp.*.insert*(..))"
                    + " or execution(* cn.cbsw.tran.serviceimp.*.update*(..))"
                    + " or execution(* cn.cbsw.tran.serviceimp.*.delete*(..))"
                    + " or execution(* cn.cbsw.tran.serviceimp.*.execute*(..))",returning="result")
    public void afterReturningMethod(JoinPoint jp, Object result){
        Signature signature=jp.getSignature();
        String methodName = signature.getName();
        
        sendData(jp.getArgs(),methodName,"");//发送数据
        
        //System.out.println("getDeclaringType："+signature.getDeclaringType().getSimpleName());
        
        System.out.println("【返回通知】the method 【" + methodName + "】 ends with 【" + result + "】");
    }
    
    
    /**
     * 发送数据至rabbiteMQ
     * @param o
     * @param type
     * @param dataType
     * @param areaCode
     */
    private void sendData(Object[] args,String type,String dataType){
        System.out.println(getAreaCodeAndData(args)[1]);
        String[] areaCodeAndData=getAreaCodeAndData(args);
        String areaCode=areaCodeAndData[0];
        if(StringUtils.isBlank(areaCode))
            return;
        Map map=new HashMap<>();
        map.put("type", type);
        map.put("data", areaCodeAndData[1]);
        map.put("dataType", areaCodeAndData[2]);
        
        //发送数据
        directSend("yzb.4100", "queue", new Gson().toJson(map));
        
    }
    
    /**
     * 发送数据
     */
    private void directSend(String exchangerName,String queue,String data){
        try {
            //链接
            RbConnection connection = new RbConnection(host, 5672, "guest", "guest", "");
            //通道
            RbChannel rbChannel = connection.getDirectChannel(exchangerName, queue, null);
            rbChannel.send(data, (Map)null);
            System.out.println("发送成功");
            rbChannel.close(true);//关闭连接,后台进程结束
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 获取单位所在辖区和需要发送的数据
     * @param args
     * @return
     */
    private String[] getAreaCodeAndData(Object[] args){
        String compId="",compCode="",data="",dataTypa="";
        List