任务目标

• 需求
  -使用网络编程,IO流,序列化流,多线程实现C\S结构的学生信息管理系统
  
  思路分析:
  1.对象需要用到序列化,创建的学生类实现Serializable接口
  2.保存在文件,第一次用文件有没有,没有需创建,同时如果防止没有数据的时候读取报错,需要创建一个空集合,序列化到文件中.
  3.服务器和客户端约定好一种格式 比如添加[1]数据 表示添加 传输的格式[1]张三,18,北京
  4.id需要自增,需用到静态代码块,读取文件,拿到list的长度来编号
  5.客户端发送请求送,服务器需先从文件中序列化集合出来,操作完后重写上去(数据覆盖)
  6.修改比较特殊,先判断id是否存在,存在的情况需再次链接数据库发送格式数据,进行修改

服务器端

1.服务器的菜单

public class Server {public static void main(String[] args) {try {// 创建ServerSocket对象ServerSocket ss = new ServerSocket(8888);// 由于客户端访问服务器一个功能就连接,不访问就断开,所以要循环接收客户端请求while (true){// 接收客户端请求Socket socket = ss.accept();// 获取客户端传过来的数据,得到编号,做出相应的处理InputStream is = socket.getInputStream();byte[] bys = new byte[1024];int len = is.read(bys);String message = new String(bys,0,len);// 增删查改的编号都是在索引为1的位置上,所以根据这个规律得到编号char op = message.charAt(1);// 根据编号作出相应的处理switch (op){case '1':// 添加break;case '2':// 查询break;case '3':// 删除break;case '4':// 修改break;case '5':// 查询一条break;default:// 关闭连接System.out.println("格式错误!");socket.close();break;}}} catch (Exception e) {e.printStackTrace();}}
}

2.服务器的添加功能

 // 添加private static void addStudent(Socket socket,String message) {try {// 创建反序列化流FileInputStream fis = new FileInputStream("day25\\stu.txt");ObjectInputStream ois = new ObjectInputStream(fis);// 读取文件中的集合ArrayList<Student> list = (ArrayList<Student>) ois.readObject();// 解析客户端传入的数据String[] arr = message.substring(3).split(",");String name = arr[0];int age = Integer.parseInt(arr[1]);String address = arr[2];// 创建Student对象,并给属性赋值Student stu = new Student(++Utils.id,name,age,address);// 把学生对象添加到集合中list.add(stu);// 创建序列化流FileOutputStream fos = new FileOutputStream("day25\\stu.txt");ObjectOutputStream oos = new ObjectOutputStream(fos);// 把集合重新写回文件中oos.writeObject(list);// 写回数据给客户端OutputStream os = socket.getOutputStream();os.write("添加成功".getBytes());// 关闭流,关闭socketfos.close();fis.close();socket.close();} catch (Exception e) {e.printStackTrace();}}

3.服务器第一次启动创建文件,并写入一个空集合对象到文件中

// 在服务器的main方法下第一行
public class Server {public static void main(String[] args) {try {// 开始启动服务器,文件不存在,得创建文件,但只有第一次启动的时候才可以创建,后期就不能创建File file = new File("day25\\stu.txt");if (!file.exists()){file.createNewFile();}// 空文件,创建反序列化流FileInputStream fis = new FileInputStream(file);ObjectInputStream ois = new ObjectInputStream(fis);// 释放资源ois.close();} catch (Exception e) {// 产生异常,说明文件中没有内容,那么就写入一个空集合对象到文件中try {// 创建序列化流FileOutputStream fos = new FileOutputStream("day25\\stu.txt");ObjectOutputStream oos = new ObjectOutputStream(fos);// 把空集合对象添加到文件中ArrayList<Student> list = new ArrayList<>();oos.writeObject(list);// 释放资源oos.close();} catch (IOException e1) {e1.printStackTrace();}}// 创建服务器对象,等待客户端连接服务器.// ...省略.....}
}

4.服务器的查询功能

// 查询private static void selectStudent(Socket socket, String message) {try {// 创建反序列化流FileInputStream fis = new FileInputStream("day25\\stu.txt");ObjectInputStream ois = new ObjectInputStream(fis);// 读取文件中的集合ArrayList<Student> list = (ArrayList<Student>) ois.readObject();// 通过socket对象获取输出流OutputStream os = socket.getOutputStream();// 转换为序列化流ObjectOutputStream oos = new ObjectOutputStream(os);// 写出集合对象oos.writeObject(list);// 释放资源ois.close();socket.close();} catch (Exception e) {e.printStackTrace();}}

5.服务器的删除功能

