Java RMI資料庫應用程式


在上一章中,我們建立了一個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 類

建立一個Student類,並建立settergetter方法,建立一個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>