Java RMI遠程調用

作者：wx_962464 2012-04-11 11:10:25

對于用用Java實現RMI的遠程調用，我們可以通過作者以下的五個部分來解決，不適合初學者。詳細了解請看下文。

這次是用java實現RMI 的遠程調用：

編寫的過程大致為：

首先我們的啟動Mysqlserver ，然后再里面建立一個數據庫，以便我們在數據庫中插入存放學生信息等。
先編寫一個接口DataServer，并且繼承Remote類，然后再接口里面寫上服務器端能實現的方法，然后再定義一個類DataServerImpl 繼承UnicastRemoteObject 在實現接口DataServer，并且一一實現它定義在借口里面得到方法，這里我們重新寫了一個類DBManager，用來實現與數據庫的連接，包括插入數據，根據學號、姓名等進行查詢等操作，其源代碼見附件。
下面就是需要使用rmic命令進行編譯DataServerImpl文件，并且產生兩個文件，產生這兩個文件后就可以編寫服務器端的代碼了，主要是在主函數中生成一個DataServerImpl對象，然后在綁定一個端口在程序中，在綁定一個url地址，來綁定服務的對象，這樣服務器端的程序就寫好了。
下面就是寫客戶端的代碼了。
首先是通過Naming.lookup(url),(url)就是服務器端指定的url地址這樣就可以得到一個DataServer的對象，然后得到這樣一個對象后就可以調用它的方法了。這樣也就實現了調用遠程服務器端的代碼了，所以說這樣RMI就比本上寫完了。

首先是編寫遠程的接口調用函數：

<span style="font-size:16px;">import java.rmi.Remote;  
import java.rmi.RemoteException;  
 
public interface DataServer extends Remote {  
    public void CreateTable() throws RemoteException;  
    public void insert(int id ,String name,double Score) throws RemoteException;  
    public double select(int id)throws RemoteException;  
    public double select (String name)throws RemoteException;  
}  
</span>

由于代碼中使用到了與數據庫的連接，所以寫了一個數據庫的管理類，代碼如下：

<span style="font-size:16px;">import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.ResultSet;  
import java.sql.SQLException;  
 
