java实现CORBA

[java] view plaincopyprint?

1.   

1.      利用CORBA实现数据的访问，也就是通过客户端的代码，访问服务器端的代码。首先是定义一个idl文件，里面的主要类型就是定义一个接口，类容如下：

2.      然后利用idlj –fall DataService.idl 命令来编译idl文件，编译后得到了许多的java文件，文件如下所示：

再然后，在该文件中建立一个Server文件夹，然后将生成的文件放入，并且建立一个java功能，作为服务器端，这里要求从数据库读取数据，所以我们写了一个DBManager类来实现与数据库的连接，以及插入、查询功能：里面的代码如下：

 

[java] view plaincopyprint?

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

 

3.      然后就是编写服务器端的代码，在服务器端里面有一个类实现定一个的接口里面的代码如下：

[java] view plaincopyprint?

1. class DataServiceImpl extends DataServicePOA {  
2.    private ORB orb ;  
3.    private studentScore s =new studentScore();  
4.    publicvoid setorb(ORB orb)  
5.    {  
6.       this.orb = orb;  
7.        
8.    }  
9.     
10.    @Override  
11.    publicvoid insert(String num, double score) {  
12.       DBManager.insert(num, score);  
13.    }  
14.    @Override  
15.    publicdouble select(String num) {  
16.     
17.       return   DBManager.select(num);  
18.        
19.    }  
20.    @Override  
21.    publicvoid selectAll() {  
22.       // TODO Auto-generatedmethod stub   
23.        
24.    }  
25. }  

这样服务器端提供的功能都实现了，然后在服务端创建服务对象并将其向 ORB 注册这样服务端的代码就写好了。

 

4.      下面就是写客户端的代码，和前面一个将生成的文件加入到客户端文件中，然后编写一个客户端文件，主要是实现数据初始化，并且连接服务程序，这里面需要输入IOR码，并且必须和服务器端产生的一样，这样才能得到服务端的服务，得到服务对象之后就是对服务端的方法的调用实现数据的插入和查询操作。

5.      下面就将运行的过程演示一遍：

首先是启动服务端：

然后就是运行客户端：

等待用户输入IOR码.(是由服务器端产生的)，然后输入IOR码：

然后就是根据数字选择操作开始调用方法了，我们随便来演示几个：

插入成功，然后我们查询一下看看是不是正确的：

然后为了保证是正确的我们再去数据库中看看：

数据库中也有我们插入的数据，说明是正确的。

这样我们就完成了java开发CORBA的过程。