我应该如何正确地将 mp3 转换为字节数组，然后将其转换回 mp3

Question

我正在做一个项目，其中一部分是关于使用 TCP 将 mp3 文件从客户端传输到服务器。我的想法是，客户端通过 FileInputStream 将 mp3 转换为字节数组，连接到套接字的输出流将字节数组传递给服务器。服务器通过socket的Input Stream获取字节数组，并通过FileOutputStream将其转换回mp3文件。

但是，我有两个问题。首先，程序运行正常，但是服务器转换的最终mp3文件是一个空文件，只有1个字节，而FileOutputStream接收和使用的字节数组不是空的。当我的服务器试图将字节数组转换回 mp3 时，我知道肯定有问题，因为只使用 FileOutputStream 似乎太容易了，我可能误解了它的功能，所以我想知道如何从套接字正确接收字节数组。

其次，我尝试比较了两个程序中的字节数组，发现它们是不同的。其中一部分是相同的，但大部分是不同的，尤其是字节数组的开头和结尾，我不确定为什么。我对如何从套接字使用 InputStream 和 OutputStream 有概念上的问题吗？

这是发送 mp3 的客户端代码的一部分：

public static void sendPackets(){
        System.out.println("Sending test file...");
        try{
            while (active){
                File file = new File("Sorrow.mp3"); // Sorrow.mp3 is the local mp3 music needs to be sent
                FileInputStream loc = new FileInputStream(file);
                sendData = new byte[(int)file.length()];
                loc.read(sendData);
                //socket_tcp is a Socket object connecting to the server
                OutputStream fis = socket_tcp.getOutputStream(); 
                fis.write(sendData);
                fis.flush();
                fis.close();
                break;
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

这是服务器的代码，它接收字节数组并将其转换回 mp3：

/** This is the function for the thread listening and receiving the music
  * active is a boolean value tracking whether the server is suppose to keep running or not
 **/

public static void listen() {
        while (active) {
            try {
                //Wait until packet is received
                // listenSocket is a ServerSocket specific for this thread
                socket = listenSocket.accept();
                System.out.println("We got music from the client!");
                File file = new File("Song.mp3");
                InputStream is = socket.getInputStream();
                receiveData = new byte[1024];
                is.read(receiveData);
                System.out.println(Arrays.toString(receiveData));
                FileOutputStream fos = new FileOutputStream(file);
                fos.write(receiveData);
                fos.flush();
                fos.close();

            } catch (IOException e) {
                if(active) {
                    listen();
                } else {
                    break;
                }
            }
        }

我是这个社区的新手，所以如果我在提问时有任何错误，请告诉我，谢谢！感谢您的帮助！

Answer 1

我没有尝试调试您的确切问题，但我有一些意见。

你的receiveData缓冲区只有1K

你的receiveData缓冲区只有1K。我想你的 MP3 比那个长。

receiveData = new byte[1024];
is.read(receiveData);

首先以更简单的方式试验流

与其通过套接字发送文件，不如尝试编写一些代码将文件复制到另一个文件夹（即从 FileInputStream 到 FileOutputStream）。一旦你让它可靠地工作，并且你掌握了流的窍门，你就可以使用相同的代码通过套接字进行写入。套接字增加了很多额外的复杂性——更多的活动部件——这使得事情更难调试。

缓冲区不是严格需要的

在将文件写入输出流之前将文件读入缓冲区是一种速度优化。您可以通过从 InputStream 读取并直接逐字节写入 OutputStream 来简化代码（至少在开始时如此）。一旦你得到了那个更简单的版本，如果你发现它性能不佳，你可以引入一个缓冲区。实际上，使用缓冲区可能不会有太大区别，因为操作系统本身会进行大量先发制人的缓存。

read() 应该在循环中

read() 方法对 InputStream return 读取的字节总数。不能保证所有字节都将被一次性读取。你应该总是把 read() 放在一个循环中，并使用数字 returned 作为数组的偏移量以供下一次读取，直到你得到 -1 来表示文件结束。

byte[] buffer = new byte[bufferSize];
int bytesRead = 0;
while ((bytesRead = input.read(buffer)) != -1) {
    output.write(buffer, 0, bytesRead);
}

尝试使用资源

为了确保即使在抛出异常时也能释放资源，您应该养成使用 try..finally 块的习惯，或者更好的是，调用 [=21] 的 try-with-resources 块=] 给你。

示例：

FileOutputStream fos = new FileOutputStream(file);
try {
    fos.write(receiveData);
} finally {
    fos.close();
}

或者更简洁的 try-with-resources 块：

try (FileOutputStream fos = new FileOutputStream(file)) {
    fos.write(receiveData);
}

不需要flush()

不需要flush()和close()。后者在关闭流之前自动刷新。