最近在研究Java RMI框架的遠端方法呼叫。利用spring對RMI的支援可以非常方便的構建你的分散式應用。
對於spring+RMI的介紹網上有很多，在這裡自己動手寫了一個Spring+mybatis+RMI的簡單應用。實現遠端方法呼叫資料庫。

首先建立一個數據庫，資料庫中只有一張表，非常的簡單。

服務端的搭建 ##

搭建好資料庫後就開始編寫程式碼了。首先建立一個Java專案或者Java web專案作為伺服器端。這是伺服器專案的結構：

引入專案需要用到的jar包：

對於建立Spring框架和spring整合mybatis比較簡單，在這裡不做過多的敘述，直接上程式碼。

User.java

package org.springmybatis.model;

import java.io.Serializable;

public class User implements Serializable{
    private int id;
    private String username;
    private String password;
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public
 
 String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getPassword() {
        return password;
    }
    public void setPassword(String password) {
        this.password = password;
    }
    public
 
 User() {
        super();
    }
    public String toString(){
        return "User[id="+id+" , username="+username+" , password="+password+"]";
    }
}

在這裡需要注意的是此處的entity類實現了Serializable介面，這是因為在RMI分散式應用系統中，伺服器與客戶機之間傳遞的Java物件必須是可序列化的物件。不可序列化的物件不能在物件流中進行傳遞。也就是說如果想要從遠端操作mybatis那麼此處的entity必須序列化。

UserDao.java

package org.springmybatis.dao;

import org.springmybatis.model.User;

public interface UserDao {
    public User getUser(User user);
    public void addUser(User user);
    public void updateUser(User user);
    public void deleteUser(int UserId);
}

UserDao.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"   
     "http://mybatis.org/dtd/mybatis-3-mapper.dtd">  
<mapper namespace="org.springmybatis.dao.UserDao">  
<select id="getUser" parameterType="org.springmybatis.model.User" resultType="org.springmybatis.model.User">  
     SELECT * FROM user WHERE username=#{username} AND password=#{password}  
