java socket编程在两台机器之间发送和接收文件

Question

我正在尝试使用套接字编程在两台机器之间进行通信。

我基本上需要的是两台机器都应该能够发送和接收文件。我在下面粘贴的代码没有显示任何错误，但服务器端程序似乎无限期运行，即它没有终止。它卡在标有注释的行上。

在这段代码中，最初，服务器发送名为“file.txt”的文件，客户端接收并保存名为“copy.txt”的文件。稍后客户端正在发送一个名为“file2.txt”的文件，服务器正在接收并保存名为“copy2.txt”的文件。

有人可以告诉我错误并提出一些改进建议吗？

//server side code

import java.net.*; 
import java.io.*; 
public class server 
{ 
public static void main (String [] args ) throws IOException 
{ 

    //sending file started
    ServerSocket serverSocket = new ServerSocket(16167);
    Socket socket = serverSocket.accept(); 
    System.out.println("Accepted connection : " + socket); 
    File transferFile = new File ("/Users/abhishek/desktop/file.txt"); 
    byte [] bytearray = new byte [(int)transferFile.length()]; 
    FileInputStream fin = new FileInputStream(transferFile); 
    BufferedInputStream bin = new BufferedInputStream(fin); 
    bin.read(bytearray,0,bytearray.length); 
    OutputStream os = socket.getOutputStream(); 
    System.out.println("Sending Files..."); 
    os.write(bytearray,0,bytearray.length); 
    os.flush(); 
    System.out.println("File transfer complete"); 
    //socket.close();
    //sending comleted

    //receiving file started
    int filesize=1022386; 
    int bytesRead=0; 
    int currentTot = 0;  
    byte [] bytearray1 = new byte [filesize]; 

    InputStream is = socket.getInputStream(); 

    FileOutputStream fos = new FileOutputStream("/Users/abhishek/desktop/copy2.txt"); 
    //fos.flush(); 
    BufferedOutputStream bos = new BufferedOutputStream(fos); 
    //bos.flush(); 
    System.out.println("not moving ahead!!!");//program stucked here
    bytesRead = is.read(bytearray1,0,bytearray1.length); 
    currentTot = bytesRead; 
    System.out.println("current"+currentTot); 
    do 
    { 
        bytesRead = is.read(bytearray1, currentTot, (bytearray1.length-currentTot)); 
        if(bytesRead >= 0) 
            currentTot += bytesRead; 
        System.out.println("current"+currentTot); 
    } while(bytesRead > -1); 
    System.out.println("outside current"+currentTot);
    bos.write(bytearray1, 0 , currentTot); 
    bos.flush(); 
    //receiving complete
    System.out.println("Receving file completed"); 
    socket.close(); 

} 
}



//client side code
import java.net.*; 
import java.io.*; 


 public class client 
{ 
    public static void main (String [] args ) throws IOException 
    { 
        int filesize=1022386; 
        int bytesRead=0; 
        int currentTot = 0; 
        Socket socket = new Socket("localhost",16167); 
        byte [] bytearray = new byte [filesize]; 
        InputStream is = socket.getInputStream(); 
        FileOutputStream fos = new FileOutputStream("/Users/abhishek/desktop/copy.txt"); 
        BufferedOutputStream bos = new BufferedOutputStream(fos); 
        bytesRead = is.read(bytearray,0,bytearray.length); 
        currentTot = bytesRead; 
        do 
        { 
            bytesRead = is.read(bytearray, currentTot, (bytearray.length-currentTot)); 
            if(bytesRead >= 0) 
                currentTot += bytesRead; 
        } while(bytesRead > -1); 
        System.out.println("current"+currentTot);
        bos.write(bytearray, 0 , currentTot); 
        bos.flush(); 
        bos.close(); 
        System.out.println("receiving first file completed!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!");

        //sending file
        System.out.println("sending second file started!");
        File transferFile = new File ("/Users/abhishek/desktop/file2.txt"); 
        byte [] bytearray2 = new byte [(int)transferFile.length()]; 
        FileInputStream fin = new FileInputStream(transferFile); 
        BufferedInputStream bin = new BufferedInputStream(fin); 
        bin.read(bytearray2,0,bytearray2.length); 
        OutputStream os = socket.getOutputStream();
        os.flush();
        os.write(bytearray2,0,bytearray2.length); 
        os.flush();
        System.out.println("sending second file completed!");
        //sending complete


        socket.close();
    } 
}

Answer 1

System.out.println("not moving ahead!!!");//program stucked here 行真的执行了吗？如果是这样，那么问题在于 InputStream.read() 函数是阻塞函数；他们将停止执行程序（“块”），直到他们能够完成。

来自JavaDoc for InputStream：

从输入流中读取最多 len 个字节的数据到一个字节数组中。尝试读取多达 len 个字节，但可能会读取较小的字节数。实际读取的字节数以整数形式返回。 此方法会一直阻塞，直到输入数据可用、检测到文件结尾或引发异常。

由于您没有遇到异常，这意味着当您调用 .read() 时，没有可读取的数据，并且您的程序等待读取数据（永远不会到达）。您应该首先检查您的客户端程序是否确实在发送数据。

Answer 2

我敢打赌

bytesRead = is.read(bytearray1,0,bytearray1.length);

是你真正陷入困境的地方。如果你卡在这里，通常的问题是通信的另一端没有发送任何数据，没有什么可读取的，你的线程卡在等待它发送。

在您的客户端，您调用

bos.close();

在发送第一条消息之后。这也将导致套接字关闭，这将在您的服务器端抛出一个 IOException，并且由于您没有捕获 IOException，您的服务器程序将退出。

你有多少插座经验？如果您刚开始使用套接字，您可能想查看我围绕此编写的扩展，从 ServerSocketEx 和 DataFetcher 开始。