Spring3 rmi 兑现

         java rmi 实现起来非常麻烦，每个接口都要继承Remote  接口，实现这个接口的类还要继承 UnicastRemoteObject类，总之非常麻烦，关于java rmi的文章      http://damies.iteye.com/blog/51778。

       Spring提供类用于集成各种远程访问技术。这种对远程访问的支持可以降低你在用POJO实现支持远程访问业务时的开发难度目前，Spring提供对下面四种远程访问技术的支持：

      远程方法调用（RMI）。通过使用RmiProxyFactoryBean和RmiServiceExporter，Spring支持传统的RMI（使用java.rmi.Remote interfaces 和 java.rmi.RemoteException）和通过RMI调用器（可以使用任何Java接口）的透明远程调用。

     Spring的HTTP调用器。Spring提供一种特殊的远程调用策略支持任何Java接口（象RMI调用器一样），它允许Java序列化能够通过HTTP传送。对应的支持类是HttpInvokerProxyFactoryBean和HttpInvokerServiceExporter。

    Hessian。通过使用HessianProxyFactoryBean和HessianServiceExporter，你可以使用Caucho提供的轻量级基于HTTP的二进制协议透明地提供你的业务。

    Burlap。Burlap是基于XML的，它可以完全代替Hessian。Spring提供的支持类有BurlapProxyFactoryBean和BurlapServiceExporter。

    JAX RPC (TODO). 

    这里主要讨论RMI的实现。

       利用Spring来实现RMI,不用实现remote接口,也不用调用rmic编译stub和skeleton, 服务端可以定义org.springframework.remoting.rmi.RmiServiceExporter类完成RMI服务器实现. 客户端只要定义org.springframework.remoting.rmi.RmiProxyFactoryBean,告知rmi的url和接口。

     这里需要Spring相关jar包，自行下载。

   首先看服务端：

接口：IUserService.java

package com.rmi.test; import java.util.List; public interface IUserService { public String getName(); public String save(User user); public List<User> findAll(); }
实现类：UserService.java

package com.rmi.test; import java.util.ArrayList; import java.util.List; import org.springframework.stereotype.Service; @Service("user") public class UserService implements IUserService { public String getName() { return "ajun"; } @Override public String save(User user) { if(user!=null){ System.out.println("----------------进入save-------------------"); System.out.println("------年龄----------"+user.getAge()+"-------------------"); System.out.println("-------性别---------"+user.getSex()+"-------------------"); System.out.println("--------身高--------"+user.getShengao()+"-------------------"); System.out.println("---------体重-------"+user.getTizhong()+"-------------------"); System.out.println("---------名字-------"+user.getUsername()+"-------------------"); } return null; } @Override public List<User> findAll() { List<User> list = new ArrayList<User>(); for(int i=1;i<3000;i++){ User u = new User(); u.setAge("20"+i); u.setSex("男"+i); u.setShengao(170+i); u.setTizhong(64+i); u.setUsername("军爷"+i); list.add(u); } return list; } }
PO类：User.java

package com.rmi.test; public class User implements java.io.Serializable{ private String username; private String age; private String sex; private double shengao; private double tizhong; public String getUsername() { return username; } public void setUsername(String username) { this.username = username; } public String getAge() { return age; } public void setAge(String age) { this.age = age; } public String getSex() { return sex; } public void setSex(String sex) { this.sex = sex; } public double getShengao() { return shengao; } public void setShengao(double shengao) { this.shengao = shengao; } public double getTizhong() { return tizhong; } public void setTizhong(double tizhong) { this.tizhong = tizhong; } }
服务端spring的配置:

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd"> <context:component-scan base-package="com.rmi.test"/> <bean id="registry" class="org.springframework.remoting.rmi.RmiRegistryFactoryBean"> <property name="port" value="1099"/> </bean> <bean id = "rmiService" class = "org.springframework.remoting.rmi.RmiServiceExporter" > <property name = "serviceName" value = "get_user" /> <property name = "service" ref = "user" /> <property name = "serviceInterface" value = "com.rmi.test.IUserService" /> <!-- <property name="registryPort" value="1099"/> --> <property name="registry" ref="registry"/> <!-- <property name="registryHost" value="192.168.39.11" /> --> </bean> </beans>
服务端启动代码：TestServer.java