 // 删除private static void deleteStudent(Socket socket, String message) {// 按照格式获取客户端要删除的学员编号String msg = message.substring(3);int id = Integer.parseInt(msg);try {// 创建反序列流FileInputStream fis = new FileInputStream("day25\\stu.txt");ObjectInputStream ois = new ObjectInputStream(fis);// 读取文件中的集合对象ArrayList<Student> list = (ArrayList<Student>) ois.readObject();// 判断集合中是否有该id的学员// 定义一个变量,标记是否删除成功boolean flag = false;// 默认删除失败// 循环遍历集合查找,如果有直接删除for (int i = 0; i < list.size(); i++) {Student stu = list.get(i);if (stu.getId() == id){// 删除list.remove(i);// 修改标记flag = true;// 更新文件中的数据// 创建序列化流FileOutputStream fos = new FileOutputStream("day25\\stu.txt");ObjectOutputStream oos = new ObjectOutputStream(fos);// 把集合重新写回文件中oos.writeObject(list);break;// 结束循环}}// 通过socket对象获取输出流OutputStream os = socket.getOutputStream();if (flag == true){os.write("删除成功".getBytes());}else {os.write("删除失败".getBytes());}// 关闭连接ois.close();socket.close();} catch (Exception e) {e.printStackTrace();}}

6.服务器查询一条数据

// 查询一条数据private static void selectById(Socket socket, String message) {// 按照格式获取客户端要删除的学员编号String msg = message.substring(3);int id = Integer.parseInt(msg);try {// 创建反序列流FileInputStream fis = new FileInputStream("day25\\stu.txt");ObjectInputStream ois = new ObjectInputStream(fis);// 读取文件中的集合对象ArrayList<Student> list = (ArrayList<Student>) ois.readObject();// 定义以变量,用来标记该学生是否存在boolean flag = false;// 默认不存在// 循环遍历集合查找,如果有就修改标记for (int i = 0; i < list.size(); i++) {Student stu = list.get(i);if (stu.getId() == id) {flag = true;break;}}// 根据标记,返回对于的内容// 通过socket对象获取输出流OutputStream os = socket.getOutputStream();if (flag == false){os.write(0);}else {os.write(1);}// 关闭连接,释放资源ois.close();socket.close();} catch (Exception e) {e.printStackTrace();}}

7.服务器修改功能

 // 修改private static void updateStudent(Socket socket, String message) {// 按照格式获取客户端要删除的学员编号String msg = message.substring(3);String[] arr = msg.split(",");int id = Integer.parseInt(arr[0]);String name = arr[1];int age = Integer.parseInt(arr[2]);String address = arr[3];try {// 创建反序列流FileInputStream fis = new FileInputStream("day25\\stu.txt");ObjectInputStream ois = new ObjectInputStream(fis);// 读取文件中的集合对象ArrayList<Student> list = (ArrayList<Student>) ois.readObject();// 定义一个变量,用来标记是否修改成功boolean flag = false;// 默认修改失败// 循环遍历集合中的元素for (int i = 0; i < list.size(); i++) {Student stu = list.get(i);if (stu.getId() == id){if (!"0".equals(name)){stu.setName(name);}if (!"0".equals(arr[2])){stu.setAge(age);}if (!"0".equals(address)){stu.setName(address);}flag = true;break;}}System.out.println(list);// 把修改后的集合写回文件中:如果有修改,写的就是修改后的,如果没有修改,写的还是原来的FileOutputStream fos = new FileOutputStream("day25\\stu.txt");ObjectOutputStream oos = new ObjectOutputStream(fos);oos.writeObject(list);oos.close();// 把信息写回给客户端// 通过socket对象获取输出流OutputStream os = socket.getOutputStream();if (flag == true){os.write("修改成功".getBytes());}else{os.write("修改失败".getBytes());}// 关闭连接socket.close();ois.close();} catch (Exception e) {e.printStackTrace();}}

客户端

1.客户端的菜单

public class Client {public static void main(String[] args) {// 创建Scanner对象Scanner sc = new Scanner(System.in);// 一级菜单循环显示while (true){System.out.println("******************************************************");System.out.println("1.添加学员\t2.查询学员\t3.删除学员\t4.修改学员\t5.退出");System.out.println("******************************************************");System.out.println("请输入功能序号:");int op = sc.nextInt();// 根据用户的选择执行对应的功能switch (op){case 1:// 添加break;case 2:// 查询break;case 3:// 删除break;case 4:// 修改break;case 5:// 退出System.out.println("谢谢使用,欢迎下次再来");System.exit(0);}}}
}

2.客户端的添加功能

