在上一章中，我們建立了一個RMI圖形化使用者介面應用程式的範例，用戶端呼叫伺服器端顯示GUI視窗(JavaFX)的方法。
在本章中，我們將以一個例子來看看用戶端程式如何檢索位於伺服器上的MySQL資料庫中的表的記錄。
假設在資料庫：testdb中有一個名稱為student的表，其表結構和資料如下所示 -
+----+--------+--------+------------+---------------------+
| ID | NAME | BRANCH | PERCENTAGE | EMAIL |
+----+--------+--------+------------+---------------------+
| 1 | Maxsu | IT | 85 | [email protected] |
| 2 | Curry | EEE | 95 | [email protected] |
| 3 | Alex | ECE | 90 | [email protected] |
+----+--------+--------+------------+---------------------+
建立資料庫和表如下語句 -
CREATE DATABASE IF NOT EXISTS testdb DEFAULT CHARSET utf8 COLLATE utf8_general_ci;
use testdb;
-- ----------------------------
-- Table structure for `student`
-- ----------------------------
DROP TABLE IF EXISTS `student`;
CREATE TABLE `student` (
`id` int(10) NOT NULL AUTO_INCREMENT,
`name` varchar(32) NOT NULL DEFAULT '',
`branch` varchar(16) NOT NULL DEFAULT '',
`percentage` float unsigned DEFAULT '0',
`email` varchar(48) NOT NULL DEFAULT '',
PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
-- ----------------------------
-- Records of student
-- ----------------------------
INSERT INTO `student` VALUES ('1', 'Maxsu', 'IT', '85', '[email protected]');
INSERT INTO `student` VALUES ('2', 'Curry', 'EEE', '96', '[email protected]');
INSERT INTO `student` VALUES ('3', 'Alex', 'ECE', '92', '[email protected]');
假設所使用的MySQL伺服器的使用者名是:root，其密碼是:123456。
建立一個Student類,並建立setter和getter方法，建立一個Java原始碼檔案：Student.java，如下所示。
public class Student implements java.io.Serializable {
private int id, percent;
private String name, branch, email;
public int getId() {
return id;
}
public String getName() {
return name;
}
public String getBranch() {
return branch;
}
public int getPercent() {
return percent;
}
public String getEmail() {
return email;
}
public void setID(int id) {
this.id = id;
}
public void setName(String name) {
this.name = name;
}
public void setBranch(String branch) {
this.branch = branch;
}
public void setPercent(int percent) {
this.percent = percent;
}
public void setEmail(String email) {
this.email = email;
}
}
在這裡，我們定義一個名為Hello的遠端介面，Hello介面中有一個getStudents()方法。此方法返回一個包含Student類物件的列表。
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.*;
// Creating Remote interface for our application
public interface Hello extends Remote {
public List<Student> getStudents() throws Exception;
}
建立一個類並實現上面建立的Hello遠端介面。
這裡我們實現遠端介面的getStudents()方法。當呼叫此方法時，它將檢索資料庫：students表中的記錄。使用Student類的setter方法設定物件的值並返回該物件列表。建立一個JAVA原始檔：ImplExample.java 如下所示 -
import java.sql.*;
import java.util.*;
// Implementing the remote interface
public class ImplExample implements Hello {
// Implementing the interface method
public List<Student> getStudents() throws Exception {
List<Student> list = new ArrayList<Student>();
// JDBC driver name and database URL
String JDBC_DRIVER = "com.mysql.jdbc.Driver";
String DB_URL = "jdbc:mysql://localhost:3306/testdb";
// Database credentials
String USER = "root";
String PASS = "123456";
Connection conn = null;
Statement stmt = null;
//Register JDBC driver
Class.forName("com.mysql.jdbc.Driver");
//Open a connection
System.out.println("Connecting to a selected database...");
conn = DriverManager.getConnection(DB_URL, USER, PASS);
System.out.println("Connected database successfully...");
//Execute a query
System.out.println("Creating statement...");
stmt = conn.createStatement();
String sql = "SELECT * FROM student_data";
ResultSet rs = stmt.executeQuery(sql);
//Extract data from result set
while(rs.next()) {
// Retrieve by column name
int id = rs.getInt("id");
String name = rs.getString("name");
String branch = rs.getString("branch");
int percent = rs.getInt("percentage");
String email = rs.getString("email");
// Setting the values
Student student = new Student();
student.setID(id);
student.setName(name);
student.setBranch(branch);
student.setPercent(percent);
student.setEmail(email);
list.add(student);
}
rs.close();
return list;
}
}
RMI伺服器程式應實現遠端介面或擴充套件實現類。 在這裡，我們將建立一個遠端物件並將其系結到RMI登錄檔。
以下是本應用程式的伺服器程式。 在這裡，我們將擴充套件上述建立的類，建立一個遠端物件並使用系結名稱為：hello ，將其註冊到RMI登錄檔。建立一個JAVA原始檔：Server.java 如下所示 -
import java.rmi.registry.Registry;
import java.rmi.registry.LocateRegistry;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
public class Server extends ImplExample {
public Server() {}
public static void main(String args[]) {
try {
// Instantiating the implementation class
ImplExample obj = new ImplExample();
// Exporting the object of implementation class (
// here we are exporting the remote object to the stub)
Hello stub = (Hello) UnicastRemoteObject.exportObject(obj, 0);
// Binding the remote object (stub) in the registry
Registry registry = LocateRegistry.getRegistry();
registry.bind("Hello", stub);
System.err.println("Server ready");
} catch (Exception e) {
System.err.println("Server exception: " + e.toString());
e.printStackTrace();
}
}
}
以下是本應用程式的用戶端程式。 在這裡，我們獲取遠端物件並呼叫getStudents()方法。它從列表物件中檢索表 - student的行記錄並顯示它們。建立一個JAVA原始檔：Client.java 如下所示 -
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.*;
public class Client {
private Client() {}
public static void main(String[] args)throws Exception {
try {
// Getting the registry
Registry registry = LocateRegistry.getRegistry(null);
// Looking up the registry for the remote object
Hello stub = (Hello) registry.lookup("Hello");
// Calling the remote method using the obtained object
List<Student> list = (List)stub.getStudents();
for (Student s:list)v {
// System.out.println("bc "+s.getBranch());
System.out.println("ID: " + s.getId());
System.out.println("name: " + s.getName());
System.out.println("branch: " + s.getBranch());
System.out.println("percent: " + s.getPercent());
System.out.println("email: " + s.getEmail());
}
// System.out.println(list);
} catch (Exception e) {
System.err.println("Client exception: " + e.toString());
e.printStackTrace();
}
}
}
以下是執行RMI範例的步驟。
注意：如果手動編譯，需要把上面程式碼存放到目錄：F:\worksp\java_rmi\java-dbapp中，並建立一個目錄：F:\worksp\java_rmi\java-dbapp\libs，把下載的
mysql-connector-java-5.1.40-bin.jar庫(下載地址：http://downloads.mysql.com/archives/c-j/ )放入到 F:\worksp\java_rmi\java-dbapp\libs 目錄中。
第一步 - 開啟儲存所有程式的檔案夾，並編譯所有Java檔案，如下所示。
F:\worksp\java_rmi\java-dbapp> javac -Djava.ext.dirs=F:\worksp\java_rmi\java-dbapp\libs *.java
第二步 - 使用以下命令啟動rmi登錄檔。
F:\worksp\java_rmi\java-dbapp> start rmiregistry
執行上面命令後，將在單獨的視窗中啟動一個rmi登錄檔。
第三步 - 執行伺服器類程式碼，如下所示。
F:\worksp\java_rmi\java-dbapp>java -Djava.ext.dirs=F:\worksp\java_rmi\java-dbapp\libs Server
Server ready
第三步 - 執行用戶端類檔案，如下所示。
F:\worksp\java_rmi\java-dbapp>java -Djava.ext.dirs=F:\worksp\java_rmi\java-dbapp\libs Client
執行上面命令後，輸出結果如下 -
F:\worksp\java_rmi\java-dbapp>java -Djava.ext.dirs=F:\worksp\java_rmi\java-dbapp\libs Client
ID: 1
name: Maxsu
branch: IT
percent: 85
email: [email protected]
ID: 2
name: Curry
branch: EEE
percent: 96
email: [email protected]
ID: 3
name: Alex
branch: ECE
percent: 92
email: [email protected]
F:\worksp\java_rmi\java-dbapp>