Các bước tạo ứng dụng với RMI

Ở đây chúng ta có 1 ví dụ tạo ứng dụng máy chủ tính toán các phép tính cơ bản(+, -, *, /)

Ở phía server:

Tạo thư mục MyCalcServer, lưu các lớp sau vào đó

1> Tạo interface

import java.rmi.Remote;
import java.rmi.RemoteException;

public interface CalculatorInterface extends Remote {
long Add(long a,long b)throws RemoteException;
long Sub(long a,long b)throws RemoteException;
long Mul(long a,long b)throws RemoteException;
float Div(float a,float b)throws RemoteException;
}

2>Tạo lớp implements cài đặt các dịch vụ ở phía máy chủ:

import java.rmi.*;
import java.rmi.server.*;

public class CalculatorImpl extends UnicastRemoteObject implements CalculatorInterface {
private ServerUI ui;
public CalculatorImpl() throws RemoteException
{
}
public CalculatorImpl(ServerUI ui) throws RemoteException
{
this.ui=ui;
}
public long Add(long a, long b) throws RemoteException {
ui.addItem(“Call from client: “+a+”+”+b+”=”+(a+b));
return a+b;
}

public long Sub(long a, long b) throws RemoteException {
ui.addItem(“Call from client: “+a+”-”+b+”=”+(a-b));
return a-b;
}

public long Mul(long a, long b) throws RemoteException {
ui.addItem(“Call from client: “+a+”*”+b+”=”+(a*b));
return a*b;
}

public float Div(float a, float b) throws RemoteException {
if(Math.abs(b-0)<0.000001)
{
ui.addItem(“Call from client: Divide by zero”);
throw new ArithmeticException();
}
ui.addItem(“Call from client: “+a+”/”+b+”=”+(a/b));
return a/b;
}
}

3>Cài đặt server. Ở đây tôi thiết kế server dùng GUI

import java.awt.*;
import java.awt.event.*;
import javax.swing.*;
import java.rmi.*;
import javax.naming.Context;
import javax.naming.InitialContext;

public class ServerUI extends JFrame implements ActionListener{
private DefaultListModel dlm;
private JList lst;
private JLabel lblMessage;
private JButton btnStart,btnStop,btnExit;
private Context ctx=null;
public ServerUI(){
super(“Server RMI”);
lst=new JList(dlm=new DefaultListModel());
this.add(new JScrollPane(lst),BorderLayout.CENTER);
setDefaultCloseOperation(EXIT_ON_CLOSE);
setSize(300,300);

JPanel pB=new JPanel(new GridLayout(2,1));
JPanel pF=new JPanel();
pB.add(pF);
pF.add(btnStart=new JButton(“Start”));
pF.add(btnStop=new JButton(“Stop”));btnStop.setEnabled(false);
pF.add(btnExit=new JButton(“Exit”));
pB.add(lblMessage=new JLabel());

btnStart.addActionListener(this);
btnStop.addActionListener(this);
btnExit.addActionListener(this);

this.add(pB,BorderLayout.SOUTH);
}

public void DislplayInfos(String msg){
lblMessage.setText(msg);
}

public void addItem(String item){
dlm.addElement(item);
}
public static void main(String[]args){
try{
ServerUI ui=new ServerUI();
java.rmi.registry.LocateRegistry.createRegistry(1099);
ui.DislplayInfos(“server is stop…”);
ui.setVisible(true);
}catch(Exception x){
x.printStackTrace();
}
}

public void actionPerformed(ActionEvent e){
Object o=e.getSource();
if(o.equals(btnStart)){
new Thread(new Runnable(){
public void run(){
try {

CalculatorInterface calc=null;
calc=new CalculatorImpl(ServerUI.this);
ctx =new InitialContext();
ctx.rebind(“rmi:calc”, calc);
lblMessage.setText(“Calculator server is running…”);
}
catch (Exception ex) {
ex.printStackTrace();
}
}
}).start();

btnStop.setEnabled(true);
btnStart.setEnabled(false);
}
else if(o.equals(btnStop)){
try {
ctx.unbind(“rmi:calc”);
ctx=null;
btnStop.setEnabled(false);
btnStart.setEnabled(true);
lblMessage.setText(“Calculator server is stopped…”);
}
catch (Exception ex) {
ex.printStackTrace();
}
}
else if(o.equals(btnExit)){
System.exit(1);
}
}
}

4>Biên dịch:

Trong command promt, gõ dòng lệnh sau để biên dịch (thư mục hiện hành là MyCalcServer)

javac *.java

5> Thực thi:

Tạo file MyCalSVR.bat với nội dung sau

java ServerUI

//=========================================================

//=========================================================

//=========================================================

Ở phía client

Tạo thư mục MyCalcClient. Các lớp sau được lưu trong đó

1> Copy tâp tin CalculatorInterface.class vào thư mục này.

