Rmi.rar_Java RMI_RMI java_java RMI 线程_rmi

package SpringRMI; import java.lang.reflect.Method; import java.rmi.Naming; import java.rmi.Remote; import org.aopalliance.intercept.MethodInterceptor; import org.aopalliance.intercept.MethodInvocation; import org.springframework.aop.framework.ProxyFactory; import org.springframework.beans.factory.FactoryBean; /* * 客户端的相关类。在MockRmiProxyFactoryBean中，它使用MethodInterceptor拦截了所有对于导出接口方法的调用并转发给相应的stub。 如果这个stub是实现了MockRmiInvocationHandler（比如MockRmiInvocationWrapper）， 那么会把所有的调用转发给MockRmiInvocationHandler的invoke方法， 同时构造一个MockRemoteInvocation。此后就是通过MockRmiInvocationWrapper_Stub进行远程调用了。 服务器端接收到请求之后，在MockRmiInvocationWrapper类中又把这个请求转发到this.rmiExporter.invoke(invocation, this.wrappedObject)。 在MockRmiServiceExporter的invoke方法中，再次转发给MockRemoteInvocation的invoke方法, 最终在MockRemoteInvocation.inovke方法中调用了targetObject上的相关方法。顺便说一下， 由于MockRemoteInvocation对象是从客户端通过序列化传递到服务器端的, 而且在这个对象中保存了客户端调用的方法名及参数列表，所以在这个对象中能最终决定应该调用targetObject上的哪个方法。 * */ public class MockRmiProxyFactoryBean implements FactoryBean, MethodInterceptor { // private Object serviceProxy; // private String serviceUrl; private Class<?> serviceInterface; public Object getObject() { return serviceProxy; } @SuppressWarnings("unchecked") public Class getObjectType() { return getServiceInterface(); } public boolean isSingleton() { return true; } protected Remote getStub() throws Throwable { Remote stub = Naming.lookup(getServiceUrl()); return stub; } public Object invoke(MethodInvocation invocation) throws Throwable { Remote stub = null; try { stub = getStub(); } catch (Throwable ex) { throw ex; } try { return doInvoke(invocation, stub); } catch (Exception ex) { throw ex; } } protected Object doInvoke(MethodInvocation mi, Remote stub) throws Throwable { if (stub instanceof MockRmiInvocationHandler) { // RMI invoker try { return doInvoke(mi, (MockRmiInvocationHandler)stub); } catch (Exception ex) { throw ex; } } else { // traditional RMI stub try { Method method = mi.getMethod(); if (method.getDeclaringClass().isInstance(stub)) { // directly implemented return method.invoke(stub, mi.getArguments()); } else { // not directly implemented Method stubMethod = stub.getClass().getMethod(method.getName(), method.getParameterTypes()); return stubMethod.invoke(stub, mi.getArguments()); } } catch (Exception ex) { throw ex; } } } protected Object doInvoke(MethodInvocation mi, MockRmiInvocationHandler mrih) throws Throwable { return mrih.invoke(createRemoteInvocation(mi)); } protected MockRemoteInvocation createRemoteInvocation(MethodInvocation mi) throws Throwable { return new MockRemoteInvocation(mi); } public void afterPropertiesSet() { serviceProxy = ProxyFactory.getProxy(getServiceInterface(), this); } public String getServiceUrl() { return serviceUrl; } public void setServiceUrl(String serviceUrl) { this.serviceUrl = serviceUrl; } public Class<?> getServiceInterface() { return serviceInterface; } public void setServiceInterface(Class<?> serviceInterface) { this.serviceInterface = serviceInterface; } }