2012-04-24 90 views
0

我一直试图解决这个错误好几天了。真。我只是不明白。代码很简单..为什么它不工作?Java中的连接重置问题

public class server 
    { 
public static void main(String[] args) 
{ 
    String fileName = null; 

    try 
    { 
     ServerSocket ss = new ServerSocket(9999, 3); 

     Socket dataSocket = ss.accept(); 
     System.out.println("Server: Connection Established"); 

     InputStream is = dataSocket.getInputStream(); 
     //BufferedReader br = new BufferedReader(new InputStreamReader(is)); 
     Scanner sc = new Scanner(dataSocket.getInputStream()); 

     while(sc.hasNextByte()) 
     { 
      System.out.println("True"); 
      fileName = fileName+sc.next(); 
     } 

     FileWriter fw = new FileWriter("server"+fileName); 
     while(dataSocket != null) 
     { 
      fw.write(is.read()); 
     } 

     fw.flush(); 
     dataSocket.close(); 
     ss.close(); 
      /*String[] nameParts; 
      nameParts = fileName.split("."); 
      File f = new File(nameParts[0]+"."+nameParts[1]); 
      FileOutputStream fos = new FileOutputStream(f); 
      System.out.println(nameParts[0]);*/ 
    } 

    catch(Exception e) 
    { 
     e.printStackTrace(); 
    } 
} 

    } 

以上是服务器代码。客户端代码如下:

public class client 
    { 
public static void main(String[] args) 
{ 
    // Read a file 
    try 
    { 
     Socket dataSocket = new Socket(); 

     dataSocket.connect(new InetSocketAddress(InetAddress.getLocalHost(), 9999)); 
     System.out.println("Client: Connection Established"); 

     OutputStream os = dataSocket.getOutputStream(); 
     PrintWriter pw = new PrintWriter(os); 

     String fileName = "text.txt"; 

     pw.write(fileName); 


     File f = new File(fileName); 
     Scanner sc = new Scanner(f); 

     /*while(sc.hasNextInt()) 
     { 
      pw.write(sc.nextInt()); 
     }*/ 

     //pw.flush(); 
     //pw.close(); 

     //dataSocket.close(); 

     /*String[] nameParts = new String[2]; 
     nameParts = args[0].split("."); 

     while(sc.hasNextByte()) 
     { 
      os.write(sc.nextByte());5 
     }*/ 
    } 

    catch (Exception e) 
    { 
     e.printStackTrace(); 
    } 
} 

    } 

起初,客户端和服务器都在等待对方说话,就像两个害羞的青少年一样。经过一些改变,这开始发生。我收到连接重置错误。请帮忙。截止日期!

回答

2

sc.hasNextByte()保持为真,直到对方关闭连接。所以你永远不会离开这个循环。您需要在文件名之前发送文件名长度,以便知道输入数据的多少是文件名。然后读取文件名,打开文件,并读取和复制流的其余部分,直到EOS。

+0

没有办法做到这一点,而不先发送名称大小?我确定有一些方法:s这是JAVA不是C:D – Asim 2012-04-25 17:56:05

+0

@Asim当然还有其他方法。例如,您可以使用'DataOutputStream.writeUTF()'和'DataInputStream.readUTF()'作为文件名。 – EJP 2012-04-26 01:20:44

0

或者,您可以用留置权下面写你的文件名:

pw.write(文件名+ “\ n”);

或者用户一些写入程序writeLine(fileName)。

而在服务器端,使用的BufferedReader按行读入行:

而(!(线= br.readLine())= NULL){

.... 

}

然后如果客户端关闭,它可以完成循环。

+0

这并不能解决我的问题:s 我想保持连接打开,以便在发送文件名后发送文件内容。 – Asim 2012-04-25 17:55:36