日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

RELATEED CONSULTING
相關(guān)咨詢
選擇下列產(chǎn)品馬上在線溝通
服務(wù)時間：8:30-17:00
你可能遇到了下面的問題
關(guān)閉右側(cè)工具欄

新聞中心

這里有您想知道的互聯(lián)網(wǎng)營銷解決方案
JavaRMI遠(yuǎn)程調(diào)用

這次是用java實(shí)現(xiàn)RMI 的遠(yuǎn)程調(diào)用：

創(chuàng)新互聯(lián)是創(chuàng)新、創(chuàng)意、研發(fā)型一體的綜合型網(wǎng)站建設(shè)公司，自成立以來公司不斷探索創(chuàng)新，始終堅(jiān)持為客戶提供滿意周到的服務(wù)，在本地打下了良好的口碑，在過去的10多年時間我們累計服務(wù)了上千家以及全國政企客戶，如成都汽車玻璃修復(fù)等企業(yè)單位，完善的項(xiàng)目管理流程，嚴(yán)格把控項(xiàng)目進(jìn)度與質(zhì)量監(jiān)控加上過硬的技術(shù)實(shí)力獲得客戶的一致表揚(yáng)。

編寫的過程大致為：

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

首先是編寫遠(yuǎn)程的接口調(diào)用函數(shù)：

 
 
 
    
  
  
  
  1. import java.rmi.Remote; 
    2. 
  
  
  
  2. import java.rmi.RemoteException; 
    3. 
  
  
  
  3. 
  
  
  
  4. public interface DataServer extends Remote { 
    5. 
  
  
  
  5.     public void CreateTable() throws RemoteException; 
    6. 
  
  
  
  6.     public void insert(int id ,String name,double Score) throws RemoteException; 
    7. 
  
  
  
  7.     public double select(int id)throws RemoteException; 
    8. 
  
  
  
  8.     public double select (String name)throws RemoteException; 
    9. 
  
  
  
  9. } 
    10. 
  
  
  
  10.

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

 
 
 
    
  
  
  
  1. import java.sql.Connection; 
    2. 
  
  
  
  2. import java.sql.DriverManager; 
    3. 
  
  
  
  3. import java.sql.ResultSet; 
    4. 
  
  
  
  4. import java.sql.SQLException; 
    5. 
  
  
  
  5. 
  
  
  
  6. public class DBManager { 
    7. 
  
  
  
  7.     private static String user = "root"; 
    8. 
  
  
  
  8.     private static String pass = "123456"; 
    9. 
  
  
  
  9.     private static String className ="com.mysql.jdbc.Driver"; 
    10. 
  
  
  
  10.     private static String url = "jdbc:mysql://localhost:3306/students"; 
    11. 
  
  
  
  11.     private static Connection conn; 
    12. 
  
  
  
  12.     private static java.sql.Statement state; 
    13. 
  
  
  
  13.     public static void init() 
    14. 
  
  
  
  14.     { 
    15. 
  
  
  
  15.         try { 
    16. 
  
  
  
  16.             Class.forName(className); 
    17. 
  
  
  
  17.              conn = DriverManager.getConnection(url,user,pass); 
    18. 
  
  
  
  18.              state =conn.createStatement(); 
    19. 
  
  
  
  19.               
    20. 
  
  
  
  20.               
    21. 
  
  
  
  21.         } catch (ClassNotFoundException e) { 
    22. 
  
  
  
  22.             // TODO Auto-generated catch block 
    23. 
  
  
  
  23.             e.printStackTrace(); 
    24. 
  
  
  
  24.         } catch (SQLException e) { 
    25. 
  
  
  
  25.             // TODO Auto-generated catch block 
    26. 
  
  
  
  26.             e.printStackTrace(); 
    27. 
  
  
  
  27.         } 
    28. 
  
  
  
  28.     } 
    29. 
  
  
  
  29.     public static  void CreateTable(){ 
    30. 
  
  
  
  30.         String sql = "create table student (id int Primary key, name char (20),score double);"; 
    31. 
  
  
  
  31.         try { 
    32. 
  
  
  
  32.             state.execute(sql); 
    33. 
  
  
  
  33.      
    34. 
  
  
  
  34.         } catch (SQLException e) { 
    35. 
  
  
  
  35.             e.printStackTrace(); 
    36. 
  
  
  
  36.         } 
    37. 
  
  
  
  37.     } 
    38. 
  
  
  
  38.     public static void insert(int id,String name,double score) 
    39. 
  
  
  
  39.     { 
    40. 
  
  
  
  40.         String sql = "insert into student values("+id+",'"+name+"',"+score+");"; 
    41. 
  
  
  
  41.         try { 
    42. 
  
  
  
  42.             state.execute(sql); 
    43. 
  
  
  
  43.              
    44. 
  
  
  
  44.         } catch (SQLException e) { 
    45. 
  
  
  
  45.             // TODO Auto-generated catch block 
    46. 
  
  
  
  46.             e.printStackTrace(); 
    47. 
  
  
  
  47.         } 
    48. 
  
  
  
  48.     } 
    49. 
  
  
  
  49.     public static double select(int id) 
    50. 
  
  
  
  50.     { 
    51. 
  
  
  
  51.         String sql  = "select score from student where id = "+id+";"; 
    52. 
  
  
  
  52.         double result= 0; 
    53. 
  
  
  
  53.         try { 
    54. 
  
  
  
  54.             ResultSet rs = state.executeQuery(sql); 
    55. 
  
  
  
  55.             while(rs.next()) 
    56. 
  
  
  
  56.             { 
    57. 
  
  
  
  57.                  result = rs.getDouble("score"); 
    58. 
  
  
  
  58.             } 
    59. 
  
  
  
  59.              
    60. 
  
  
  
  60.         } catch (SQLException e) { 
    61. 
  
  
  
  61.             // TODO Auto-generated catch block 
    62. 
  
  
  
  62.             e.printStackTrace(); 
    63. 
  
  
  
  63.         } 
    64. 
  
  
  
  64.         return result; 
    65. 
  
  
  
  65.     } 
    66. 
  
  
  
  66.      
    67. 
  
  
  
  67.     public static double select(String name) 
    68. 
  
  
  
  68.     { 
    69. 
  
  
  
  69.         String sql  = "select score from student where name = '"+name+"';"; 
    70. 
  
  
  
  70.         double result= 0; 
    71. 
  
  
  
  71.         try { 
    72. 
  
  
  
  72.             ResultSet rs = state.executeQuery(sql); 
    73. 
  
  
  
  73.             while(rs.next()) 
    74. 
  
  
  
  74.             { 
    75. 
  
  
  
  75.                  result = rs.getDouble("score"); 
    76. 
  
  
  
  76.             } 
    77. 
  
  
  
  77.          
    78. 
  
  
  
  78.         } catch (SQLException e) { 
    79. 
  
  
  
  79.             // TODO Auto-generated catch block 
    80. 
  
  
  
  80.             e.printStackTrace(); 
    81. 
  
  
  
  81.         } 
    82. 
  
  
  
  82.         return result; 
    83. 
  
  
  
  83.     } 
    84. 
  
  
  
  84. } 
    85. 
  
  
  
  85.

