`
qihuiyong6
  • 浏览: 40739 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

javassi实现t动态代理模式

 
阅读更多
最近研究了一下javassist框架,目前我对它的理解是它是一个动态创建类的框架。作为自己的学习的阶段成果使用它模拟了一个jdk动态代理的实现,在这里和大家分享一下。其实这反射的编程比想象中的麻烦一点的,期间遇到很多不好解决的问题放到javassist就不能执行,还好自己还是坚持完成了。如果我的实现方式有可优化或者漏洞欢迎大家指出。

主要实现类
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);
	}
}

输出结果:



  • 大小: 56.4 KB
分享到:
评论

相关推荐

    ssi.rar_ibatis_ibatis struts2_java ssi_myeclipse ssi_struts2

    "ibatis_struts2"表示iBatis和Struts2的集成使用,"java_ssi"可能是指在Java环境下实现的SSI功能,"myeclipse_ssi"则表明在MyEclipse中进行了SSI相关的开发工作。这些标签为理解项目的技术栈提供了指导。 压缩包内...

    SSI框架实现的动态二叉树

    本主题聚焦于使用SSI框架实现的动态二叉树,这是一个将数据结构与服务器端编程技术相结合的应用实例。在数据库管理中,动态二叉树能够有效地组织和展示数据,特别是对于层次结构明显的数据库结构,如组织结构、文件...

    SSI框架的实现

    在本教程中,我们将深入探讨如何实现SSI框架,并构建一个功能完善的动态网页系统。 1. **SSI基本语法** SSI的基本语法以`&lt;!--#`开头,`--&gt;`结尾,中间插入不同的指令。例如,`&lt;!--#include virtual="header....

    ssi实现注册登录

    - **登录状态**:如果用户已登录,可以使用SSI动态插入用户的个人信息或注销链接。 - **错误显示**:在登录失败时,可以通过SSI插入错误信息,而不是每次失败都刷新整个页面。 5. **安全性强化**: - **XSS防护*...

    SSI框架实现登陆以及增删改查

    Struts是Apache软件基金会的一个开源项目,它基于Model-View-Controller设计模式,帮助开发者构建动态网站。在登录功能中,Struts通常会创建一个Action类来处理用户的登录请求,接收表单参数,并通过业务逻辑判断...

    ssi框架代码实例

    SSI框架,即Struts2、Spring和iBatis的集成框架,是Java Web开发中常见的技术栈,用于构建高效、可维护的企业级应用程序。这个压缩包文件“ssi_curd”很可能包含了一个基本的CRUD(创建、读取、更新、删除)操作的...

    ssi框架简单搭建。。。

    在Java环境下,我们可以使用各种框架来实现SSI功能,以提高网站的开发效率和可维护性。下面我们将详细探讨Java中的SSI框架搭建及其应用。 首先,理解SSI的基本概念是必要的。SSI主要通过在HTML文件中使用特定的指令...

    ssi整合增删改查

    "SSI"是软件开发中的一个集成框架,代表Struts、Spring和iBatis三个组件的组合。这个框架常用于构建企业级的Java Web应用程序,提供强大的MVC(模型-视图-控制器)架构支持,以及数据库操作和依赖注入功能。 **...

    [项目实战] SSI实现产品自动补全功能

    在本项目实战中,我们将探讨如何使用SSI(Server-Side Includes)技术,结合流行的Java Web框架如iBatis、Spring和Struts2,以及前端库jQuery UI的autocomplete组件,来实现一个高效的产品自动补全功能。这个功能...

    FPGA之SSI接口协议实现 fpga开发.pdf

    FPGA之SSI接口协议实现 FPGA之SSI接口协议实现是指在 Field-Programmable Gate Array(现场可编程门阵列)中实现 Synchronous Serial Interface(同步串行接口)协议。SSI 是一种全双工的串行接口,允许芯片与多种...

    SSI实例,新手专用

    开发者可以在XML配置文件或者注解中定义SQL语句,通过Java接口或类调用这些SQL,从而实现数据的增删改查操作。iBatis与Spring结合使用时,可以无缝集成到Spring的IoC容器中,实现事务管理和数据访问对象(DAO)的...

    java-ssi医疗系统

    【标题】"java-ssi医疗系统"是一个基于Java技术栈的医疗信息系统,它采用Maven作为构建工具,结合Spring框架的三个核心组件——Spring、SpringMVC和Oracle数据库,为医疗机构提供了一整套功能完善的解决方案。...

    java SSI框架 简单的登录注册和增删改查

    基于SSI框架的开发的用户信息管理项目源码,当做毕业论文设计也是可以的,其中的功能都是好用的,而且也通俗易懂,对于初学SSI框架也是一个很好的练习。 注:程序操作数据的表名为USER2,需要在数据库建一个这样的...

    SSI框架 实现登陆以及 增删改查 LZLL

    **SSI(Server Side Includes)框架**是一种在服务器端执行的小型脚本语言,常用于动态网页的构建。它允许Web开发者在HTML文档中嵌入动态内容,如时间、日期、服务器变量等,而无需使用更复杂的服务器端技术如PHP或...

    SSI框架项目案例

    SSI,全称Server-Side Includes,是一种简单的服务器端脚本语言,主要用于网页动态包含静态内容。这个"SSI框架项目案例"提供了一个实践性的学习资源,适合对SSI技术感兴趣或者正在学习的朋友。通过下载并查看该项目...

    ssi框架实现的留言板

    在IT行业中,SSI(Struts2、Spring、iBatis)是一种常见的企业级应用开发框架组合,它集成了MVC设计模式、依赖注入以及持久层操作,大大提高了开发效率和代码的可维护性。本项目以"ssi框架实现的留言板"为例,将深入...

    SSI框架实现增删改查(spring2.5 + struts2.1 + ibatis2.3)

    在Spring和Struts的集成中,iBatis作为数据访问对象(DAO)层,负责与数据库的交互,通过XML配置文件或注解定义SQL映射,实现了动态SQL和数据访问的定制化。 **Junit测试框架**: Junit是Java开发中最常用的单元...

    采用SSI协议实现的绝对值编码器

    在硬件设计中,采用Verilog语言实现SSI通信协议,这是一种硬件描述语言,用于描述数字系统的结构和行为。通过Verilog编程,可以创建出能够处理SSI协议的逻辑电路,实现编码器与主控系统的高效通信。 绝对值编码器与...

    ssi 纯净框架

    在Java Web开发领域,SSI(Struts2、Spring、iBatis)框架组合被誉为经典的“铁三角”架构,以其强大的功能和灵活性深受开发者喜爱。本篇文章将深入探讨这三个开源框架的核心概念、功能以及它们如何协同工作,帮助你...

    SSI例子(很全面,下载请评论)

    在本压缩包中,我们看到的是一个基于JAVA实现的SSI框架搭建实例。 【描述】:“JAVA SSI框架搭建的例子,字段很多,写的很全面,增删改查各种功能,ECLIPSE工具下。”这表明提供的压缩包内包含了一个完整的Java应用...

Global site tag (gtag.js) - Google Analytics