分布式计算 lab2 Java RMI

题目：

实验二：Java RMI试验

【实验目的及要求】

在Java语言环境下，通过RMI实现一个学生成绩或教师信息查询的程序。

要求：要求独立完成。

【实验原理和步骤】

1. 定义学生成绩查询或教师信息查询的远程接口

2. 实现服务器端软件（程序）：设计远程接口的实现类和服务器对象类，在服务器上启动目录服务，并注册远程对象，供客户端访问。远程接口的实现类要从本地读取数据信息（成绩或教师信息），数据信息可以存储在文件或数据库中。

3. 实现客户端软件（程序）：实现访问远程对象的客户程序。

话说前几天考完分布式就蛋疼了，还是回来乖乖把lab都给撸掉...挂了可就不好玩儿了。lab2比较直白，感觉老师就是让我们去敲敲rmi的代码，走走流程熟悉一下。废话不多说，开始记录记录。

这里我实际上要做的只有三件事：

1. 搞定数据库的链接，随便建个表，存点记录进去。

2. 把远程接口、接口实现类、stub、sever和client神马的都写了，编了。

3. 程序跑起，虫子给捉起，动漫给看起，微博刷起....起...起起...

数据库

首先数据库这块要弄好，我比较喜欢从底层往上打代码。本来想复用上学期数据库大作业的代码，可惜当时没有写blog记录的习惯。在图书馆里逛了逛，惊奇地发现了当时做数据库大作业时候参考的那本书，顿时感觉尼玛遇上了初恋啊（初恋总是美好的有木有= =）。数据库方面的代码我就参考上面的demo了，另外还参考了同样封面的另一本书，这里记录一下。

1. Java程序设计实践教程（颜志军 栾媛媛）
2. Java程序设计（张化祥 陆晶）

都是清华大学出版社的，尼玛，一个出版社有必要出两本内容几乎一样的书嘛- -.....

要搞成数据库，先要装一个JDBC（Java Data Base Connectivity）驱动。驱动其实就是封装好的一堆代码。因为市面上数据库很多，MySQL和sqlserver什么的，你不可能对所有数据库的语言都了解。Java就定义了一些标准的API，然后让数据库的公司自己根据所定义的API来实现。比如定义一个executeQuery();这个函数有什么功能，参数是什么，返回值是什么，Java给你定义好，实现的过程你丫的爱怎么实现就怎么实现，Java不管。所以我们用Java只要按API来调用，数据库就乖乖地运行了...数据库公司实现的，其实就是JDBC驱动。

我是用的mySQL，自然下了个mySQL的驱动，在相应的工程里添加一下即可。步骤如下：

右击工程，Build Path->Configure Build Path->选Libraries->Add External JARs（这里找到你放驱动的路径，直接add就可以了）

驱动百度一下（或者360一下）很容易找到。

下面的都搞好了，就开始弄上面。首先我们需要知道怎么用代码连数据库，索性初恋Java书告诉了我：

数据库连接类：

import java.sql.*;


public class DbConn {
    private Connection conn;
    protected DbConn(String dbDriver, String dbUrl, String username, String password){
        conn = null;
        
        
        try {
            //载入参数指定的驱动，如未找到驱动程序，将抛出ClassNotFound/Exception异常
            Class.forName(dbDriver);
            
            //建立数据库连接，可能会抛出SQLException异常
            conn = DriverManager.getConnection(dbUrl, username, password);
            
        } catch (ClassNotFoundException cnfe) {
            System.err.println(cnfe.getMessage());
        } catch (SQLException se) {
            System.err.println(se.getMessage());
        }
    }
    
    public static Connection getConnection(String dbDriver, String dbUrl, String username, String password){
        Connection conRet= null;
        DbConn bc = new DbConn(dbDriver, dbUrl, username, password);
        
        conRet = bc.conn;
        
        return conRet;
    }
}

测试用类：

