5.12学习总结

一.JAVA聊天室项目

文件发送

使用 Java Socket 实现聊天内容或文件的传输的原理如下：

服务器端启动：聊天室的服务器端在指定的端口上监听客户端的连接。它创建一个 ServerSocket 对象，并通过调用 accept() 方法等待客户端的连接请求。
客户端连接：聊天室的客户端通过创建一个 Socket 对象并指定服务器的地址和端口，与服务器建立连接。客户端和服务器之间的连接建立后，可以进行数据传输。
服务器端接收消息：当客户端连接到服务器后，服务器会为每个客户端创建一个独立的线程，用于处理与该客户端的通信。在服务器端的线程中，通过调用输入流的 readLine() 方法读取客户端发送的消息。服务器可以根据接收到的消息类型（例如普通消息或文件传输请求），采取相应的处理逻辑。
服务器端广播消息：服务器在接收到客户端发送的消息后，可以将该消息广播给其他连接到服务器的客户端。通过遍历保存所有客户端的列表，并调用相应客户端的输出流发送消息给客户端。
客户端发送消息：客户端可以通过输出流向服务器发送消息。客户端将消息写入输出流，然后通过网络发送给服务器。
客户端接收消息：客户端在一个独立的线程中通过输入流不断监听服务器端的消息。通过调用输入流的 readLine() 方法读取服务器端发送的消息，并进行相应的处理，如将消息显示在用户界面上。
文件传输：客户端可以通过输入流读取文件内容，并通过输出流将文件数据发送给服务器。服务器在接收到文件数据后，可以将文件广播给其他客户端。

以上就是使用 Java Socket 实现简易多人聊天室传输聊天内容或文件的基本原理。通过建立客户端和服务器之间的连接，以及使用输入流和输出流进行数据的读写，可以实现实时的聊天和文件传输功能。

实现代码:

1.首先用文件选择器选择文件,将文件分片传送到服务端

private static void sendFile(File file, String filename, File selectedFile) throws IOException {
        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, null, 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.oos.writeObject(filemessage);
        }
        byte[] buffer = new byte[length];
        int bytesRead = fileInputStream.read(buffer);
        message filemessage = new message(buffer, false);
        connection.oos.writeObject(filemessage);
        System.out.println("文件发送完成，共发送了 " + number + " 个文件块。");
    }

2.服务端接收到文件,并将文件下载到服务端,将下载的地址保存到数据库中

else if (mge1.messagetip.equals(markTool.filemessage)) {
                        Thread threadB = new Thread(new Runnable() {
                            @Override
                            public void run() {
                                try {
                                    String path = "E:\\server\\src\\file" + "\\" + mge1.Textmessage;
                                    File file = new File(path);
                                    FileOutputStream fos = new FileOutputStream(file);
                                    while (true) {
                                        message getmessage = (message) ois.readObject();
                                        if (!getmessage.flag) {
                                            fos.write(getmessage.Filebytes);
                                            fos.flush();
                                            break;
                                        }
                                        fos.write(getmessage.Filebytes);
                                        fos.flush();
                                    }
                                    fos.close();
                                    // 更新聊天记录
                                    message getmessage = new message();
                                    new add(mge1, getmessage).addchattingrecords("filemessage", path, formattedDateTime);
                                } catch (IOException | ClassNotFoundException e) {
                                    e.printStackTrace();
                                }
                            }
                        });
                        threadB.start();
                        try {
                            threadB.join();
                        } catch (InterruptedException e) {
                            throw new RuntimeException(e);
                        }
                    }

3.下载文件同理,从服务器中数据库找到下载的路径,找到文件,再传递给客户端,客户端在通过用户选择文件路径下载.

二.聊天室项目构思