转载请注明出处：http://blog.csdn.net/ns_code/article/details/14642873

  书上示例

    在第一章《基本套接字》中，作者给出了一个TCP Socket通信的例子——反馈服务器，即服务器端直接把从客户端接收到的数据原原本本地反馈回去。

     书上客户端代码如下：

import java.net.Socket;
import java.net.SocketException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;public class TCPEchoClient {public static void main(String[] args) throws IOException {if ((args.length < 2) || (args.length > 3))  // Test for correct # of argsthrow new IllegalArgumentException("Parameter(s): <Server> <Word> [<Port>]");String server = args[0];       // Server name or IP address// Convert argument String to bytes using the default character encodingbyte[] data = args[1].getBytes();int servPort = (args.length == 3) ? Integer.parseInt(args[2]) : 7;// Create socket that is connected to server on specified portSocket socket = new Socket(server, servPort);System.out.println("Connected to server...sending echo string");InputStream in = socket.getInputStream();OutputStream out = socket.getOutputStream();out.write(data);  // Send the encoded string to the server// Receive the same string back from the serverint totalBytesRcvd = 0;  // Total bytes received so farint bytesRcvd;           // Bytes received in last readwhile (totalBytesRcvd < data.length) {if ((bytesRcvd = in.read(data, totalBytesRcvd,data.length - totalBytesRcvd)) == -1)throw new SocketException("Connection closed prematurely");totalBytesRcvd += bytesRcvd;}  // data array is fullSystem.out.println("Received: " + new String(data));socket.close();  // Close the socket and its streams}
}

书上的服务器端代码如下：

import java.net.*;  // for Socket, ServerSocket, and InetAddress
import java.io.*;   // for IOException and Input/OutputStreampublic class TCPEchoServer {private static final int BUFSIZE = 32;   // Size of receive bufferpublic static void main(String[] args) throws IOException {if (args.length != 1)  // Test for correct # of argsthrow new IllegalArgumentException("Parameter(s): <Port>");int servPort = Integer.parseInt(args[0]);// Create a server socket to accept client connection requestsServerSocket servSock = new ServerSocket(servPort);int recvMsgSize;   // Size of received messagebyte[] receiveBuf = new byte[BUFSIZE];  // Receive bufferwhile (true) { // Run forever, accepting and servicing connectionsSocket clntSock = servSock.accept();     // Get client connectionSocketAddress clientAddress = clntSock.getRemoteSocketAddress();System.out.println("Handling client at " + clientAddress);InputStream in = clntSock.getInputStream();OutputStream out = clntSock.getOutputStream();// Receive until client closes connection, indicated by -1 returnwhile ((recvMsgSize = in.read(receiveBuf)) != -1) {out.write(receiveBuf, 0, recvMsgSize);}clntSock.close();  // Close the socket.  We are done with this client!}/* NOT REACHED */}
}

       示例程序当然运行无误，运行结果如下：

 

   问题的引出

     首先明确几点：

     1、客户端与服务器端在接收和发送数据时，read（）和write（）方法不一定要对应，比如，其中一方可以一次发送多个字节的数据，而另一方可以一个字节一个字节地接收，也可以一个字节一个字节地方送，而多个字节多个字节地接收。因为TCP协议会将数据分成多个块进行发送，而后在另一端会从多个块进行接收，再组合在一起，它并不仅能确定read（）和write（）方法中所发送信息的界限。

     2、read（）方法会在没有数据可读时发生阻塞，直到有新的数据可读。

     注意客户端中下面部分代码

while (totalBytesRcvd < data.length) {if ((bytesRcvd = in.read(data, totalBytesRcvd,data.length - totalBytesRcvd)) == -1)throw new SocketException("Connection closed prematurely");totalBytesRcvd += bytesRcvd;
}  // data array is full

 客户端从Socket套接字中读取数据，直到收到的数据的字节长度和原来发送的数据的字节长度相同为止，这里的前提是已经知道了要从服务器端接收的数据的大小，如果现在我们不知道要反馈回来的数据的大小，那么我们只能用read方法不断读取，直到read（）返回-1，说明接收到了所有的数据。我这里采用一个字节一个字节读取的方式，代码改为如下：

while((bytesRcvd = in.read())!= -1){data[totalBytesRcvd] = (byte)bytesRcvd;totalBytesRcvd++;
} 

    这时问题就来了，输出结果如下：

      客户端没有数据打印出来，初步推断应该是read（）方法始终没有返回-1，导致程序一直无法往下运行，我在客客户端执行窗口中按下CTRL+C，强制结束运行，在服务器端抛出如下异常：