public class testforfun {
    public static void main(String[] args){
        Connection conn = DbConn.getConnection("com.mysql.jdbc.Driver", "jdbc:mysql://localhost/distributeds", "root", "password");
                
        if(conn == null){
            System.out.println("未能成功连接数据库！");
        }
        else{
            System.out.println("成功连接数据库！");
            
            try {
                Statement st = conn.createStatement();
                
                String sql = "select * from student";
                
                ResultSet rs = st.executeQuery(sql);
                
                String id, name, cname;
                int score;
                
                while(rs.next()){
                    id = rs.getString("id");
                    name = rs.getString("name");
                    cname = rs.getString("cname");
                    score = rs.getInt("score");
                    
                    System.out.println(id + "\t" + name + "\t" + score + "\t" + cname);
                }
                
                rs.close();
                st.close();
                conn.close();
            } catch (SQLException se) {
                System.err.println(se.getMessage());
            }
            
        }
    }

}

这里需要解释一下的有：

1. distributeds是我建的数据库。

2. student是我建的渣表，很多重复数据，不过因为不是数据库实验，所以将就着吧。

create table student(
id varchar(12),
name varchar(20),
score integer,
cname varchar(40),
primary key(id)
);    

有一个东东很重要，就是

导入sql文件的命令：
mysql> source d:/myprogram/database/db.sql;

写在文本里，比较好，一次可以insert多条，也方便交实验代码。

数据库有关的都搞完了。

远程接口、接口实现类、stub、sever和client

远程接口：很简单。一开始返回值用的Resultset，后来发现不行，改成了String[]

接口实现类：关键所在，切记每次修改都要把stub重新生成一次。这里for循环给String[]赋值的时候犯了个二逼错误。程序跑起后老是说有空指针，我看来看去，没发现有数组越界啊。莫非最后的那个用来判定结束的"."出了问题？后来发现自己二逼把for的性质给搞错了，for是每次循环结束时累加，不是开始时。我当时多加了一个周期，难免出错。另外，由于client需要知道查到了多少条记录，是没有还是很多条，我考虑是不是需要封装一个新类，给String[]加一个int标记数量。后来觉得自己傻了，用一个标记结束符（如"."）就可以解决了。零个多个都没问题。

stub：这个东西就很坑爹了。考试的时候卷子把它翻译成了什么？= =桩！高贵的stub夫人真是一口老血都得吐出来了，中国的翻译真是伤不起，还是去求教字幕组吧。（那才是真正的中外文化交流大使啊）我们都知道，stub是接口实现类和rmic在cmd这酒店里搞出的私生女。该怎么生呢？rmic SomeImpl.class？ rmic SomeImpl.java？ 姿势都不对啊= =正确的姿势是rmic SomeImpl。 前提是cmd在实现类的目录下。这里本来还要加包名，就是 rmic packagename.SomeImpl。但是我创的时候没打包名，所以就不用输了。 

我在进目录的时候果断囧了。cd d: ，不行；cd d:\ ，不行；cd d:\ ，不行。尼玛各种姿势都试过了还不行是闹哪样啊= =。百度了一下原来是d: = =  cd是针对当前目录的。比如你在d: ，你想跳到 d:/mylab目录，你就输入cd mylab。想切换目录直接打路径就好。

server和client:这两个都打的比较快，书里的样例代码几乎不用改。

实验代码：

Client

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.sql.ResultSet;
import java.sql.SQLException;


public class ScoreClient {
    public static void main(String[] args) throws IOException {
        int RMIPort;
        
        //定义流对象
        InputStreamReader isr = new InputStreamReader(System.in);
        BufferedReader br = new BufferedReader(isr);
        
        //定义端口
        System.out.println("Enter the port number:");
        String portNum = br.readLine();
        RMIPort = Integer.parseInt(portNum);
        
        String registryURL = "rmi://localhost:" + portNum + "/Score";        
        
        ScoreReferInterface h;
        
        try {
            
            //查找远程对象
            h = (ScoreReferInterface)Naming.lookup(registryURL);            
            System.out.println("Lookup completed.");
            
            //输入 . 退出，或输入学生姓名以查询该学生的各门课成绩信息
            System.out.println("Enter the student's name or . to quit");
            
            while(true){                
            
            String sname = br.readLine();
            if(sname.equals("."))
                break;
            
            //调用远程方法
            String[] record = h.getScore(sname);
            
            int i = 0;
            while(true){        
                
                //检查是否读到records的结尾（以防数组越界）
                if(record[i].equals(new String("."))){
                    //若并无该学生记录，则提示No such a student.
                    if(i == 0)
                        System.out.println("No such a student.");
                    break;
                }
                    
                //输出学生课程成绩信息
                System.out.println(record[i] + "\t" + record[i+1] + "\t" + record[i+3] + "\t" +  record[i+2]);
                i+=4;
            }
            
            //输入 . 退出，或输入学生姓名以查询该学生的各门课成绩信息
            System.out.println("Enter the student's name or . to quit");
            }
            System.out.println("Goodbye.");
            
        } catch (NotBoundException e) {
            System.out.println("here I am");
            System.err.println(e.getMessage());
        } catch (SQLException se) {
            System.out.println("here I am2.");
            System.err.println(se.getMessage());
        }
        }
        
}

 Server:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;


