2021山东大学软件学院JAVA高程课设-考试平台的设计

package Server; import DataObject.*; import java.io.*; import java.net.Socket; import java.sql.SQLException; //服务端先获得ObjectlnputStream对象，客户端就要先获得ObjectOutputStream对象; //服务端先获得ObjectOutputStream对象，客户端就要先获得ObjectInputStream对象 public class ServerHandleThread implements Runnable{ Socket socket=null; public ServerHandleThread(Socket socket) { super(); this.socket = socket; } @Override public void run() { // TODO Auto-generated method stub InputStream is=null; OutputStream os = null; ObjectInputStream ois = null; ObjectOutputStream oos = null; SerializableObject serializableObject_in=null; SerializableObject[] serializableObjects_in=null; SerializableObject serializableObject_out=null; SerializableObject[] serializableObjects_out=null; try { is = socket.getInputStream(); ois=new ObjectInputStream(is);//反序列化流，将之前使用 ObjectOutputStream 序列化的原始数据恢复为对象，以流的方式读取对象 serializableObject_in=(SerializableObject) ois.readObject();//readObject()方法必须保证服务端和客户端的SerializableObject类包名一致，要不然会出现找不到类的错误 //System.out.println(serializableObject_in.getFunction()); //socket.shutdownInput();// 禁用套接字的输入流 //在客户端或者服务端通过socket.shutdownOutput()都是单向关闭的，即关闭客户端的输出流并不会关闭服务端的输出流，所以是一种单方向的关闭流； //通过socket.shutdownOutput()关闭输出流，但socket仍然是连接状态，连接并未关闭 //如果直接关闭输入或者输出流，即：in.close()或者out.close()，会直接关闭socket //以下功能是面向教师的 //实现登陆功能 if(serializableObject_in.getFunction().equals("登陆")){ socket.shutdownInput(); UserInfo userInfo_in=(UserInfo)serializableObject_in; String telephonenum=userInfo_in.getTelephonenum(); String password=userInfo_in.getPassword(); Landing landing=new Landing(); UserInfo userInfo_out=landing.findUser(telephonenum,password); //如果登陆成功，则返回一个function为“登陆成功”的对象，还包含一个用户的所有信息 if(userInfo_out!=null){ System.out.println("用户"+userInfo_out.getUsername()+"登陆！"); serializableObject_out=userInfo_out; serializableObject_out.setFunction("登陆成功"); serializableObject_out.setTYPE("UserInfo"); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } //登陆失败 else { serializableObject_out=new SerializableObject(); serializableObject_out.setFunction("登陆失败，账号或密码错误"); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } } //实现注册功能 if(serializableObject_in.getFunction().equals("注册")){ socket.shutdownInput(); UserInfo userInfo_in=(UserInfo)serializableObject_in; Enroll enroll=new Enroll(); String str=enroll.Enroll(userInfo_in.getUsername(),userInfo_in.getTelephonenum(),userInfo_in.getSchool(),userInfo_in.getPassword(),userInfo_in.getIdentity()); //如果注册成功，则返回一个function为“注册成功”的对象 if(str.equals("注册成功")){ System.out.println("用户"+userInfo_in.getUsername()+"注册！"); serializableObject_out=new SerializableObject(); serializableObject_out.setFunction("注册成功"); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } //如果注册失败 else { serializableObject_out=new SerializableObject(); serializableObject_out.setFunction("注册失败，账号或用户名重复"); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } } //修改密码 if(serializableObject_in.getFunction().equals("修改密码")){ socket.shutdownInput(); UserInfo userInfo=(UserInfo)serializableObject_in; ChangePassword changePassword=new ChangePassword(); String str=changePassword.changePassword(userInfo.getTelephonenum(),userInfo.getPassword(),userInfo.getTYPE()); if(str.equals("修改成功")){ System.out.println("修改密码！"); } serializableObject_out=new SerializableObject(); //System.out.println(str); serializableObject_out.setFunction(str); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } //在题库中添加题目 if(serializableObject_in.getFunction().equals("题库添加")){ socket.shutdownInput(); Question question=(Question) serializableObject_in; DoQuestionBank doQuestionBank=new DoQuestionBank(); String str; if(question.getType().equals("选择题")){ str=doQuestionBank.addSelection(question.getId(),question.getComplexity(),question.getType(),question.getContent(),question.getOptiona(),question.getOptionb(),question.getOptionc(),question.getOptiond(),question.getAnswer()); } //其他两种题型 else{ str=doQuestionBank.addReadProgram(question.getId(),question.getComplexity(),question.getType(),question.getContent(),question.getAnswer()); } if(str.equals("添加成功")){ System.out.println("题库添加！"); serializableObject_out=new SerializableObject(); serializableObject_out.setFunction("添加成功"); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } else{ serializableObject_out=new SerializableObject(); serializableObject_out.setFunction("添加失败，题号或题目内容重复"); os=socket.getOutputStream(); oos=new ObjectOutputStream(os); oos.writeObject(serializableObject_out); socket.shutdownOutput(); } } //在题库中根据题号查询 if(serializableObject_in.getFunction().equals("题库查询")){ socket.shutdownInput(); Question question=(Question) serializableObject_in; DoQuestionBank doQuestionBank=new DoQuestionBank(); Question q=doQuestionBank.queryQuestionID(question.getId()); //如果查询成功，则返回一个function为“查询成功”的对象，还包含一个问题的所有信息 if(q!=null){