package com.rmi.test; import org.springframework.beans.factory.BeanFactory; import org.springframework.context.support.ClassPathXmlApplicationContext; public class TestServer { /** * @param args */ public static void main(String[] args) { BeanFactory f = new ClassPathXmlApplicationContext("applicationContext-server.xml"); f.getBean("rmiService"); } }
运行出现：

INFO: 2012-06-21 09:04:07 org.springframework.context.support.AbstractApplicationContext.prepareRefresh(456) Refreshing org.springframework.context.support.ClassPathXmlApplicationContext@1592174: startup date [Thu Jun 21 09:04:07 CST 2012]; root of context hierarchy INFO: 2012-06-21 09:04:07 org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(315) Loading XML bean definitions from class path resource [applicationContext-server.xml] INFO: 2012-06-21 09:04:08 org.springframework.beans.factory.support.DefaultListableBeanFactory.preInstantiateSingletons(555) Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@11bed71: defining beans [user,org.springframework.context.annotation.internalConfigurationAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.context.annotation.internalPersistenceAnnotationProcessor,registry,rmiService]; root of factory hierarchy INFO: 2012-06-21 09:04:08 org.springframework.remoting.rmi.RmiRegistryFactoryBean.getRegistry(253) Looking for RMI registry at port '1099' INFO: 2012-06-21 09:04:10 org.springframework.remoting.rmi.RmiRegistryFactoryBean.getRegistry(264) Could not detect RMI registry - creating new one INFO: 2012-06-21 09:04:10 org.springframework.remoting.rmi.RmiServiceExporter.prepare(276) Binding service 'get_user' to RMI registry: RegistryImpl[UnicastServerRef [liveRef: [endpoint:[192.168.1.165:1099](local),objID:[0:0:0, 0]]]]
说明服务端运行成功。

客户端：

你可以将服务端class打成jar包，放到客户端的classpath下，一遍客户端可以引用到服务端的接口，spring来生成相关的代理类。

这里我生成的为rmiserver.ar,用myeclipse自动打包的。

java类：DisplayUser.java

package com.rmi.client.test; import java.util.List; import com.rmi.test.IUserService; import com.rmi.test.User; public class DisplayUser { private IUserService uerClient; public void displayUser(){ User u = new User(); u.setAge("20"); u.setSex("男"); u.setShengao(176.00); u.setTizhong(64); u.setUsername("军爷"); uerClient.save(u); List<User> list = uerClient.findAll(); System.out.println("userSize:"+list.size()); } public IUserService getUerClient() { return uerClient; } public void setUerClient(IUserService uerClient) { this.uerClient = uerClient; } }
spring 配置文件：client.xml

要透过org.springframework.remoting.rmi.RmiProxyFactoryBean，并告知服务的URL、代理的接口即可，就好像在使用本地端管理的服务一样：

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:context="http://www.springframework.org/schema/context" xmlns:p="http://www.springframework.org/schema/p" xmlns:mvc="http://www.springframework.org/schema/mvc" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd"> <bean id="serviceClient" class="org.springframework.remoting.rmi.RmiProxyFactoryBean"> <property name="serviceUrl" value="rmi://192.168.1.165:1099/get_user" /> <property name="serviceInterface" value="com.rmi.test.IUserService" /> <property name="lookupStubOnStartup" value="false"/> <property name="refreshStubOnConnectFailure" value="true"/> <property name="cacheStub" value="false"/> </bean> <bean id="test" class="com.rmi.client.test.DisplayUser"> <property name="uerClient" ref="serviceClient" /> </bean> </beans>
测试rmi客户端类：TestClient.java

package com.rmi.client.test; import org.springframework.beans.factory.BeanFactory; import org.springframework.context.support.ClassPathXmlApplicationContext; public class TestClient { /** * @param args */ public static void main(String[] args) { BeanFactory f = new ClassPathXmlApplicationContext("client.xml"); DisplayUser du = (DisplayUser)f.getBean("test"); du.displayUser(); } }
运行：

在远程服务端console会出现：

----------------进入save-------------------
------年龄----------20-------------------
-------性别---------男-------------------
--------身高--------176.0-------------------
---------体重-------64.0-------------------
---------名字-------军爷-------------------
说明调用成功!!!

最后rmi还会有一些注意的问题及：http://yangwencan2002.iteye.com/blog/284249