下面就是編寫實(shí)現(xiàn)類，要繼承UnicastRemoteObject，并且實(shí)現(xiàn)上面定義的接口。

 
 
 
    
  
  
  
  1. import java.rmi.RemoteException; 
    2. 
  
  
  
  2. import java.rmi.server.UnicastRemoteObject; 
    3. 
  
  
  
  3. 
  
  
  
  4. 
  
  
  
  5. public class DataServerImpl extends UnicastRemoteObject implements DataServer { 
    6. 
  
  
  
  6. 
  
  
  
  7.     static  { 
    8. 
  
  
  
  8.         DBManager.init(); 
    9. 
  
  
  
  9.     } 
    10. 
  
  
  
  10.     public DataServerImpl() throws RemoteException { 
    11. 
  
  
  
  11.         super(); 
    12. 
  
  
  
  12.          
    13. 
  
  
  
  13.         // TODO Auto-generated constructor stub 
    14. 
  
  
  
  14.     } 
    15. 
  
  
  
  15.      
    16. 
  
  
  
  16.     @Override
    17. 
  
  
  
  17.     public void CreateTable() throws RemoteException { 
    18. 
  
  
  
  18.         DBManager.CreateTable(); 
    19. 
  
  
  
  19.     } 
    20. 
  
  
  
  20. 
  
  
  
  21.     @Override
    22. 
  
  
  
  22.     public void insert(int id, String name, double score) 
    23. 
  
  
  
  23.             throws RemoteException { 
    24. 
  
  
  
  24.         DBManager.insert(id, name, score); 
    25. 
  
  
  
  25.     } 
    26. 
  
  
  
  26. 
  
  
  
  27.     @Override
    28. 
  
  
  
  28.     public double select(int id) throws RemoteException { 
    29. 
  
  
  
  29.         // TODO Auto-generated method stub 
    30. 
  
  
  
  30.         double score = DBManager.select(id); 
    31. 
  
  
  
  31.         return score; 
    32. 
  
  
  
  32.     } 
    33. 
  
  
  
  33. 
  
  
  
  34.     @Override
    35. 
  
  
  
  35.     public double select(String name) throws RemoteException { 
    36. 
  
  
  
  36.         double score = DBManager.select(name); 
    37. 
  
  
  
  37.         return score; 
    38. 
  
  
  
  38.     } 
    39. 
  
  
  
  39. 
  
  
  
  40. } 
    41. 
  
  
  
  41.

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

 
 
 
    
  
  
  
  1. import java.net.MalformedURLException; 
    2. 
  
  
  
  2. import java.rmi.Naming; 
    3. 
  
  
  
  3. import java.rmi.RemoteException; 
    4. 
  
  
  
  4. import java.rmi.registry.LocateRegistry; 
    5. 
  
  
  
  5. 
  
  
  
  6. public class RMIServer { 
    7. 
  
  
  
  7. 
  
  
  
  8.     public static void main(String[] args) { 
    9. 
  
  
  
  9.         try { 
    10. 
  
  
  
  10.             DataServerImpl dataServer = new DataServerImpl(); 
    11. 
  
  
  
  11.             LocateRegistry.createRegistry(1111);   //這里，服務(wù)端口號可任意指定 
    12. 
  
  
  
  12.              
    13. 
  
  
  
  13.             Naming.rebind("http://localhost:1111/showScore", dataServer); 
    14. 
  
  
  
  14.             System.out.println("服務(wù)已經(jīng)啟動。。"); 
    15. 
  
  
  
  15.              
    16. 
  
  
  
  16.         } catch (RemoteException e) { 
    17. 
  
  
  
  17.             // TODO Auto-generated catch block 
    18. 
  
  
  
  18.             e.printStackTrace(); 
    19. 
  
  
  
  19.         } catch (MalformedURLException e) { 
    20. 
  
  
  
  20.             // TODO Auto-generated catch block 
    21. 
  
  
  
  21.             e.printStackTrace(); 
    22. 
  
  
  
  22.         } 
    23. 
  
  
  
  23.     } 
    24. 
  
  
  
  24. 
  
  
  
  25. } 
    26. 
  
  
  
  26.

