与现有服务器的连接
人们常说，RMI主要是“从Java到Java”，但这种说法掩盖了这样一个事实：Java可使用被称为JNI的本机方法接口，很轻易地与现有和原有系统连接。JNI和RMI的混合使用与任何其它Java程序一样简单。您可使用JDBC，再结合RMI，与现有的关系数据库连接。也就是说，您可使用RMI连接二层次和三层次系统--即使双方都不是用Java 编写的亦可。这样做有很大的好处和优势，下面会具体阐述。但首先让我们看一看它是如何完成的。
假定您现在有一台在关系数据库中存储了有关客户订单信息的服务器。在任何多层次系统中，您都得设计一个远程接口，以便于客户机访问服务器--利用作为Remote 接口的RMI：
import java.rmi.*;
import java.sql.SQLException;
import java.util.Vector;
public interface OrderServer extends Remote {
Vector getUnpaid() throws RemoteException, SQLException;
void shutDown() throws RemoteException;
// ... other methods (getOrderNumber, getShipped, ...)
}
java.sql包包含JDBC包。每个远程方法均可被服务器采用实际数据库的JDBC调用，或通过采用其它数据库访问机制的本机方法实现。上面所示的方法返回一个Order (订单) 对象的Vector (列表)。Order (订单)就是在您的系统中定义的、用来保存客户订单的类。
本节将介绍如何使用JDBC实现getUnpaid，和如何使用JNI 实施shutDown。
JDBC -- 连接数据库
使用JDBC实现getUnpaid的OrderServerImpl如下：
import java.rmi.*;
import java.rmi.server.*;
import java.sql.*;
import java.util.Vector;
public class OrderServerImpl
extends UnicastRemoteObject
implements OrderServer
{
Connection db; // connection to the db
PreparedStatement unpaidQuery; // unpaid order query
OrderServerImpl() throws RemoteException, SQLException {
db = DriverManager.getConnection("jdbc:odbc:orders");
unpaidQuery = db.preparedStatement("…");
}
public Vector getUnpaid() throws SQLException {
ResultSet results = unpaidQuery.executeQuery();
Vector list = new Vector();
while (results.next())
list.addElement(new Order(results));
return list;
}
public native void shutDown();
}
其中大多是JDBC任务。除了以Order开始的类型是您的系统的一部分类型以外，您所看到的所有类型均为JDBC或 RMI的一部分。构造函数初始化OrderServerImpl对象，创建与jdbc URL中所规定的数据库的连接( Connection)。有了这个连接，我们就可以使用prepareStatement定义一个能找到所有未付款订单的查询。在此还可为其它方法定义其它查询。OrderServerImpl作为数据库在同一个系统上运行，而且还可能是在同一个进程中(下面将讨论shutDown)。
当getUnpaid方法在RMI服务器对象OrderServerImpl上被调用后，就会执行预先编译的查询，并返回包含所有匹配元素的JDBC ResultSet对象。随后，我们为结果集中的每个项目创建新的Order对象，并将其添加到Vector对象中( Java 的动态数组)。在结束读取结果后，我们将这个向量返回给客户机，后者可将结果显示给用户，或者其他相关的人。
JNI -- 本机方法
RMI服务器和客户机可利用本机方法与现有的和原有的系统连接。您可使用本机方法实现不能直接访问数据库的远程方法，或者通过采用现有代码更简单地实现。您可使用本机接口JNI编写C和C++程序，以实现?Java方法并 Java对象上调用该方法。用本机方法实现shutDown的程序如下：
JNIEXPORT void JNICALL
Java_OrderServerImpl_shutDown(JNIEnv *env, jobject this)
{
jclass cls;
jfieldID fid;
DataSet *ds;
cls = (*env)-GetObjectClass(env, this);
fid = (*env)-GetFieldID(env, cls, "dataSet", "J");
ds = (DataSet *) (*env)-GetObjectField(env, this, fid);
/* With a DataSet pointer we can use the original API */
DSshutDown(ds);
}
这是假定了现有服务器通过其API定义的DataSet类型得到了引用。
