黑马程序员技术交流社区

标题: 为什么程序只能发一次的输入 [打印本页]
作者: z1342802487    时间: 2014-4-30 10:36
标题: 为什么程序只能发一次的输入
本帖最后由 z1342802487 于 2014-5-2 21:31 编辑

我想写一个服务程序，接受客户端发送的语句，收到信息后向客户端发送，服务端输入bye结束服务端运行。客户端输入bye结束客户端运行。为什么我的程序只能发一次？之后就输不进去了。客户端
  1. import java.io.*;
  2. import java.net.*;
  3. public class TCPClient
  4.         {
  5.                 public static void main(String[] args)
  6.                         {
  7.                                 try
  8.                                         {
  9.                                                 Socket socket = new Socket("localhost",10002);
  10.                                                 BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
  11.                                                 PrintWriter osPrintWriter = new PrintWriter(socket.getOutputStream());
  12.                                                 BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream()));
  13.                                                 System.out.println("Client start to writing....");
  14.                                                 String readline;
  15.                                                 readline = sin.readLine();
  16.                                                 while (!readline.equals("bye"))
  17.                                                         {
  18.                                                                 osPrintWriter.println(readline);
  19.                                                                 osPrintWriter.flush();
  20.                                                                 System.out.println("Client:"+readline);
  21.                                                                 System.out.println("From Server:"+is.readLine());
  22.                                                                 readline=sin.readLine();
  23.                                                         }
  24.                                                 osPrintWriter.close();
  25.                                                 is.close();
  26.                                                 socket.close();
  27.                                         } catch (Exception e1)
  28.                                         {
  29.                                         }
  30.                         }
  31.         }
复制代码


服务端代码，
  1. import java.io.*;
  2. import java.net.*;
  3. public class TCPServer
  4.         {
  5.                 public static void main(String[] args)
  6.                         {
  7.                         try
  8.                                 {
  9.                                         ServerSocket server=null;
  10.                                         try
  11.                                                 {
  12.                                                         server=new ServerSocket(10002);
  13.                                                 } catch (Exception e)
  14.                                                 {
  15.                                                 }
  16.                                         Socket socket = null;
  17.                                         try
  18.                                                 {
  19.                                                         socket=server.accept();
  20.                                                         System.out.println("Server has started");
  21.                                                 } catch (Exception e1)
  22.                                                 {
  23.                                                 }
  24.                                         String line;
  25.                                         BufferedReader is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
  26.                                         PrintWriter os = new PrintWriter(socket.getOutputStream());
  27.                                         BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
  28.                                         System.out.println("From Client:"+is.readLine());
  29.                                         line=sin.readLine();
  30.                                         while (!line.equals("bye"))
  31.                                                 {
  32.                                                         os.print(line);
  33.                                                         System.out.println("Server:"+line);
  34.                                                         System.out.println("From Client:"+is.readLine());
  35.                                                         line=sin.readLine();
  36.                                                 }
  37.                                         os.close();
  38.                                         is.close();
  39.                                         socket.close();
  40.                                         server.close();
  41.                                 } catch (Exception e)
  42.                                 {
  43.                                         e.printStackTrace();
  44.                                 }        
  45.                         }
  46.         }
复制代码



作者: xtxiaolu    时间: 2014-4-30 22:06
亲,加一个循环白!while() 里面在加上判断语句,根据盘短语句输入跳出循环.
作者: Lin0411    时间: 2014-5-1 23:31
  1. 修正后的代码如下，没有错误。
  2. public class TCPClient
  3. {
  4.     public static void main(String[] args)
  5.     {
  6.             try
  7.             {

  9.             Socket socket = new Socket("localhost",10002);

  11.             BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));

  13.             PrintWriter osPrintWriter = new PrintWriter(socket.getOutputStream(),true);

  15.             BufferedReader is = new BufferedReader(new InputStreamReader(socket.getInputStream()));

  17.             System.out.println("Client start to writing....");
  18.             String readline;
  19.             readline = sin.readLine();

  21.             while (!readline.equals("bye"))
  22.             {
  23.                    
  24.                     osPrintWriter.println(readline);
  25.                    
  26.                 System.out.println("Client:"+readline);
  27.                
  28.                 System.out.println("From Server:"+is.readLine());
  29.                
  30.                
  31.                 readline=sin.readLine();
  32.             }

  34.            osPrintWriter.close();

  36.            is.close();

  38.            socket.close();

  40.          }
  41.          catch (Exception e1)
  42.          {
  43.                  
  44.          }
  45.         

  47.     }
  48. }

  50. public class TCPServer
  51. {

  53.     public static void main(String[] args) throws IOException
  54.     {
  55.             ServerSocket server=null;
  56.                 try
  57.                 {                       
  58.                         server=new ServerSocket(10002);
  59.                        
  60.                 }
  61.                 catch (Exception e)
  62.                 {
  63.                        
  64.                 }
  65.                        
  66.                 Socket socket = null;
  67.                 String line = null;
  68.                 BufferedReader is = null;
  69.                 PrintWriter  os = null;
  70.                 try
  71.                 {
  72.                
  73.                         socket=server.accept();               
  74.                         System.out.println("Server has started");
  75.                
  76.                 }
  77.                 catch (Exception e1)               
  78.                 {
  79.                         e1.printStackTrace();
  80.                 }
  81.                
  82.                 is=new BufferedReader(new InputStreamReader(socket.getInputStream()));
  83.                 os = new PrintWriter(socket.getOutputStream(),true);
  84.                 BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
  85.                 while (!"bye".equals(line))
  86.                 {           
  87.                         System.out.println("From Client:"+is.readLine());       
  88.                        
  89.                     line=sin.readLine();       
  90.                     System.out.println("Server:"+line);

  92.                     os.println(line);
  93.                     line = sin.readLine();
  94.                 }
  95.                 os.close();
  96.                
  97.                 is.close();
  98.                
  99.                 socket.close();
  100.                 server.close();
  101.         }
  102. }

  104. 源代码的错误可能是一些具有线程阻塞性的函数顺序放错了，导致只能发送一次便阻塞了。
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2