</select>  
<insert id="addUser" parameterType="org.springmybatis.model.User" flushCache="true">  
    INSERT INTO user (id,username,password) VALUES (#{id},#{username},#{password})  
</insert>  
<update id="updateUser" parameterType="org.springmybatis.model.User">  
    UPDATE user SET password=#{password} WHERE id=#{id}  
</update>  
<delete id="deleteUser" parameterType="int">  
    DELETE FROM user WHERE id=#{id}  
</delete>  
</mapper> 

這裡的UserDao.xml就是mapper對映檔案

mybatis配置檔案也很簡單：
mybatis-config.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE configuration PUBLIC  
     "-//mybatis.org//DTD Config 3.0//EN"  
     "http://mybatis.org/dtd/mybatis-3-config.dtd">  
 <configuration>  
     <mappers>  
         <mapper resource="org/springmybatis/dao/UserDao.xml"/>  
     </mappers>  
 </configuration> 

這是最基礎的spring配置檔案，後續需要在此整合RMI框架：
ApplicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans 
    xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    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/aop 
    http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
    http://www.springframework.org/schema/tx
    http://www.springframework.org/schema/tx/spring-tx-3.0.xsd
    http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context-3.0.xsd">

<bean id="jdbcDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">  
    <property name="driverClassName">  
         <value>org.gjt.mm.mysql.Driver</value>  
    </property>  
    <property name="url">  
        <value>jdbc:mysql://localhost:3306/springmybatisrmi?useUnicode=true&amp;characterEncoding=UTF-8</value>  
    <!--springmybaitis是我的資料庫  -->
    </property>  
    <property name="username">  
        <value>root</value>  
    </property>  
    <property name="password">  
        <value>admin</value>  
    </property>  
</bean>

<bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/>

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">  
     <property name="dataSource" ref="jdbcDataSource" />  
     <property name="configLocation" value="classpath:mybatis-config.xml"></property>  
</bean>

<bean id="userDao" class="org.mybatis.spring.mapper.MapperFactoryBean">  
     <property name="mapperInterface" value="org.springmybatis.dao.UserDao"></property>  
     <property name="sqlSessionFactory" ref="sqlSessionFactory"></property>  
</bean>
</beans>  

至此整個spring+mybatis框架就搭建好了，然後我們編寫一個測試類，用來檢測框架是否搭建成功。

UserController.java

package org.springmybatis.test;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springmybatis.dao.UserDao;
import org.springmybatis.model.User;

public class UserController {
    public static void main(String[] args) {
         ApplicationContext ctx=null;
         ctx=new ClassPathXmlApplicationContext("applicationContext.xml");
         UserDao userDao=(UserDao) ctx.getBean("userDao");
         User user=new User();
         //新增兩條資料
         user.setId(1);
         user.setUsername("ltx");
         user.setPassword("123");
         userDao.addUser(user);
         user.setId(2);
         user.setUsername("ltxltx");
         user.setPassword("123");
         userDao.addUser(user);
         System.out.println("新增成功");
         //查詢資料
         user.setUsername("ltxltx");
         user.setPassword("123");
         System.out.println(userDao.getUser(user).toString());
         user.setUsername("ltx");
         user.setPassword("123");
         System.out.println(userDao.getUser(user).toString());
         //修改資料
         user.setId(2);
         user.setPassword("95");
         userDao.updateUser(user);
         System.out.println("修改成功");
        //刪除資料
         userDao.deleteUser(1);
         userDao.deleteUser(2);
         System.out.println("刪除成功");       
    }
}

執行一下程式，如果控制檯輸出了

表明執行成功。

接下來就要往服務端新增RMI框架了。
首先我們需要做的是將服務端的介面包裝，並建立此介面的實現類。這一步的目的是隱藏服務端的mybatis，提供新的介面給客戶端呼叫，讓客戶端就像在本地使用spring+mybatis訪問資料庫一樣。

RUserDao.java

package org.springmybatis.dao;

import org.springmybatis.model.User;

public interface RUserDao {
    public User getUser(User user);
    public void addUser(User user);
    public void updateUser(User user);
    public void deleteUser(int userId);
}

RUserDaoImpl.java

package org.springmybatis.dao;

import org.springframework.beans.factory.annotation.Autowired;
import org.springmybatis.model.User;

public class RUserDaoImpl implements RUserDao {
    @Autowired
    private UserDao userDao;

    @Override
    public User getUser(User user) {
        // TODO Auto-generated method stub
        return userDao.getUser(user);
    }
    @Override
    public void addUser(User user) {
        // TODO Auto-generated method stub
         this.userDao.addUser(user);
    }

    @Override
    public void updateUser(User user) {
        // TODO Auto-generated method stub
         this.userDao.updateUser(user);
    }
    @Override
    public void deleteUser(int userId) {
        // TODO Auto-generated method stub
        this.userDao.deleteUser(userId);
    }
}

在這裡需要注意的是，我使用了@Autowried註解來實現spring中Bean的建立和自動裝配。我們需要在spring配置檔案中新增一行程式碼：

<bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/>

接下來我們需要在spring配置檔案中新增RMI支援，在ApplicationContext.xml檔案中新增以下內容：

<bean id="RuserDaoImpl" class="org.springmybatis.dao.RUserDaoImpl" scope="prototype" />
<bean class="org.springframework.remoting.rmi.RmiServiceExporter">
    <!-- 將遠端介面實現類物件設定到RMI服務中 -->
    <property name="service" ref="RuserDaoImpl" />
    <!-- 設定RMI服務名，為RMI客戶端依據此服務名獲取遠端介面實現類物件引用奠定基礎 -->
    <property name="serviceName" value="ruserdao" />
    <!-- 將遠端介面設定為RMI服務介面 -->
    <property name="serviceInterface" value="org.springmybatis.dao.RUserDao" />
    <!-- 為RMI服務端遠端物件登錄檔設定埠號-->
    <property name="registryPort" value="9090" />
</bean>

至此就完成了RMI服務端的搭建。

客戶端的搭建 ##

首先在搭建客戶端之前，先說一說我遇到的一個問題。當我搭建完成客戶端之後，執行程式碼發現報了這麼一個異常no security manager: RMI class loader disabled

在網上搜了一下之後發現這個異常的原因是客戶端的包路徑與服務端的包路徑不一致，改成一致就ok了。

首先建立一個Java或者Javaweb專案，同時引用服務端的專案。或者你也可以選擇將服務端的User.java和RUserDao.java拷貝到客戶端來。當然了，你要注意客戶端的包路徑必須與服務端的包路徑一致。

下面是我客戶端的專案結構：

首先是客戶端的spring配置檔案：

applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans 
    xmlns="http://www.springframework.org/schema/beans" 
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
    http://www.springframework.org/schema/beans/spring-beans-2.5.xsd
    http://www.springframework.org/schema/context 
    http://www.springframework.org/schema/context/spring-context-2.5.xsd">

    <!--RMI客戶端-->
    <bean id="dataExchangeProxyService" class="org.springframework.remoting.rmi.RmiProxyFactoryBean"> 
        <property name="serviceUrl" value="rmi://localhost:9090/ruserdao"/>
        <property name="serviceInterface" value="org.springmybatis.dao.RUserDao"/>
        <!-- 當連線失敗時是否重新整理遠端呼叫stub -->
        <property name="refreshStubOnConnectFailure" value="true"/>
    </bean>
</beans>

啟動檔案RMIClient.java:

package org.springmybatis.test;


import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springmybatis.dao.RUserDao;
import org.springmybatis.model.User;

public class RMIClient {

    public static void main(String[] args){

        ApplicationContext ctx = new ClassPathXmlApplicationContext("conf/spring/applicationContext.xml");
        RUserDao userdao =  (RUserDao) ctx.getBean("dataExchangeProxyService");
         User user=new User();
         //新增兩條資料
         user.setId(1);
         user.setUsername("ltx");
         user.setPassword("123");
         //userdao.addUser(user);
         user.setId(3);
         user.setUsername("ltxltx");
         user.setPassword("123");
         userdao.addUser(user);
         System.out.println("新增成功");
         userdao.deleteUser(1);
         //userdao.deleteUser(2);
    }
}

至此整個專案就完成了。
在這裡我們呼叫服務端暴露出來的介面RUserDao來訪問服務端的資料庫，實現了RMI的遠端呼叫。