标签：future voc callback man 调试 4.0 property run tar
开始研究动态代理之前 先简要谈下动态代理的概念
在不改变原有类结构的前提下增强类的功能以及对类原有方法操作，注意是方法不是属性(属性一般被设计为private修饰，不可以直接被调用)
动态代理的基本实例不做阐述，网上一大把 不理解的同学可以直接去搜索。
今天说的是自己在项目中遇到的一个实际的动态代理应用--》定时刷新多数据库的连接接属性
项目背景：项目中存在三个数据库 redis PostgreSQL(PT库) oracle
我们做的需求是将oracle和redis的数据库链接存储在 PT库中 然后项目启动后从PT库的自定义配置表中读取oracle和redis的数据库链接
在这里我们使用的是druid连接池 有兴趣的伙伴可以去研究下
废话不多说直接上代码实例
基于CGlib实现
1 package com.manager.aop; 2 3 import java.lang.reflect.Method; 4 import java.sql.SQLException; 5 import java.util.concurrent.ScheduledFuture; 6 import javax.annotation.PostConstruct; 7 import javax.sql.DataSource; 8 import org.springframework.beans.factory.FactoryBean; 9 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; 10 import com.alibaba.druid.pool.DruidDataSource; 11 import net.sf.cglib.proxy.Enhancer; 12 import net.sf.cglib.proxy.MethodInterceptor; 13 import net.sf.cglib.proxy.MethodProxy; 14 15 16 17 18 public class DynamicProxy implements FactoryBean<DataSource> { 19 20 private DruidDataSource target; 21 private DataSource proxy; 22 23 24 //这两个类是线程池的类用来做定时器任务 25 //需要用注解注入进来 26 private ThreadPoolTaskScheduler scheduler; 27 private ScheduledFuture<?> future; 28 29 30 //存储每次刷新的上一次的数据库的链接属性，以便和最新的数据库链接对比 31 private String key; 32 @PostConstruct 33 private void init() throws SQLException { 34 //项目启动后 第一次实例化连接池 35 target=createDataSource(); 36 //生成Druid链接池的代理对象 37 proxy=(DataSource) Enhancer.create(target.getClass(),//设置代理目标类的字节码对象 38 CallBacks()//设置代理对象的回调对象 39 ); 40 //判断是否创建新的代理对象 41 refresh(); 42 future=scheduler.scheduleWithFixedDelay(new Runnable() { 43 public void run() { 44 // TODO Auto-generated method stub 45 try { 46 refresh(); 47 } catch (SQLException e) { 48 // TODO Auto-generated catch block 49 e.printStackTrace(); 50 } 51 } 52 }, 1000*10); 53 } 54 private void refresh() throws SQLException { 55 //这里的key的值是从PT数据库读取而来的 oracle的链接属性的拼接值 没有全写 56 //写一个service去从pt数据库里面 定时 获取oracle的连接参数 定时任务和此处的定时器一致 57 String key="username+password+url"; 58 //如果最新的连接池属性拼接参数key和上一次的key不相同 则销毁上次的委托对象并创建新的数据库连接 如果相同者不做处理 59 if(this.key.equals(key)) { 60 if(target!=null) { 61 target.close(); 62 } 63 //当数据库链接不同的时候才会重新给key添加新的引用 64 this.key=key; 65 target=createDataSource(); 66 } 67 } 68 private DruidDataSource createDataSource() throws SQLException { 69 70 //在这里设置连接池的属性 同样没有写全 71 DruidDataSource druid=new DruidDataSource(); 72 druid.setUrl("url"); 73 //阿里连接池的自行初始化 如果不初始化 代理的连接池对象的属性为空 74 druid.init(); 75 return druid; 76 } 77 78 private MethodInterceptor CallBacks() { 79 return new MethodInterceptor() { 80 public Object intercept(Object obj, Method method, Object[] args, MethodProxy proxy) throws Throwable { 81 // TODO Auto-generated method stub 82 //在这里执行被代理对象的操作 83 Object result=proxy.invokeSuper(target, args); 84 //在这里执行被代理对象的操作 85 return result; 86 } 87 }; 88 } 89 public DataSource getObject() throws Exception { 90 // TODO Auto-generated method stub 91 return proxy; 92 } 93 public Class<?> getObjectType() { 94 // TODO Auto-generated method stub 95 return null; 96 } 97 public boolean isSingleton() { 98 // TODO Auto-generated method stub 99 return true; 100 } 101 102 }
这里实现了 FactoryBean<DataSource> 为什么要实现FactoryBean 主要是为了在xml做的ref引用时获得DataSource代理对象
基于JDK实现
1 package com.manager.aop; 2 3 import java.lang.reflect.InvocationHandler; 4 import java.lang.reflect.Method; 5 import java.lang.reflect.Proxy; 6 import java.sql.SQLException; 7 import java.util.concurrent.ScheduledFuture; 8 9 import javax.annotation.PostConstruct; 10 import javax.sql.DataSource; 11 12 import org.springframework.beans.factory.FactoryBean; 13 import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; 14 import org.springframework.util.ClassUtils; 15 16 import com.alibaba.druid.pool.DruidDataSource; 17 18 19 public class JdkProxy implements FactoryBean<DataSource> { 20 private DruidDataSource target; 21 private DataSource proxy; 22 23 24 //这两个类是线程池的类用来做定时器任务 25 private ThreadPoolTaskScheduler scheduler; 26 private ScheduledFuture<?> future; 27 28 29 //存储每次刷新的上一次的数据库的链接属性，以便和最新的数据库链接对比 30 private String key; 31 @PostConstruct 32 private void init() throws SQLException { 33 //项目启动后 第一次实例化连接池 34 target=createDataSource(); 35 //生成Druid链接池的代理对象 36 proxy=(DataSource) Proxy.newProxyInstance(ClassUtils.getDefaultClassLoader(), //获取类加载器 37 DataSource.class.getInterfaces(), //获取DataSource所实现的接口 38 handler()); 39 //判断是否创建新的代理对象 40 refresh(); 41 future=scheduler.scheduleWithFixedDelay(new Runnable() { 42 public void run() { 43 // TODO Auto-generated method stub 44 try { 45 refresh(); 46 } catch (SQLException e) { 47 // TODO Auto-generated catch block 48 e.printStackTrace(); 49 } 50 } 51 }, 1000*10); 52 } 53 private void refresh() throws SQLException { 54 //这里的key的值是从PT数据库读取而来的 oracle的链接属性的拼接值 没有全写 55 String key="username+password+url"; 56 //如果最新的连接池属性拼接参数key和上一次的key不相同 则销毁上次的委托对象并创建新的数据库连接 如果相同者不做处理 57 if(this.key.equals(key)) { 58 if(target!=null) { 59 target.close(); 60 } 61 //当数据库链接不同的时候才会重新给key添加新的引用 62 this.key=key; 63 target=createDataSource(); 64 } 65 } 66 private DruidDataSource createDataSource() throws SQLException { 67 68 //在这里设置连接池的属性 同样没有写全 69 DruidDataSource druid=new DruidDataSource(); 70 druid.setUrl("url"); 71 //阿里连接池的自行初始化 如果不初始化 代理的连接池对象的属性为空 72 druid.init(); 73 return druid; 74 } 75 76 private InvocationHandler handler() { 77 return new InvocationHandler() { 78 public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { 79 // TODO Auto-generated method stub 80 Object obj=method.invoke(target, args); 81 return obj; 82 } 83 }; 84 } 85 public DataSource getObject() throws Exception { 86 // TODO Auto-generated method stub 87 return proxy; 88 } 89 public Class<?> getObjectType() { 90 // TODO Auto-generated method stub 91 return null; 92 } 93 public boolean isSingleton() { 94 // TODO Auto-generated method stub 95 return true; 96 } 97 }
再来看xml如何到底是怎么配置的
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" 4 xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" 5 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 6 xmlns:util="http://www.springframework.org/schema/util" 7 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd 8 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd 9 http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd 10 http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util-4.0.xsd"> 11 <!-- 配置dao层扫描 --> 12 <context:property-placeholder location="classpath:conf/database.properties" /> 13 <!-- 通过JDBC模版获取数据库连接 --> 14 <bean scope="singleton" id="jdbcTemplate" 15 class="org.springframework.jdbc.core.JdbcTemplate"> 16 <property name="dataSource" ref="dataSource"></property> 17 </bean> 18 <!-- 数据库连接池 --> 19 //这里的class写的是我们所写的代理类的类路径 20 <bean id="dataSource" class="com.manager.aop.JdkProxy"> 21 //这里什么都可以不用写 因为我们在类中已经设置了属性 22 </bean> 23 24 <!-- 让spring管理sqlsessionfactory 使用mybatis和spring整合包中的 --> 25 <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> 26 <!-- 数据库连接池 --> 27 //这里的ref引用的时候 会调用类中的getObject()方法拿到代理对象 28 <property name="dataSource" ref="dataSource" /> 29 <!-- 加载mybatis的全局配置文件 --> 30 <property name="mapperLocations" value="classpath:com/mapper/*.xml" /> 31 </bean> 32 //其他的配置没有写 只是示例在xml怎么拿到代理类所返回的代理对象供其他bean使用 33 </beans>
这里只是给出一个动态代理在项目中的应用实际情况，希望给各位同仁一点应用动态的代理的思路和技巧。单独拿出来是无法使用要配合实际的项目背景来调试和使用
如有错误和理解性的错误，请及时指出 大家一起学习。
标签：future voc callback man 调试 4.0 property run tar
原文地址：https://www.cnblogs.com/tongAngle/p/10292864.html