public class ScoreServer {
    public static void main(String[] args) throws IOException{
        //定义流对象
        InputStreamReader isr = new InputStreamReader(System.in);
        BufferedReader br = new BufferedReader(isr);
        
        String portNum, registryURL;
        
        //设置服务器端口号
        System.out.println("Enter the RMIregistry port number");
        portNum = (br.readLine()).trim();
        int RMIPortNum = Integer.parseInt(portNum);
        
        //在指定端口处注册
        startRegistry(RMIPortNum);
        
        //注册接口实现类的引用
        ScoreReferImpl impl = new ScoreReferImpl();
        registryURL = "rmi://localhost:" + portNum + "/Score";        
        Naming.rebind(registryURL, impl);
        
        System.out.println("Sever registered.\n Registry contains:");
        
        //列出已注册的信息
        listRegistry(registryURL);
        
        System.out.println("Score sever already");
            
        
    }//end main
    
    public static void startRegistry(int RMIPortNum){
        try {
            Registry registry = LocateRegistry.getRegistry(RMIPortNum);
            registry.list();
        } catch (RemoteException e) {
            System.out.println("RMI registry cannot be located at port" + RMIPortNum);
            try {
                Registry registry = LocateRegistry.createRegistry(RMIPortNum);
            } catch (RemoteException e1) {
                // TODO Auto-generated catch block
                e1.printStackTrace();
            }
            System.out.println("RMI registry created at port: " + RMIPortNum);
        }
    }//end startRegistry
    
    private static void listRegistry(String registryURL) throws RemoteException, MalformedURLException{
        System.out.println("Registry " + registryURL + " contains: ");
        String[] names = Naming.list(registryURL);
        for(int i = 0;i<names.length;i++){
            System.out.println(names[i]);
        }
    }//end listRegistry

}//end class

Interface:

import java.rmi.Remote;
import java.sql.ResultSet;
import java.sql.SQLException;


public interface ScoreReferInterface extends Remote{
    public String[] getScore(String name)
        throws java.rmi.RemoteException, SQLException;
}

Implement of Interface:

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;


public class ScoreReferImpl extends UnicastRemoteObject
    implements ScoreReferInterface{

    //定义String数组的最大长度
    final static int MAX_LEN = 200;
    
    protected ScoreReferImpl() throws RemoteException {
        super();
        // TODO Auto-generated constructor stub
    }

    @Override
    public String[] getScore(String name) throws RemoteException, SQLException {
        //建立并获取数据库连接
        Connection conn = DbConn.getConnection("com.mysql.jdbc.Driver", "jdbc:mysql://localhost/distributeds", "root", "");
        
        if(conn == null){
            System.out.println("未能成功连接数据库！");
        }
        else{
            System.out.println("成功连接数据库！");
            
            //定义返回值String数组
            String[] records = new String[MAX_LEN];        
                
            //定义语句对象
            Statement st = conn.createStatement();
                
            //定义sql语句
            String sql = "select * from student where name='" + name + "'";
            
            //在数据库中查询并获得结果集
            ResultSet rs = st.executeQuery(sql);
            
            //将结果集中的记录存入String数组中
            String id, sname, cname, score;
                        
            int i;
            for(i = 0;rs.next();i+=4){
                id = rs.getString("id");
                sname = rs.getString("name");
                cname = rs.getString("cname");
                score = rs.getString("score");
                    
                records[i] = id;
                records[i+1] = sname;
                records[i+2] = cname;
                records[i+3] = score;
            }
            
            //标记结束字符串
            records[i] = ".";
            System.out.println(records[i]);
                
            rs.close();
            st.close();
            conn.close();
                
            
                
            return records;
            
        }
        return null;
    }

}