public class DBManager {  
    private static String user = "root";  
    private static String pass = "123456";  
    private static String className ="com.mysql.jdbc.Driver";  
    private static String url = "jdbc:mysql://localhost:3306/students";  
    private static Connection conn;  
    private static java.sql.Statement state;  
    public static void init()  
    {  
        try {  
            Class.forName(className);  
             conn = DriverManager.getConnection(url,user,pass);  
             state =conn.createStatement();  
               
               
        } catch (ClassNotFoundException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        } catch (SQLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
    }  
    public static  void CreateTable(){  
        String sql = "create table student (id int Primary key, name char (20),score double);";  
        try {  
            state.execute(sql);  
      
        } catch (SQLException e) {  
            e.printStackTrace();  
        }  
    }  
    public static void insert(int id,String name,double score)  
    {  
        String sql = "insert into student values("+id+",'"+name+"',"+score+");";  
        try {  
            state.execute(sql);  
              
        } catch (SQLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
    }  
    public static double select(int id)  
    {  
        String sql  = "select score from student where id = "+id+";";  
        double result= 0;  
        try {  
            ResultSet rs = state.executeQuery(sql);  
            while(rs.next())  
            {  
                 result = rs.getDouble("score");  
            }  
              
        } catch (SQLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
        return result;  
    }  
      
    public static double select(String name)  
    {  
        String sql  = "select score from student where name = '"+name+"';";  
        double result= 0;  
        try {  
            ResultSet rs = state.executeQuery(sql);  
            while(rs.next())  
            {  
                 result = rs.getDouble("score");  
            }  
          
        } catch (SQLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
        return result;  
    }  
}  
</span>

下面就是編寫實現類，要繼承UnicastRemoteObject，并且實現上面定義的接口。

<span style="font-size:16px;">import java.rmi.RemoteException;  
import java.rmi.server.UnicastRemoteObject;  
 
 
public class DataServerImpl extends UnicastRemoteObject implements DataServer {  
 
    static  {  
        DBManager.init();  
    }  
    public DataServerImpl() throws RemoteException {  
        super();  
          
        // TODO Auto-generated constructor stub  
    }  
      
    @Override 
    public void CreateTable() throws RemoteException {  
        DBManager.CreateTable();  
    }  
 
    @Override 
    public void insert(int id, String name, double score)  
            throws RemoteException {  
        DBManager.insert(id, name, score);  
    }  
 
    @Override 
    public double select(int id) throws RemoteException {  
        // TODO Auto-generated method stub  
        double score = DBManager.select(id);  
        return score;  
    }  
 
    @Override 
    public double select(String name) throws RemoteException {  
        double score = DBManager.select(name);  
        return score;  
    }  
 
}  
</span>

這樣就基本上完成了，然后就是編寫服務端的代碼：

<span style="font-size:16px;">import java.net.MalformedURLException;  
import java.rmi.Naming;  
import java.rmi.RemoteException;  
import java.rmi.registry.LocateRegistry;  
 
public class RMIServer {  
 
    public static void main(String[] args) {  
        try {  
            DataServerImpl dataServer = new DataServerImpl();  
            LocateRegistry.createRegistry(1111);   //這里，服務端口號可任意指定  
              
            Naming.rebind("//localhost:1111/showScore", dataServer);  
            System.out.println("服務已經啟動。。");  
              
        } catch (RemoteException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        } catch (MalformedURLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
    }  
 
}  
</span>

使用命令空間綁定服務的地址，以及服務的名稱，以便客戶端實現遠程調用?？蛻舳说拇a如下：

<span style="font-size:16px;">import java.net.MalformedURLException;  
import java.rmi.Naming;  
import java.rmi.NotBoundException;  
import java.rmi.RemoteException;  
import java.util.Scanner;  
 
 
public class RMIClient {  
    public static void main(String[] args) {  
        Scanner sc = new Scanner(System.in);  
        try {  
            DataServer dataServer = (DataServer)Naming.lookup("//localhost:1111/showScore");  
            System.out.println("首先創建一個數據表，student");  
            dataServer.CreateTable();  
            System.out.println("創建成功。。");  
            boolean isrunning = true;  
            while(isrunning)  
            {  
                System.out.println("請您按照數字選擇操作。\n1.插入數據   2.按學號查找    3.按姓名查找   0.退出");  
                int select = sc.nextInt();  
                if(select == 1)  
                {  
                    System.out.println("請您依次輸入學生的學號、姓名、成績：");  
                    int num = sc.nextInt();  
                    String name = sc.next();  
                    double score = sc.nextDouble();  
                    dataServer.insert(num, name, score);  
                }  
                else if(select == 2)  
                {  
                    System.out.println("請您輸入學生的學號：");  
                    int num = sc.nextInt();  
                    double score = dataServer.select(num);  
                    System.out.println("學號： "+num +"   成績為： "+ score);  
                }  
                else if(select == 3)  
                {  
                    System.out.println("請您輸入學生的姓名：");  
                    String name  = sc.next();  
                    double score = dataServer.select(name);  
                    System.out.println("姓名：  "+name +"   成績為： "+ score);  
                }  
                else if(select == 0)  
                {  
                    isrunning = false;  
                }  
                else   
                {  
                    System.out.println("輸入有誤，請您重新輸入！");  
                }  
            }  
        } catch (MalformedURLException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        } catch (RemoteException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        } catch (NotBoundException e) {  
            // TODO Auto-generated catch block  
            e.printStackTrace();  
        }  
 
    }  
 
}  
</span>

這樣就基本上的完成了所有的工作。。。

原文鏈接：http://blog.csdn.net/wx_962464/article/details/7443231

【編輯推薦】

淺談Java的方法覆蓋與變量覆蓋
Java類變量和成員變量初始化過程
JavaScript表格組件加載速度測試
5個讓人激動的Java項目
Java并行編程：從并行任務集獲取反饋

責任編輯：林師授來源： wx_962464的博客

Java RMI

成人免费xxxxx在线视频软件_久久精品久久久_亚洲国产精品久久久_天天色天天色_亚洲人成一区_欧美一级欧美三级在线观看

Java RMI遠程調用