JavaRMI远程调用

这次是用java实现RMI 的远程调用：

创新互联是创新、创意、研发型一体的综合型网站建设公司，自成立以来公司不断探索创新，始终坚持为客户提供满意周到的服务，在本地打下了良好的口碑，在过去的10多年时间我们累计服务了上千家以及全国政企客户，如成都汽车玻璃修复等企业单位，完善的项目管理流程，严格把控项目进度与质量监控加上过硬的技术实力获得客户的一致表扬。

编写的过程大致为：

  1. 首先我们的启动Mysqlserver ，然后再里面建立一个数据库，以便我们在数据库中插入存放学生信息等。
  2. 先编写一个接口DataServer，并且继承Remote类，然后再接口里面写上服务器端能实现的方法，然后再定义一个类DataServerImpl 继承UnicastRemoteObject 在实现接口DataServer，并且一一实现它定义在借口里面得到方法，这里我们重新写了一个类DBManager，用来实现与数据库的连接，包括插入数据，根据学号、姓名等进行查询等操作，其源代码见附件。
  3. 下面就是需要使用rmic命令进行编译DataServerImpl文件，并且产生两个文件，产生这两个文件后就可以编写服务器端的代码了，主要是在主函数中生成一个DataServerImpl对象，然后在绑定一个端口在程序中，在绑定一个url地址，来绑定服务的对象，这样服务器端的程序就写好了。
  4. 下面就是写客户端的代码了。
  5. 首先是通过Naming.lookup(url),(url)就是服务器端指定的url地址这样就可以得到一个DataServer的对象，然后得到这样一个对象后就可以调用它的方法了。这样也就实现了调用远程服务器端的代码了，所以说这样RMI就比本上写完了。

首先是编写远程的接口调用函数：

 
 
 
    
  
  
  
  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.

由于代码中使用到了与数据库的连接，所以写了一个数据库的管理类，代码如下：

 
 
 
    
  
  
  
  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.

下面就是编写实现类，要继承UnicastRemoteObject，并且实现上面定义的接口。

 
 
 
    
  
  
  
  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.

这样就基本上完成了，然后就是编写服务端的代码：

 
 
 
    
  
  
  
  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);   //这里，服务端口号可任意指定 
    12. 
  
  
  
  12.              
    13. 
  
  
  
  13.             Naming.rebind("//localhost:1111/showScore", dataServer); 
    14. 
  
  
  
  14.             System.out.println("服务已经启动。。"); 
    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.

使用命令空间绑定服务的地址，以及服务的名称，以便客户端实现远程调用。客户端的代码如下：

 
 
 
    
  
  
  
  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("//localhost:1111/showScore"); 
    13. 
  
  
  
  13.             System.out.println("首先创建一个数据表，student"); 
    14. 
  
  
  
  14.             dataServer.CreateTable(); 
    15. 
  
  
  
  15.             System.out.println("创建成功。。"); 
    16. 
  
  
  
  16.             boolean isrunning = true; 
    17. 
  
  
  
  17.             while(isrunning) 
    18. 
  
  
  
  18.             { 
    19. 
  
  
  
  19.                 System.out.println("请您按照数字选择操作。\n1.插入数据   2.按学号查找    3.按姓名查找   0.退出"); 
    20. 
  
  
  
  20.                 int select = sc.nextInt(); 
    21. 
  
  
  
  21.                 if(select == 1) 
    22. 
  
  
  
  22.                 { 
    23. 
  
  
  
  23.                     System.out.println("请您依次输入学生的学号、姓名、成绩："); 
    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("请您输入学生的学号："); 
    32. 
  
  
  
  32.                     int num = sc.nextInt(); 
    33. 
  
  
  
  33.                     double score = dataServer.select(num); 
    34. 
  
  
  
  34.                     System.out.println("学号： "+num +"   成绩为： "+ score); 
    35. 
  
  
  
  35.                 } 
    36. 
  
  
  
  36.                 else if(select == 3) 
    37. 
  
  
  
  37.                 { 
    38. 
  
  
  
  38.                     System.out.println("请您输入学生的姓名："); 
    39. 
  
  
  
  39.                     String name  = sc.next(); 
    40. 
  
  
  
  40.                     double score = dataServer.select(name); 
    41. 
  
  
  
  41.                     System.out.println("姓名：  "+name +"   成绩为： "+ 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.

这样就基本上的完成了所有的工作。。。

新闻名称：JavaRMI远程调用
网页URL：http://www.csdahua.cn/qtweb/news42/38542.html

网站建设、网络推广公司-快上网，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 快上网

成都快上网为您推荐相关内容

品牌网站建设知识

分类信息网

企业网站建设公司　　 　成都移动机房　　 　卡多尼人工智　　 　vi形象设计　　 　四川绵阳机房　　 　成都公司注册　　 　成都做网站　　 　四川主机托管　　 　IDC机房托管　　 　关键词优化　　 　成都小程序开发公司　　 　重庆主机托管　　 　广告吸塑字　　 　上市企业网站建设方案　　 　成都装修公司　　 　成都全屋定制　　 　成都小程序开发　　 　网络营销公司　　 　网站设计制作报价　　 　绵阳发电机