java聊天室项目

分片上传

将大文件切分为多个小的数据块（通常大小为1MB~10MB），然后将这些小数据块分别上传至服务器，最后由服务器将这些小块组合成完整的文件。这种方式可以避免由于网络中断或超时而导致上传失败，并且能够更好地控制上传进度。

• 客户端将文件切成固定大小的块（例如每个块的大小为1MB），并为每个块生成唯一的标识符。
• 客户端逐个上传每个块到服务器。上传时，客户端将块的标识符和块数据一起发送给服务器。
• 服务器接收到每个块后，会将块数据存储到临时文件中，并在服务器端记录每个块的标识符和位置。
• 当所有块都上传完成后，客户端向服务器发送一个“合并请求”，请求服务器将所有块合并成一个完整的文件。
• 服务器接收到“合并请求”后，根据之前记录的块标识符和位置信息，将所有块合并成一个完整的文件。
• 服务器将合并后的文件存储到指定的位置，并返回上传成功的响应给客户端。
• 客户端收到上传成功的响应后，通知用户上传已完成。

 

 

private static void sendFile(File file, String filename, File selectedFile) throws IOException {LocalDateTime currentDateTime = LocalDateTime.now();DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");String formattedDateTime = currentDateTime.format(formatter); // 格式化当前日期和时间int length = 1024 * 1024 * 5;byte[] bytes = new byte[length];int number = (int) Math.ceil((double) selectedFile.length() / length);FileInputStream fileInputStream = new FileInputStream(selectedFile.getPath());message tomessage = new message(messagetype, user, markTool.filemessage, filename, formattedDateTime, chatgroup, otheruser);connection.oos.writeObject(tomessage);for (int i = 0; i < number; i++) {byte[] buffer = new byte[length];int bytesRead = fileInputStream.read(buffer);message filemessage = new message(buffer, true);connection.oos1.writeObject(filemessage);}byte[] buffer = new byte[length];int bytesRead = fileInputStream.read(buffer);message filemessage = new message(buffer, false);connection.oos1.writeObject(filemessage);System.out.println("文件发送完成，共发送了 " + number + " 个文件块。");}

文本,文件操作

服务端包括监听线程和处理收发信线程：

• 创建监听线程，监听客户端的连接。将每个连接的客户端加入维护的列表，并为每个连接的客户端开启一个处理收发信的线程。
• 在每个客户端的收发信线程中，接收每个客户端发回的消息，并对其进行转发到相应接收的客户端上，以此实现多人聊天室。
• 添加处理传输文件的判断，通过在传输的字节数组中添加标志位来区分传输的是文本消息，还是文件。

客户端包括发送消息线程和接收消息线程：

• 发送消息线程，用来处理用户的输入信息，判断输入的是文本信息还是文件，并修改传输的字节数组标志位进行区分。最后将信息传输给服务器。
• 接收消息线程，用来处理服务器发回的信息，根据标志位判断输入的是文本信息还是文件，并做相应处理。如果是文本信息，则显示在控制台，如果是文件，则保存在指定目录下。

 

 

发送文件(文件选择器)

//发送图片点击事件FileChooser fileChooser = new FileChooser();fileChooser.setTitle("选择文件");// 添加文件过滤器，仅允许选择图片文件fileChooser.getExtensionFilters().addAll(new FileChooser.ExtensionFilter("图片文件", "*.png", "*.jpg", "*.gif"));// 显示文件选择对话框并获取用户选择的文件Window stage = null;File selectedFile = fileChooser.showOpenDialog(stage);// 如果用户选择了文件，则将文件加载到ImageView中显示

将传输的字节数组写入文件

private static void sendFile(message getmessage,String path) throws IOException, ClassNotFoundException {System.out.println(path);File file = new File(path);FileOutputStream fos = new FileOutputStream(file);while (true) {message message = (message) connection.ois1.readObject();System.out.println(message.Filebytes);System.out.println(message.flag);if (!message.flag) {fos.write(message.Filebytes);fos.flush();break;}fos.write(message.Filebytes);fos.flush();}fos.close();}