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

Question

我正在制作一个项目，其中一部分是关于使用 TCP 将 mp3 文件从客户端传输到服务器。我的想法是客户端通过 FileInputStream 将 mp3 转换为字节数组，连接到套接字的输出流将字节数组传递到服务器。服务器将通过套接字的输入流获取字节数组，并通过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

您的接收数据缓冲区只有 1K。我想你的 MP3 比那长。

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

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

不要通过套接字发送文件，而是尝试编写一些代码将文件复制到另一个文件夹(即从 FileInputStream 到 FileOutputStream)。一旦您可靠地工作并且掌握了流的窍门，您就可以使用相同的代码跨套接字进行写入。套接字增加了很多额外的复杂性——更多的移动部件——这使得调试变得更加困难。

缓冲区并不是严格需要的

在将文件写入输出流之前将其读入缓冲区是一种速度优化。您可以通过从 InputStream 读取并直接逐字节写入 OutputStream 来简化代码(至少在开始时)。一旦你让这个更简单的版本工作起来，如果你发现它性能不佳，你可以引入一个缓冲区。实际上，使用缓冲区可能不会产生太大区别，因为操作系统本身会进行大量抢占式缓存。

read() 应该在循环中

InputStream 上的 read() 方法返回读取的总字节数。无法保证所有字节都会被一次性读取。您应该始终将 read() 放入循环中，并使用返回的数字作为数组中的偏移量进行下一次读取，直到获得 -1 表示结束文件的内容。

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

对资源使用 try

为了确保即使抛出异常也能释放资源，您应该养成使用 try..finally block 的习惯，或者更好的是，使用 try-with-resources为您调用 close() 的 block 。

示例:

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

或更简洁的等价物与 try-with-resources block :

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

不需要flush()

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