1. import java.net.*;
   
2. import java.io.*;
   
3. class  TCPClintSend
   
4. {
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                 Socket ds=new Socket(InetAddress.getByName("127.0.0.1"),10000);//创建tcp客户端套接字
   
8.                 InputStream in=ds.getInputStream();//获取头解字的输入流
   
9.                 BufferedReader br=new BufferedReader(new InputStreamReader(System.in));//获取键盘录入
   
10.                 String res=br.readLine();
    
11.                 PrintWriter out=new PrintWriter(ds.getOutputStream(),true);//获取套接字的输出流
    
12.                 BufferedReader brln=new BufferedReader(new InputStreamReader(ds.getInputStream()));//获取套接字的输入流
    
13.                 while ((res!=null))
    
14.                 {
    
15.                         if (res.equals("over"))
    
16.                                 break;
    
17.                         out.println(res);//向服务端发送数据
    
18.                         System.out.println(brln.readLine());//接收服务端发送回来的数据并打印出来
    
19.                 }
    
20.                 ds.close();
    
21.         }
    
22. }
    

复制代码

这是服务端代码

1. import java.net.*;
   
2. import java.io.*;
   
3. class TCPServer
   
4. {
   
5.         public static void main(String[] args) throws Exception
   
6.         {
   
7.                 ServerSocket ss=new ServerSocket(10000);//创建一个服务端套接字
   
8.                 Socket s=ss.accept();//侦听客户端套接字
   
9.                 BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));//获取客户端套接字的输入流
   
10.                 PrintWriter out=new PrintWriter(s.getOutputStream(),true);//获取客户端套接字的输出流
    
11.                 String res=br.readLine();
    
12.                 if (res!=null)
    
13.                 {
    
14.                         System.out.println(res);
    
15.                         out.println("哈哈哈，我收到了");//向客户端输出
    
16.                 }
    
17.                 s.close();
    
18.                 ss.close();
    
19.         }
    
20. }
    

复制代码

这是服务端代码


客户端和服务端取得链接之后，互相传输了一次数据之后就报了如图所示的错误了，想问问为啥？？？

• class TCPServer
• {
•         public static void main(String[] args) throws Exception
•         {
•                 ServerSocket ss=new ServerSocket(10000);//创建一个服务端套接字
•                 Socket s=ss.accept();//侦听客户端套接字
•                 BufferedReader br=new BufferedReader(new InputStreamReader(s.getInputStream()));//获取客户端套接字的输入流
•                 PrintWriter out=new PrintWriter(s.getOutputStream(),true);//获取客户端套接字的输出流
•                 String res=br.readLine();
•                 if (res!=null)
•                 {
•                         System.out.println(res);
•                         out.println("哈哈哈，我收到了");//向客户端输出
•                 }
•                s.close();服务端把连接断开了，但客户端还在读取数据
•                 ss.close();
•         }
• }
  

你这个问题出在客户端的，你在while外部完成了阻塞式读取键盘的方法，这样你在while（）里面判断res！=null是一直为真，则在循环体内会一直发送你第一次输入的内容，我把代码改成如下就好了；
while (（res=br.readLine()）!=null)
                {
                        if (res.equals("over"))
                                break;
                        out.println(res);//向服务端发送数据
                        System.out.println(brln.readLine());//接收服务端发送回来的数据并打印出来
                }