反射机制——通过反射调用service中方法

﹏ヽ暗。殇╰゛Y 2021-09-26 18:02 794阅读 0赞

需求：现在有一群service接口，有同一个方法名称，内部逻辑除了调用不同的调用自身的方法外其他基本都一致，那现在就需要一个独立的方法来勾勒出这个方法

1.SpringContextUtil

package com.XXX.report.util;
    
    import org.apache.log4j.Logger;
    import org.springframework.beans.BeansException;
    import org.springframework.beans.factory.NoSuchBeanDefinitionException;
    import org.springframework.context.ApplicationContext;
    import org.springframework.context.ApplicationContextAware;
    import org.springframework.stereotype.Component;
    /** 
    * @FileName SpringContextUtil.java
    * @Description:
    * @author 东天里的冬天
    * @version V1.0
    * @createtime 2018年5月11日 上午9:54:57 
    * 修改历史：
    * 时间           作者          版本        描述
    *====================================================  
    *
    */
    @Component
    public class SpringContextUtil implements ApplicationContextAware {  
        private static Logger logger = Logger.getLogger(SpringContextUtil.class);  
        private static ApplicationContext applicationContext = null;  
      
        public void setApplicationContext(ApplicationContext applicationContext) throws BeansException  
        {  
            logger.info("------SpringContextUtil setApplicationContext-------");  
            SpringContextUtil.applicationContext = applicationContext;  
        }  
      
        public static ApplicationContext getApplicationContext() {  
            return applicationContext;  
        }  
      
        /** 
         * 注意 bean name默认 = 类名(首字母小写) 
         * 例如: A8sClusterDao = getBean("a8sClusterDao") 
         * @param name 
         * @return 
         * @throws BeansException 
         */  
        public static Object getBean(String name) throws BeansException {  
            return applicationContext.getBean(name);  
        }  
      
        /** 
         * 根据类名获取到bean 
         * @param <T> 
         * @param clazz 
         * @return 
         * @throws BeansException 
         */  
        @SuppressWarnings("unchecked")  
        public static <T> T getBeanByName(Class<T> clazz) throws BeansException {  
            try {  
                char[] cs=clazz.getSimpleName().toCharArray();  
                cs[0] += 32;//首字母大写到小写  
                return (T) applicationContext.getBean(String.valueOf(cs));  
            } catch (Exception e) {  
                e.printStackTrace();  
                return null;  
            }   
        }  
      
        public static boolean containsBean(String name) {  
            return applicationContext.containsBean(name);  
        }  
      
        public static boolean isSingleton(String name) throws NoSuchBeanDefinitionException {  
            return applicationContext.isSingleton(name);  
        }  
    
    }

2.配置文件中注入SpringContextUtil

3.BaseServiceImpl