   // 添加private static void addStudent() {// 输入要添加的学生信息Scanner sc = new Scanner(System.in);System.out.println("请输入学员姓名:");String name = sc.next();System.out.println("请输入学员年龄:");int age = sc.nextInt();System.out.println("请输入学员地址:");String address = sc.next();// 把数据按照一定格式拼接,服务器方便解析String msg = "[1]"+name+","+age+","+address;// 连接服务器try {// 创建Socket对象,连接服务器Socket socket = new Socket("127.0.0.1",8888);// 通过socket获取输出流OutputStream os = socket.getOutputStream();// 写出数据到服务器os.write(msg.getBytes());// 通过socket获取输入流InputStream is = socket.getInputStream();// 读取服务器回写的数据byte[] bys = new byte[1024];int len = is.read(bys);System.out.println(new String(bys,0,len));// 操作完了,关闭连接socket.close();} catch (Exception e) {e.printStackTrace();}}

3.客户端的查询功能

// 查询private static void selectStudent() {// 按照格式封装要传给服务器的数据String message = "[2]";try {// 创建Socket对象,连接服务器Socket socket = new Socket("127.0.0.1",8888);// 通过socket获得输出流OutputStream os = socket.getOutputStream();// 写出数据os.write(message.getBytes());// 通过socket获得输入流InputStream is = socket.getInputStream();// 转换为反序列流,读取服务器写回的集合对象ObjectInputStream ois = new ObjectInputStream(is);// 读取集合对象ArrayList<Student> list = (ArrayList<Student>) ois.readObject();if (list.size() == 0){System.out.println("没有数据");}else{for (Student stu : list) {System.out.println(stu);}}// 释放资源socket.close();} catch (Exception e) {e.printStackTrace();}}

4.客户端的删除功能

 // 删除private static void deleteStudent() {// 输入要删除学生的idScanner sc = new Scanner(System.in);System.out.println("请输入学员id:");int id = sc.nextInt();// 按照格式封装要传给服务器的数据String message = "[3]"+id;try {// 创建Socket对象,连接服务器Socket socket = new Socket("127.0.0.1",8888);// 通过socket获得输出流OutputStream os = socket.getOutputStream();// 写出数据os.write(message.getBytes());// 通过socket获得输入流InputStream is = socket.getInputStream();// 读取服务器回写的数据byte[] bys = new byte[1024];int len = is.read(bys);System.out.println(new String(bys,0,len));// 关闭连接socket.close();} catch (Exception e) {e.printStackTrace();}}

5.客户端的修改功能

// 修改private static void updateStudent() {// 输入要修改学生的idScanner sc = new Scanner(System.in);System.out.println("请输入学员id:");int id = sc.nextInt();// 按照格式封装要传给服务器的数据String message = "[5]"+id;// 连接服务器,把id发送给服务器try {// 创建Socket对象,连接服务器,Socket socket = new Socket("127.0.0.1",8888);// 通过socket获得输出流OutputStream os = socket.getOutputStream();// 写出数据os.write(message.getBytes());// 获取服务器返回结果,如果没有就结束修改,如果有,就重新连接服务器,写出要修改的数据InputStream is = socket.getInputStream();// 假设服务器返回0,表示没查询到,返回1表示查询到int len = is.read();if (len == 0){// 如果没有就结束修改System.out.println("没有改id,修改失败");socket.close();return;}else{// 断开连接socket.close();// 如果有,就重新连接服务器,写出要修改的数据try {// 输入要修改的信息System.out.println("请输入需要修改的姓名,0表示不修改:");String name = sc.next();System.out.println("请输入需要修改的年龄,0表示不修改:");int age = sc.nextInt();System.out.println("请输入需要修改的地址,0表示不修改:");String address = sc.next();// 按照格式封装要传给服务器的数据String msg = "[4]"+id+","+name+","+age+","+address;// 创建Socket对象,连接服务器,Socket socket2 = new Socket("127.0.0.1",8888);// 通过socket获得输出流OutputStream os2 = socket2.getOutputStream();// 写出数据os2.write(msg.getBytes());// 通过socket获得输入流InputStream is2 = socket2.getInputStream();// 读取服务器回写的数据byte[] bys = new byte[1024];int len2 = is2.read(bys);System.out.println(new String(bys,0,len2));// 关闭连接socket2.close();} catch (Exception e) {e.printStackTrace();}}} catch (Exception e) {e.printStackTrace();}}

6.服务器多线程

• 如果有多个客户端连接服务器,那么服务器接收请求后,应该开辟多条线程来执行不同客户端的任务

 // 由于客户端访问服务器一个功能就连接,不访问就断开,所以要循环接收客户端请求
while (true){// 接收客户端请求Socket socket = ss.accept();// 接收连接后,开辟线程执行任务new Thread(()->{// 任务代码// ....}).start();
}

工具类

1.学生类

public class Student implements Serializable {// 需要实现序列化接口private int id;// 编号private String name;// 姓名private int age;// 年龄private String address;// 地址// 构造方法public Student() {}public Student(int id, String name, int age, String address) {this.id = id;this.name = name;this.age = age;this.address = address;}// setter\getterpublic int getId() {return id;}public void setId(int id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public int getAge() {return age;}public void setAge(int age) {this.age = age;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}// 可能需要打印@Overridepublic String toString() {return "Student{" +"id=" + id +", name='" + name + '\'' +", age=" + age +", address='" + address + '\'' +'}';}
}