TCP程序阻塞在读取另一方信息的代码上

0 0

TCP程序阻塞在读取另一方信息的代码上10

问题在客户端代码中（ instr=reader.readLine(); //阻塞在这一行代码上！！）

请教各位有经验的熟手们，最好能带修改后的代码和解释！不甚感激，新手致~

/***************
服务端
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class SeverSocketTest {
public static void main(String[] args){
  ServerSocket ss;
  try {
   ss = new ServerSocket(64440);
   System.out.println("服务器已在监听");
   Socket s = ss.accept();
   InputStream in=s.getInputStream();
   BufferedReader reader=new BufferedReader(new InputStreamReader(in));
   OutputStream out=s.getOutputStream();
   PrintWriter writer=new PrintWriter(out);
   BufferedReader selfReader=new BufferedReader(new InputStreamReader(System.in));
   String instr;
   String outstr;

    do{
       System.out.printf("server:");
       outstr=selfReader.readLine();
       writer.write(outstr);
       writer.flush();//强制输出，即发送消息
       System.out.println("clint:");
       instr= reader.readLine();
       System.out.println(instr);
    }
    while(!outstr.contentEquals("bye"));
    reader.close();
    selfReader.close();
     writer.close();
     s.close();
     ss.close();

   } catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }





  }
}
/****************************
客户端
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

public class SocketTest {

public static void main(String[] args){

   try { InetAddress addr = null;
      addr = InetAddress.getByAddress(new byte[]{127,0,0,1});
      Socket s=new Socket(addr,64440);
      InputStream in=s.getInputStream();
      BufferedReader reader=new BufferedReader(new InputStreamReader(in));
      OutputStream out=s.getOutputStream();
      PrintWriter writer=new PrintWriter(out);
      BufferedReader selfReader=new BufferedReader(new InputStreamReader(System.in));
      String outstr;
      String instr;
   do{
      System.out.println("server:");
      instr=reader.readLine();   //阻塞在这一行代码上！！
   System.out.println(instr);
      System.out.printf("clint:");
      outstr=selfReader.readLine();
   writer.write(outstr);
   writer.flush();//强制输出，即发送消息

   } while(!outstr.contentEquals("bye"));
reader.close();
selfReader.close();
writer.close();
s.close();

  } catch (IOException e) {
   // TODO Auto-generated catch block
   e.printStackTrace();
  }

}
}