2>Tạo client như sau, ở đây chúng ta dùng GUI để thiết kế

import java.awt.event.*;
import java.awt.*;
import javax.swing.*;
import java.rmi.*;

public class ClientUI extends JFrame implements ActionListener
{
private JTextField txtA,txtB,txtKQ;
private JButton btnClear,btnExit;
private JButton btnCalcAdd,btnCalcSub,btnCalcMul,btnCalcDev;
public ClientUI(){
JPanel pCen=new JPanel(new GridLayout(4,1));
JPanel p1=new JPanel();JPanel p2=new JPanel();
JPanel p3=new JPanel();JPanel p4=new JPanel();
pCen.add(p1);pCen.add(p2);pCen.add(p3);pCen.add(p4);
getContentPane().add(pCen);
//==========================================
p1.add(new JLabel(“Nhap so a”));p1.add(txtA=new JTextField(15));
p2.add(new JLabel(“Nhap so b”));p2.add(txtB=new JTextField(15));
p3.add(new JLabel(“Ket qua :”));p3.add(txtKQ=new JTextField(15));
txtKQ.setEditable(false);
p4.add(btnCalcAdd=new JButton(” + “));btnCalcAdd.addActionListener(this);
p4.add(btnCalcSub=new JButton(” – “));btnCalcSub.addActionListener(this);
p4.add(btnCalcMul=new JButton(” * “));btnCalcMul.addActionListener(this);
p4.add(btnCalcDev=new JButton(” / “));btnCalcDev.addActionListener(this);

p4.add(btnClear=new JButton(“Clear”));btnClear.addActionListener(this);
p4.add(btnExit=new JButton(“Exit”));btnExit.addActionListener(this);
setResizable(false);
setSize(350,200);
setDefaultCloseOperation(EXIT_ON_CLOSE);
setLocation(300,200);
}
public void actionPerformed(ActionEvent e) {
Object o=e.getSource();
if(o.equals(btnExit)){
System.exit(1);
}
else
{
if(txtA.getText().trim().equals(“”)||txtB.getText().trim().equals(“”)){
JOptionPane.showMessageDialog(null,”Text Fields cannot be null”,
“Error”,JOptionPane.ERROR_MESSAGE);
return;
}

if(o.equals(btnCalcAdd)){
try {
CalculatorInterface obj=null;
obj=(CalculatorInterface)Naming.lookup(“//localhost/calc”);
int a=Integer.parseInt(txtA.getText());
int b=Integer.parseInt(txtB.getText());
long x=obj.Add(a,b);
txtKQ.setText(“”+x);
}catch (Exception ex) {
ex.printStackTrace();
}
}
else if(o.equals(btnCalcSub)){
try {
CalculatorInterface obj=null;
obj=(CalculatorInterface)Naming.lookup(“//localhost/calc”);
int a=Integer.parseInt(txtA.getText());
int b=Integer.parseInt(txtB.getText());
long x=obj.Sub(a,b);
txtKQ.setText(“”+x);
}catch (Exception ex) {
ex.printStackTrace();
}
}
else if(o.equals(btnCalcMul)){
try {
CalculatorInterface obj=null;
obj=(CalculatorInterface)Naming.lookup(“//localhost/calc”);
int a=Integer.parseInt(txtA.getText());
int b=Integer.parseInt(txtB.getText());
long x=obj.Mul(a,b);
txtKQ.setText(“”+x);
}catch (Exception ex) {
ex.printStackTrace();
}
}
else if(o.equals(btnCalcDev)){
try {
CalculatorInterface obj=null;
obj=(CalculatorInterface)Naming.lookup(“//localhost/calc”);
int a=Integer.parseInt(txtA.getText());
int b=Integer.parseInt(txtB.getText());
double x=obj.Div(a,b);
txtKQ.setText(“”+x);
}catch (ArithmeticException aex) {
txtKQ.setText(“Divide by zero”);
}catch (Exception ex) {
ex.printStackTrace();
}
}
else if(o.equals(btnClear)){
txtA.setText(“”);
txtB.setText(“”);
txtKQ.setText(“”);
}
}
}
public static void main(String[]args){
System.setProperty(“java.security.policy”, “client.policy”);
ClientUI cc=new ClientUI();
cc.setVisible(true);
}
}

3> Tạo File Policy tên client.policy với nội dung sau

grant {
permission java.net.SocketPermission “*:1024-65535″, “connect”;
};

4> Biên dịch với command promt (thư mục hiện hành là MyCalcClient)

javac *.java

5> Tạo file thực thi có tên MyCalclient.bat với nội dung sau

java ClientUI

//=========================================================

//=========================================================

//=========================================================

Demo ứng dụng:

1> Chạy file MyCalSVR.bat để chạy server. Nhấn nút Start để start server

2> Chạy file MyCalclient.bat để chạy client.

3> Test chương trình

Chúc thành công!