- 浏览: 39479 次
- 性别:
- 来自: 北京
最新评论
最近研究了一下javassist框架,目前我对它的理解是它是一个动态创建类的框架。作为自己的学习的阶段成果使用它模拟了一个jdk动态代理的实现,在这里和大家分享一下。其实这反射的编程比想象中的麻烦一点的,期间遇到很多不好解决的问题放到javassist就不能执行,还好自己还是坚持完成了。如果我的实现方式有可优化或者漏洞欢迎大家指出。
主要实现类
MyProxy:提供一个静态方法创建代理对象,主要代码都在这里。整理思路是使用它动态的创建一个类然后使用MyInvocationHandler的实现调用业务接口实现类的具体方法,这样就完成了动态代理一个类的基本操作;
MyInvocationHandler:提供一个动态代理的接口供使用者使用,比较简单;
MyProxy
MyInvocationHandler
测试代码:
业务接口类IEcho
业务接口实现类EchoEn
代理模式接口实现类:TestInvocationHandler
测试代码
输出结果:
主要实现类
MyProxy:提供一个静态方法创建代理对象,主要代码都在这里。整理思路是使用它动态的创建一个类然后使用MyInvocationHandler的实现调用业务接口实现类的具体方法,这样就完成了动态代理一个类的基本操作;
MyInvocationHandler:提供一个动态代理的接口供使用者使用,比较简单;
MyProxy
package qhy.demo.javassist.myDynamicProxy; import java.lang.reflect.Modifier; import javassist.ClassPool; import javassist.CtClass; import javassist.CtField; import javassist.CtField.Initializer; import javassist.CtMethod; public class MyProxy { private static int proxyIndex = 1; private static String PROXY_SUFFIX="_$Proxy_"; //代理类的名称 /** * * Description: 创建代理对象. <br/> * @param interfaceClass 接口定义 * @param implClass 实现类 * @param invocationClass 代理类 * @return * @throws Exception */ public static <T> T newProxyInstance(Class<T> interfaceClass, Class<? extends T> implClass, Class<? extends MyInvocationHandler> invocationClass) throws Exception { String interfaceName = interfaceClass.getName(); //业务接口 String implClassName = implClass.getName();//业务实现类,被代理的对象 String invocationImplClassName = invocationClass.getName(); //代理模式接口实现类 //开始生成代理类实例 String proxyClassName = interfaceName + PROXY_SUFFIX + proxyIndex++; ClassPool cp = ClassPool.getDefault(); CtClass proxyImplClass = cp.makeClass(proxyClassName); //1、设置实现类的 接口 CtClass interfaceCtClass = cp.getCtClass(interfaceName); proxyImplClass.addInterface(interfaceCtClass); CtMethod[] interfaceCtMethods = interfaceCtClass.getDeclaredMethods(); if(interfaceCtMethods !=null && interfaceCtMethods.length > 0){ //2、注入invocationHandler 属性 CtField newField = new CtField(cp.get(invocationImplClassName), "testInvoke", proxyImplClass); newField.setModifiers(Modifier.PRIVATE); proxyImplClass.addField(newField, Initializer.byExpr(" testInvoke = new "+invocationImplClassName+"();")); int i = 0; for (CtMethod ctMethod : interfaceCtMethods) { //3、循环创建接口的实现方法 //3.1、创建方法定义 String methodName = ctMethod.getName(); CtClass returnType = ctMethod.getReturnType(); CtClass[] paramTypes = ctMethod.getParameterTypes(); CtMethod newMethod = new CtMethod(returnType, methodName, paramTypes, proxyImplClass); newMethod.setModifiers(Modifier.PUBLIC); //3.1、创建方法体 StringBuffer body = new StringBuffer(); body.append("{"); //3.2、生成获取指定实现类方法的代码 String getMethodArg = generateImplGetMethodCode(methodName,implClassName,paramTypes); body.append("\n Object result = testInvoke.invoke(Class.forName(\""+implClassName+"\").newInstance(),"+getMethodArg+",$args);"); //3.3、生成获取指定实现类方法的代码 String returnCode = generateImplReturnCode(returnType,"result"); if(returnCode !=null && returnCode.trim().length()>5){ body.append(returnCode); } // body.append("\n return ("+returnType.getName()+")result;"); body.append("}"); newMethod.setBody(body.toString()); proxyImplClass.addMethod(newMethod); i++; } } Object obj = proxyImplClass.toClass().newInstance(); return (T)obj; } /** * Description:生成返回代码 . <br/> * @param returnType * @param string * @return */ private static String generateImplReturnCode(CtClass returnType, String returnVariableName) { String returnCode = null; if(returnType != CtClass.voidType){ if(returnType.isPrimitive()){ if(returnType == CtClass.intType){ returnCode = "\n return (("+Integer.class.getName()+")"+returnVariableName+").intValue();"; }else if(returnType == CtClass.byteType){ returnCode = "\n return (("+Byte.class.getName()+")"+returnVariableName+").byteValue();"; }else if(returnType == CtClass.booleanType){ returnCode = "\n return (("+Boolean.class.getName()+")"+returnVariableName+").booleanValue();"; }else if(returnType == CtClass.charType){ returnCode = "\n return (("+Character.class.getName()+")"+returnVariableName+").charValue();"; }else if(returnType == CtClass.doubleType){ returnCode = "\n return (("+Double.class.getName()+")"+returnVariableName+").doubleValue();"; }else if(returnType == CtClass.floatType){ returnCode = "\n return (("+Float.class.getName()+")"+returnVariableName+").floatValue();"; }else if(returnType == CtClass.longType){ returnCode = "\n return (("+Long.class.getName()+")"+returnVariableName+").longValue();"; }else if(returnType == CtClass.shortType){ returnCode = "\n return (("+Short.class.getName()+")"+returnVariableName+").shortValue();"; } }else{ returnCode = "\n return ("+returnType.getName()+") "+returnVariableName+";"; } } return returnCode; } /** * Description: 获取方法的代码指定实现方法的代码. <br/> * @param methodName * @param implClassName * @param paramTypes */ private static String generateImplGetMethodCode(String methodName, String implClassName, CtClass[] paramTypes) { //没用约束的方法这么定义获取方式 String getMethodArg="Class.forName(\""+implClassName+"\").getDeclaredMethod(\""+methodName+"\", null)"; if(paramTypes!=null && paramTypes.length>0){ StringBuffer sb = new StringBuffer("new Class[]{"); int paramLength = paramTypes.length; for (int j = 0; j < paramLength; j++) { String calssName = paramTypes[j].getName(); if(j == (paramLength-1)){ sb.append(calssName).append(".class"); }else{ sb.append(calssName).append(".class").append(","); } } sb.append("}"); getMethodArg = "Class.forName(\""+implClassName+"\").getDeclaredMethod(\""+methodName+"\","+sb.toString()+")"; } return getMethodArg; } }
MyInvocationHandler
package qhy.demo.javassist.myDynamicProxy; import java.lang.reflect.Method; public interface MyInvocationHandler { public Object invoke(Object proxy,Method method,Object[] args) throws Throwable; }
测试代码:
业务接口类IEcho
package qhy.demo.javassist.myDynamicProxy.test; import java.util.Date; public interface IEcho { public void echo(); public int echo(int aa); public Boolean echo1(int aa,String user); public long getCurrentType(); public Date getDate(String aa); public ObjectModel echo(ObjectModel model); public char getChar(); }
业务接口实现类EchoEn
package qhy.demo.javassist.myDynamicProxy.test; import java.util.Date; public class EchoEn implements IEcho { @Override public void echo() { System.out.println("hello "+233434+"!"); } @Override public long getCurrentType() { System.out.println("getCurrentType"); return System.currentTimeMillis(); } @Override public Boolean echo1(int aa, String user) { System.out.println("getDate;param="+aa+","+user); // TODO Auto-generated method stub return true; } @Override public char getChar() { return 'A'; } @Override public Date getDate(String aa) { System.out.println("getDate;param="+aa); // TODO Auto-generated method stub return null; } @Override public ObjectModel echo(ObjectModel model) { System.out.println("echo(ObjectModel model)>>>>>>>param="+model.getName()); ObjectModel result = new ObjectModel("郑文玉", 33, 10023L); return result; } @Override public int echo(int aa) { System.out.println("我是AAA"+aa+"!"); return -98; } }
代理模式接口实现类:TestInvocationHandler
package qhy.demo.javassist.myDynamicProxy.test; import java.lang.reflect.Method; import qhy.demo.javassist.myDynamicProxy.MyInvocationHandler; public class TestInvocationHandler implements MyInvocationHandler { @Override public Object invoke(Object proxy, Method method, Object[] args) throws Throwable { System.out.println("执行前:拦截111111111111111"); Object result = method.invoke(proxy, args); System.out.println("执行后:拦截22222222222222222"); return result; } }
测试代码
package qhy.demo.javassist.myDynamicProxy.test; import qhy.demo.javassist.myDynamicProxy.MyProxy; public class Test { /** * Description: . <br/> * * @param args * @throws Exception */ public static void main(String[] args) throws Exception { IEcho echo = MyProxy.newProxyInstance(IEcho.class, EchoEn.class, TestInvocationHandler.class); echo.echo(); int aa = echo.echo(888); System.err.println(">>>>>>>>>>>>>>"+aa); Boolean bool = echo.echo1(555, "qihyyy"); System.err.println(">>>>>>>>>>>>>>"+bool); ObjectModel result = new ObjectModel("qiqi玉", 31, 6013L); ObjectModel objModel = echo.echo(result); System.err.println(">>>>objModel>>>>>>>>>>"+objModel.getName()+"--"+objModel.getAge()+"--"+objModel.getCurrentTime()); char cha = echo.getChar(); System.err.println(">>>>getChar>>>>>>>>>>"+cha); } }
输出结果:
发表评论
-
Java实现SPI基础工具类
2016-09-09 17:16 1265概述: 前端时间看了一下dubbo源码被它使用的基于SPI(s ... -
JSP COOKIE使用
2015-12-05 16:08 474原来一直在想要实现可 ... -
Jedis事务用法
2015-11-25 20:06 1715今天同事问了一个redis的问题,主要就是出现错误之后就把所有 ... -
zookeeper笔记
2015-11-24 08:17 274这个笔记是2013年初写的,当时学习solr发现solr使用了 ... -
jdk1.7安装之后切换不回去
2015-11-02 20:03 593错误现象: 在win7上安装过jdk1.7之后,然后把环境变量 ... -
hadoopMapReduce小例子
2015-03-28 21:08 453今天做了一个简单的mapreduce小程序,目的是熟悉一下怎么 ... -
VMware虚拟机搭建Hadoop集群
2014-12-05 22:07 943最近搭建了hadoop2.5的集群,在这里分享一下希望能帮助到 ... -
Hibernate代码生成插件(eclipse)
2014-05-04 12:31 795阅读对象: 有一些hibernate使用经验的开发人员; 介绍 ... -
eclipse文件同步插件
2014-04-29 17:41 604clipse同步插件用于指定两个目录(源目录和目标目录)做文件 ... -
修改WAS(WebSpehre)默认编码和jvm内存申请
2014-04-28 17:09 1071登陆WAS管理控制台,打开:服务器->应用程序服务器-& ... -
Apache HttpClient 代理、登陆访问百度开放平台
2014-04-23 17:50 805最近做了下使用httpclient登陆百度开放平台获取G ... -
windows下编写mapreduce程序
2014-04-20 09:51 743配置linux的hadoop环境比较繁琐,为了方便的编写 ... -
RMI随机生成端口解决方法(结合spring)
2014-04-20 08:20 2905RMI有一个网络端口和一个数据端口,网络端口我们在程序里 ... -
WAS(WebSphere)修改端口
2014-04-20 07:58 39811、修改管理页面端口(默认:9060) a>进入控制台页 ...
相关推荐
maven项目,基于spring3+springmvc+oracle的医疗项目
主流框架SSI的搭建以及实现过程,你值的拥有!
SSI框架下的动态二叉树 便于学习 数据库是sql server2005 自己搭建
刚学完ssi时候 做的一个会员注册登录的效果,是一个初级开发者很好的参考资料。
FPGA之SSI接口协议实现 fpga开发.pdf
基于SSI框架的开发的用户信息管理项目源码,当做毕业论文设计也是可以的,其中的功能都是好用的,而且也通俗易懂,对于初学SSI框架也是一个很好的练习。 注:程序操作数据的表名为USER2,需要在数据库建一个这样的...
Java开发的简单ssi框架,适用于初学者
SSI框架 实现登陆以及 增删改查 LZLL第三部
struts+spring+ibatis框架实现登陆以及增删改查
strut2 spring ibatis三大框架整合
struts2+spring+ibatis做的小程序
近年来,随着科技和工业的快速发展,...详细阐述了SSI协议的通信方式,设计出硬件电路,并采用Verilog语言实现了SSI通信协议。通过测试实验,证明了该应用系统抗干扰性强、性能可靠、通信速度快,具有潜在的市场价值。
这是一个官网的 SSI 框架小案例,有兴趣的朋友可以下载看一看。我也是刚接触,今天下载测试一下。
struts+spring+ibatis整合实例。只需弄个数据库,对着弄就行。
[项目实战] ibatis +spring+struts2+jquery.autocomplete实现产品自动补全功能 能成功部署运行
MyEclispse下SSI整合JAR包(Struts1+Spring3+ibatis2)
用ssi框架(struts2,spring,ibatis)实现的留言板,包括对留言的增删改查功能,PS(本人不太懂审美,页面可能不堪入目,但功能均可实现)
ssi Strtus2、Spring、iBatis三个开源的MVC框架 还用多说吗?
ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子ssi例子
SSI框架+sqlserver2005实现的登录及增删改查功能,有jar包