使用命令空間綁定服務(wù)的地址，以及服務(wù)的名稱，以便客戶端實(shí)現(xiàn)遠(yuǎn)程調(diào)用?？蛻舳说拇a如下：

 
 
 
    
  
  
  
  1. import java.net.MalformedURLException; 
    2. 
  
  
  
  2. import java.rmi.Naming; 
    3. 
  
  
  
  3. import java.rmi.NotBoundException; 
    4. 
  
  
  
  4. import java.rmi.RemoteException; 
    5. 
  
  
  
  5. import java.util.Scanner; 
    6. 
  
  
  
  6. 
  
  
  
  7. 
  
  
  
  8. public class RMIClient { 
    9. 
  
  
  
  9.     public static void main(String[] args) { 
    10. 
  
  
  
  10.         Scanner sc = new Scanner(System.in); 
    11. 
  
  
  
  11.         try { 
    12. 
  
  
  
  12.             DataServer dataServer = (DataServer)Naming.lookup("http://localhost:1111/showScore"); 
    13. 
  
  
  
  13.             System.out.println("首先創(chuàng)建一個數(shù)據(jù)表，student"); 
    14. 
  
  
  
  14.             dataServer.CreateTable(); 
    15. 
  
  
  
  15.             System.out.println("創(chuàng)建成功。。"); 
    16. 
  
  
  
  16.             boolean isrunning = true; 
    17. 
  
  
  
  17.             while(isrunning) 
    18. 
  
  
  
  18.             { 
    19. 
  
  
  
  19.                 System.out.println("請您按照數(shù)字選擇操作。\n1.插入數(shù)據(jù)   2.按學(xué)號查找    3.按姓名查找   0.退出"); 
    20. 
  
  
  
  20.                 int select = sc.nextInt(); 
    21. 
  
  
  
  21.                 if(select == 1) 
    22. 
  
  
  
  22.                 { 
    23. 
  
  
  
  23.                     System.out.println("請您依次輸入學(xué)生的學(xué)號、姓名、成績："); 
    24. 
  
  
  
  24.                     int num = sc.nextInt(); 
    25. 
  
  
  
  25.                     String name = sc.next(); 
    26. 
  
  
  
  26.                     double score = sc.nextDouble(); 
    27. 
  
  
  
  27.                     dataServer.insert(num, name, score); 
    28. 
  
  
  
  28.                 } 
    29. 
  
  
  
  29.                 else if(select == 2) 
    30. 
  
  
  
  30.                 { 
    31. 
  
  
  
  31.                     System.out.println("請您輸入學(xué)生的學(xué)號："); 
    32. 
  
  
  
  32.                     int num = sc.nextInt(); 
    33. 
  
  
  
  33.                     double score = dataServer.select(num); 
    34. 
  
  
  
  34.                     System.out.println("學(xué)號： "+num +"   成績?yōu)椋?nbsp;"+ score); 
    35. 
  
  
  
  35.                 } 
    36. 
  
  
  
  36.                 else if(select == 3) 
    37. 
  
  
  
  37.                 { 
    38. 
  
  
  
  38.                     System.out.println("請您輸入學(xué)生的姓名："); 
    39. 
  
  
  
  39.                     String name  = sc.next(); 
    40. 
  
  
  
  40.                     double score = dataServer.select(name); 
    41. 
  
  
  
  41.                     System.out.println("姓名：  "+name +"   成績?yōu)椋?nbsp;"+ score); 
    42. 
  
  
  
  42.                 } 
    43. 
  
  
  
  43.                 else if(select == 0) 
    44. 
  
  
  
  44.                 { 
    45. 
  
  
  
  45.                     isrunning = false; 
    46. 
  
  
  
  46.                 } 
    47. 
  
  
  
  47.                 else  
    48. 
  
  
  
  48.                 { 
    49. 
  
  
  
  49.                     System.out.println("輸入有誤，請您重新輸入！"); 
    50. 
  
  
  
  50.                 } 
    51. 
  
  
  
  51.             } 
    52. 
  
  
  
  52.         } catch (MalformedURLException e) { 
    53. 
  
  
  
  53.             // TODO Auto-generated catch block 
    54. 
  
  
  
  54.             e.printStackTrace(); 
    55. 
  
  
  
  55.         } catch (RemoteException e) { 
    56. 
  
  
  
  56.             // TODO Auto-generated catch block 
    57. 
  
  
  
  57.             e.printStackTrace(); 
    58. 
  
  
  
  58.         } catch (NotBoundException e) { 
    59. 
  
  
  
  59.             // TODO Auto-generated catch block 
    60. 
  
  
  
  60.             e.printStackTrace(); 
    61. 
  
  
  
  61.         } 
    62. 
  
  
  
  62. 
  
  
  
  63.     } 
    64. 
  
  
  
  64. 
  
  
  
  65. } 
    66. 
  
  
  
  66.

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


文章標(biāo)題：JavaRMI遠(yuǎn)程調(diào)用
網(wǎng)站網(wǎng)址：http://www.5511xx.com/article/cdedsdg.html