Java RMI - แอปพลิเคชันฐานข้อมูล
ในบทก่อนหน้านี้เราได้สร้างแอปพลิเคชัน RMI ตัวอย่างที่ไคลเอนต์เรียกใช้เมธอดที่แสดงหน้าต่าง GUI (JavaFX)
ในบทนี้เราจะนำตัวอย่างเพื่อดูว่าโปรแกรมไคลเอนต์สามารถดึงข้อมูลของตารางในฐานข้อมูล MySQL ที่อยู่บนเซิร์ฟเวอร์ได้อย่างไร
สมมติว่าเรามีตารางชื่อ student_data ในฐานข้อมูล details ดังแสดงด้านล่าง
+----+--------+--------+------------+---------------------+
| ID | NAME | BRANCH | PERCENTAGE | EMAIL |
+----+--------+--------+------------+---------------------+
| 1 | Ram | IT | 85 | [email protected] |
| 2 | Rahim | EEE | 95 | [email protected] |
| 3 | Robert | ECE | 90 | [email protected] |
+----+--------+--------+------------+---------------------+
สมมติว่าชื่อของผู้ใช้คือ myuser และรหัสผ่านคือ password.
การสร้างชั้นเรียนของนักเรียน
สร้างไฟล์ Student คลาสด้วย setter และ getter วิธีการดังที่แสดงด้านล่าง
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 ด้วยเมธอดชื่อ 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;
}
การพัฒนาระดับการใช้งาน
สร้างคลาสและใช้สิ่งที่สร้างไว้ข้างต้น interface.
ที่นี่เรากำลังใช้งานไฟล์ getStudents() วิธีการของ Remote interface. เมื่อคุณเรียกใช้เมธอดนี้ระบบจะดึงข้อมูลของตารางที่มีชื่อว่าstudent_data. ตั้งค่าเหล่านี้เป็นคลาส Student โดยใช้เมธอด setter เพิ่มลงใน list object และส่งกลับรายการนั้น
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/details";
// Database credentials
String USER = "myuser";
String PASS = "password";
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 registry.
ต่อไปนี้เป็นโปรแกรมเซิร์ฟเวอร์ของแอปพลิเคชันนี้ ที่นี่เราจะขยายคลาสที่สร้างขึ้นข้างต้นสร้างวัตถุระยะไกลและลงทะเบียนไปยังรีจิสทรี RMI ด้วยชื่อการผูกhello.
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(). จะดึงข้อมูลของตารางจากวัตถุรายการและแสดง
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 ของเรา
Step 1 - เปิดโฟลเดอร์ที่คุณเก็บโปรแกรมทั้งหมดและรวบรวมไฟล์ Java ทั้งหมดดังที่แสดงด้านล่าง
Javac *.java
Step 2 - เริ่มไฟล์ rmi รีจิสทรีโดยใช้คำสั่งต่อไปนี้
start rmiregistry
สิ่งนี้จะเริ่มต้น rmi รีจิสทรีในหน้าต่างแยกต่างหากดังที่แสดงด้านล่าง
Step 3 - เรียกใช้ไฟล์คลาสเซิร์ฟเวอร์ดังที่แสดงด้านล่าง
Java Server
Step 4 - เรียกใช้ไฟล์คลาสไคลเอนต์ตามที่แสดงด้านล่าง
java Client