具有多線程的客戶端服務器

Question

我編寫了一個程序客戶端 - 服務器，具有多線程的發送 - 接收文件。程序運行，客戶端發送和服務器接收。文件被創建，但空的新文件被創建 爲什麼？請幫我

類客戶：

import java.io.*; 
    import java.net.Socket; 


public class Client extends Thread { 

Socket socket = null; 
Socket socket1 = null; 
    public void sendFile() throws IOException { 

String host = "127.0.0.1"; 
String host1 = "127.0.0.2"; 

socket = new Socket(host, 1024); 
socket1 = new Socket(host1, 1025); 

File file = new File("/home/reza/Desktop/link help"); 
File file1 = new File("/home/reza/Desktop/hi"); 
long length = file.length(); 
long length1 = file1.length(); 
final byte[] bytes = new byte[(int) length]; 
final byte[] bytes1 = new byte[(int) length1]; 

FileInputStream fis = new FileInputStream(file); 
FileInputStream fis1 = new FileInputStream(file1); 

@SuppressWarnings("resource") 
final BufferedInputStream bis = new BufferedInputStream(fis); 
final BufferedOutputStream out = new BufferedOutputStream(socket.getOutputStream()); 
@SuppressWarnings("resource") 
final BufferedInputStream bis1 = new BufferedInputStream(fis1); 
final BufferedOutputStream out1 = new BufferedOutputStream(socket1.getOutputStream()); 


Thread t = new Thread(new Runnable() { 



    public void run() 
{ 


while(socket.isConnected()) 
    { 

Wait2(); 


    try { 
    System.out.println("ok"); 
    int count; 

    while ((count = bis.read(bytes)) > 0) { 
     out.write(bytes, 0, count); 

    } 
} catch (IOException e) { 

e.printStackTrace(); 
} 

    } 
    } 
    }); 

    Thread t1 = new Thread(new Runnable() { 
    public void run() { 
while(socket1.isConnected()) 
    { 

    Wait2(); 

     try { 
      System.out.println("ok1"); 
      int count1; 
      while ((count1 = bis1.read(bytes1)) > 0) { 
       out1.write(bytes1, 0, count1); 

      } 


    } catch (IOException e) { 

    e.printStackTrace(); 
    } 

    } 

} 
}); 
t1.start(); 
t.start(); 




socket.close(); 
socket1.close(); 
} 

public void Wait2() 

{ 


try { 

Thread.sleep(3000); 

} catch (InterruptedException x) { 

System.out.println("Interrupted!"); 

} 

} 
} 

級服務器：

import java.io.*; 
    import java.net.*; 
public class Server { 

public Server() 
{ 
Thread t = new Thread(new Client()); 
t.start(); 
Thread t1 = new Thread(new Client()); 
t1.start();  
} 



    //@SuppressWarnings("null") 
    public void recivefile() throws IOException { 
    ServerSocket serverSocket = null; 
ServerSocket serverSocket1 = null; 


try { 

    serverSocket = new ServerSocket(1024); 


} catch (IOException ex) { 
    System.out.println("Can't setup server on this port number. "); 
} 
try { 
    serverSocket1 = new ServerSocket(1025); 

    } catch (IOException ex) { 
     System.out.println("Can't setup server on this port number1. "); 
    } 


Socket socket = null; 
Socket socket1 = null; 

InputStream is = null; 
InputStream is1 = null; 

FileOutputStream fos = null; 
FileOutputStream fos1 = null; 

BufferedOutputStream bos = null; 
BufferedOutputStream bos1 = null; 

int bufferSize = 0; 
int bufferSize1 = 0; 


try { 
    socket = serverSocket.accept(); 
    socket1 = serverSocket1.accept(); 




} catch (IOException ex) { 
    System.out.println("Can't accept client connection. "); 
} 

try { 
    is = socket.getInputStream(); 
    is1 = socket1.getInputStream(); 


    bufferSize = socket.getReceiveBufferSize(); 
    bufferSize1 = socket1.getReceiveBufferSize(); 
    //bufferSize2 = socket2.getReceiveBufferSize(); 
    System.out.println("Buffer size: " + bufferSize); 
    System.out.println("file recieved"); 
    System.out.println("Buffer size1: " + bufferSize1); 
    System.out.println("file recieved"); 

    System.out.println("file recieved"); 
} catch (IOException ex) { 
    System.out.println("Can't get socket input stream. "); 
} 


try { 
    fos = new FileOutputStream("/home/reza/Desktop/reza"); 
    bos = new BufferedOutputStream(fos); 
    fos1 = new FileOutputStream("/home/reza/Desktop/ali"); 
    bos1 = new BufferedOutputStream(fos1); 




} catch (FileNotFoundException ex) { 
    System.out.println("File not found. "); 
} 

byte[] bytes = new byte[bufferSize]; 

int count; 

while ((count = is.read(bytes)) > 0) { 
    bos.write(bytes, 0, count); 

} 
byte[] bytes1 = new byte[bufferSize1]; 

int count1; 
while ((count1 = is1.read(bytes1)) > 0) { 
     bos1.write(bytes1, 0, count1); 
    } 


bos.flush(); 
bos.close(); 
bos1.flush(); 
bos1.close(); 
is.close(); 
is1.close(); 
socket.close(); 
serverSocket.close(); 
socket1.close(); 
serverSocket1.close(); 


} 

public static void main(String[] args) throws IOException 
{ 
    System.out.println("server is run, please send file"); 



    Server s = new Server(); 
    s.recivefile(); 


} 
} 

客戶端測試類：

import java.io.IOException; 


public class clientTest extends Thread { 

public static void main(String[] args) throws IOException, InterruptedException 
{ 
    Client client = new Client(); 
    client.sendFile(); 
    } 
    } 

Answer 1

我相信這個代碼在服務器是你的問題：

while ((count = is.read(bytes)) > 0) { 
    bos.write(bytes, 0, count); 
} 
byte[] bytes1 = new byte[bufferSize1]; 

int count1; 
while ((count1 = is1.read(bytes1)) > 0) { 
    bos1.write(bytes1, 0, count1); 
} 
bos.flush(); 
bos.close(); 
bos1.flush(); 
bos1.close(); 
is.close(); 
is1.close(); 
socket.close(); 
serverSocket.close(); 
socket1.close(); 
serverSocket1.close(); 

因此，服務器已連接到客戶端，然後它立即檢查是否有任何字節要讀取，如果不是，它會停止讀取並關閉連接。如果發生這種情況的速度比客戶端可以提供任何字節快，繁榮，則不會收到任何數據。而且它會比客戶端發送數據的速度更快，因爲客戶端正在連接，然後開始線程發送數據。

只要客戶端維持連接處於活動狀態，服務器就應該在每個連接上進行讀取。服務器需要等待接收數據。

請注意，在您的代碼中，客戶端正在等待服務器關閉連接。但是，服務器應該如何知道所有數據何時發送？客戶端必須關閉連接，否則客戶端必須向服務器發送EOF類型標記，指示數據已結束，並且關閉連接是安全的。