package com.XXX.report.core.service.impl;
    
    import java.lang.reflect.Method;
    import java.util.concurrent.atomic.AtomicInteger;
    import org.apache.log4j.Logger;
    import org.springframework.stereotype.Service;
    import org.springframework.util.ReflectionUtils;
    import com.XXX.report.core.service.BaseService;
    import com.XXX.report.util.DateUtil;
    import com.XXX.report.util.SpringContextUtil;
    /** 
    * @FileName BaseServiceImpl.java
    * @Description:
    * @author 东天里的冬天
    * @version V1.0
    * @createtime 2018年5月10日 下午3:12:20 
    * 修改历史：
    * 时间           作者          版本        描述
    *====================================================  
    *
    */
    @Service
    public class BaseServiceImpl implements BaseService{
    	private  Logger logger = Logger.getLogger(BaseServiceImpl.class);
    	
    	
    	@Override
    	public int checkMonthOrDate(String monthOrDate) {
    		int length=monthOrDate.length();
    		if(length!=7&&length!=10) {
    			logger.error("输入日期长度错误，错误日期monthOrDate为："+monthOrDate);
    			return 0;
    		}
    		if(length==7) {
    			if(DateUtil.checkMonth(monthOrDate)<=0) {
    				return 0;
    			}
    		}
    		if(length==10) {
    			if(DateUtil.checkDate(monthOrDate)<=0) {
    				return 0;
    			}
    		}
    		return 1;
    	}
    	@Override
    	public int checkMonth(String month) {
    		int length=month.length();
    		if(length==7) {
    			if(DateUtil.checkMonth(month)<=0) {
    				return 0;
    			}
    		}
    		return 1;
    	}
    	@Override
    	public int monthRequestMethod(final Class clazz, String month) {
    		if(DateUtil.checkMonth(month)<=0) {
    			return 0;
    		}
    		final long start=System.currentTimeMillis();
    		final int days = DateUtil.getMonthDays(month);
    		final String monthshow=month;
    		final String methodName="insertByDate";
    		String orgClassName=clazz.getSimpleName();
    		String startName=orgClassName.substring(0, 1).toLowerCase();//
    		String endName=orgClassName.substring(1, orgClassName.length());
    		final String className=startName+endName;
    		List<Thread> threadList=new LinkedList<Thread>();
    		for(int i=1;i<=days;i++) {
    			final AtomicInteger j=new AtomicInteger();
    			j.set(i);
    			Thread thread = new Thread(new Runnable() {
    				@Override
    				public void run() {
    					String date="";
    					if(j.get()<10) {
    						date=monthshow+"-0"+j.get();
    					}else {
    						date=monthshow+"-"+j.get();
    					}
    					try {
    						//通过SpringContextUtil.getBean方法初始化bean
    						Method  mh = ReflectionUtils.findMethod(SpringContextUtil.getBean(className).getClass(),methodName,new Class[]{String.class} );  
    				        ReflectionUtils.invokeMethod(mh,SpringContextUtil.getBean(className),date);  
    					} catch (Exception e) {
    						logger.error("BaseService.monthService异常",e);
    					}
    				}
    			});
    			thread.start();
    			threadList.add(thread);
    		}
    		for(Thread thread:threadList) {
    			while(thread.isAlive()) {
    				try {
    					Thread.sleep(10);
    				} catch (InterruptedException e) {
    					logger.error("BaseService.monthRequestMethod线程异常", e);
    				}
    			}
    		}
    		logger.info(orgClassName+"月份为:"+month+",月份数据总耗时："+(System.currentTimeMillis()-start));
    		return 1;
    	}	
    }	public int monthRequestMethod(final Class clazz, String month) {
    		if(DateUtil.checkMonth(month)<=0) {
    			return 0;
    		}
    		final long start=System.currentTimeMillis();
    		final int days = DateUtil.getMonthDays(month);
    		final String monthshow=month;
    		final String methodName="insertByDate";
    		String orgClassName=clazz.getSimpleName();
    		String startName=orgClassName.substring(0, 1).toLowerCase();//
    		String endName=orgClassName.substring(1, orgClassName.length());
    		final String className=startName+endName;
    		List<Thread> threadList=new LinkedList<Thread>();
    		for(int i=1;i<=days;i++) {
    			final AtomicInteger j=new AtomicInteger();
    			j.set(i);
    			Thread thread = new Thread(new Runnable() {
    				@Override
    				public void run() {
    					String date="";
    					if(j.get()<10) {
    						date=monthshow+"-0"+j.get();
    					}else {
    						date=monthshow+"-"+j.get();
    					}
    					try {
    						//通过SpringContextUtil.getBean方法初始化bean
    						Method  mh = ReflectionUtils.findMethod(SpringContextUtil.getBean(className).getClass(),methodName,new Class[]{String.class} );  
    				        ReflectionUtils.invokeMethod(mh,SpringContextUtil.getBean(className),date);  
    					} catch (Exception e) {
    						logger.error("BaseService.monthService异常",e);
    					}
    				}
    			});
    			thread.start();
    			threadList.add(thread);
    		}
    		for(Thread thread:threadList) {
    			while(thread.isAlive()) {
    				try {
    					Thread.sleep(10);
    				} catch (InterruptedException e) {
    					logger.error("BaseService.monthRequestMethod线程异常", e);
    				}
    			}
    		}
    		logger.info(orgClassName+"月份为:"+month+",月份数据总耗时："+(System.currentTimeMillis()-start));
    		return 1;
    	}	
    }

4.方法的调用

注意service注解上的别名不能随意更改，必须是接口名的首字母小写

package com.XXX.report.core.service.impl;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    import java.util.HashMap;
    import java.util.LinkedList;
    import java.util.List;
    import java.util.Map;
    import org.apache.log4j.Logger;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    import com.XXX.core.service.AbstractBaseService;
    import com.XXX.core.util.StrUtils;
    import com.XXX.report.core.dao.ActivitysalesinfobydateMapper;
    import com.XXX.report.core.model.Activitysalesinfobydate;
    import com.XXX.report.core.service.ActivitysalesinfobydateService;
    import com.XXX.report.core.service.BaseForwardService;
    import com.XXX.report.core.service.BaseOrderDetailService;
    import com.XXX.report.core.service.BaseService;
    import com.XXX.report.core.service.BaseStatisticsService;
    import com.XXX.report.core.service.BaseTransportService;
    import com.XXX.report.util.DateUtil;
    import com.XXX.report.util.MathUtils;
    
    /**资方
     * 日活动销售情况汇总的业务处理接口
     * @author 123456
     * @version 1.0$2018-03-02 11:13:57
     * 
     */
    @Service("activitysalesinfobydateService") 
    @Transactional
    public class ActivitysalesinfobydateServiceImpl extends AbstractBaseService<Activitysalesinfobydate> implements ActivitysalesinfobydateService{
    	private  Logger logger = Logger.getLogger(ActivitysalesinfobydateServiceImpl.class);
    
    	@Autowired
    	BaseService baseService;
    	
    	@Override
    	public int insertActivitysalesinfobyMonth(String month) {
    		baseService.monthRequestMethod(ActivitysalesinfobydateService.class, month);
    		return 1;
    	}	
    }