netthread.java~2~

java在线考试例子代码

package testovernet;

import java.io.*;
import java.net.*;

public class NetThread extends Thread {

    public ServerSocket serverSocket;
    public NetThread(ServerSocket serverSocket) {
        this.serverSocket=serverSocket;
    }

    public void run() {
        while (true) {

           try {

               Socket servSocket = serverSocket.accept();
               ExamAdmin examAdmin = new ExamAdmin();
               InputStream servInput = servSocket.getInputStream();
               OutputStream servOutput = servSocket.getOutputStream();

               DataInputStream dataInput = new DataInputStream(servInput);
               DataOutputStream dataOutput = new DataOutputStream(servOutput);

               ObjectInputStream objInput = new ObjectInputStream(servInput);
               ObjectOutputStream objOutput = new ObjectOutputStream(
                       servOutput);

               Student stuFromClient = (Student) objInput.readObject();

               System.out.println("Student " + stuFromClient.name +
                                  " is connected. "
                                  + "\n" + "Authenticating...");

               //stuFromClient.printStudentInfo();

               boolean isStudent = examAdmin.isStudentInDatabase(stuFromClient.
                       testNum, stuFromClient.name);

               if (isStudent == true) {

                   dataOutput.writeUTF("\nAuthenticated!" +
                                       "\nYou are qulified to take a test!\n"
                                       +
                           "Please input what type of question you want"
                                       + " to answer and how many?");


                   dataOutput.writeUTF("Eligible");

                   String questionType = dataInput.readUTF();
                   int questionAmount = dataInput.readInt();

                   examAdmin.sendPaperToStudent(questionType, questionAmount,
                                                objOutput);

                   examAdmin.getTestPaperAfterExamFromStudent(questionAmount,
                           objInput);

                   examAdmin.caculatorStudentScore(questionAmount, dataOutput);

                   examAdmin.recordStudentScoreToDatabase();

               }
               else {

                   dataOutput.writeUTF(
                           "\nSorry,You are not qulified to take a test!\n"
                           + "Please make yourself qulified, Bye!!!");
                   dataOutput.writeUTF("NotEligible");
               }

               servInput.close();
               servOutput.close();
               servSocket.close();
           }
           catch (Exception e) {
               e.printStackTrace();
           }
       }

    }

}