Java TCP/IP Socket 学习总结 (二)

java为TCP协议提供了两个类：Socket和ServerSocket。一个Socket实例代表了一个TCP连接的一端。一个TCP连接(TCP connection)是一条抽象的双向通道，两端分别由IP地址和端口号确定。在开始通信之前，要建立一个TCP连接，这需要先由客户端TCP向服务器端TCP发送连接请求。ServerSocket实例则监听TCP连接请求，并为每个请求创建新的Socket实例。也就是说，服务器端要同时处理ServerSocket实例和Socket实例，而客户端只需要使用Socket实例。

典型的TCP客户端要经过下面三步：  
   1、创建一个Socket实例：构造函数向指定的远程主机和端口建立一个TCP连接。
   2、通过套接字的输入输出流(I/O Stream)进行通信：一个Socket连接实例包括一个InputStream和一个OutputStram。
   3、使用Sokcet类的close()方法关闭连接。

	
	private static final int BUFFER_SIZE = 32;
	
	public static void main(String[] args) throws IOException{
		
		String server = "127.0.0.1";
		int serverPort = 7777;
		
		Socket socket = new Socket(server,serverPort);
		
		InputStream in = socket.getInputStream();
		OutputStream out = socket.getOutputStream();
		
		byte[] data = "test".getBytes();
		out.write(data);
		
		byte[] ib = new byte[BUFFER_SIZE];
		while(in.read(ib) != -1){
			System.out.println("client： " +new String(ib));
		}
		
		socket.close();
	}
}

服务器端的工作是建立一个通信终端，并被动地等待客户端的连接。典型的TCP服务器执行如下两步工作：
   1、创建一个ServerSocket实例并指向本地端口。此套接字的功能是监听该指定端口收到的连接。
   2、重复执行;    
      a、调用ServerSocket的accept()方法以获取下一个客户端连接。基于新建立的客户端连接，创建一个Socket实例，并由accept()返回。     
      b、使用所返回的Socket实例的InputStream和OutputStream与客户端进行通信。     
      c、通信完成后，调用Socket类的close()方法关闭客户端套接字连接。

public class TCPEchoServer {
	
	private static final int BUFFER_SIZE = 40;
	
	public static void main(String[] args) throws IOException{
		
		int serverPort = 7777;
		ServerSocket serverSocket = new ServerSocket(serverPort);
		
		byte[] ib = new byte[BUFFER_SIZE];
		byte[] ob = "hello".getBytes();
		System.out.println("Server start ....." );
		
		while(true){
			Socket socket = serverSocket.accept();
			System.out.println("Handling Server at " + socket.getLocalSocketAddress());
			System.out.println("Handling client at " + socket.getRemoteSocketAddress());
			
			InputStream in = socket.getInputStream();
			OutputStream out = socket.getOutputStream();
			
			while(in.read(ib) != -1){
				System.out.println("server :" + new String(ib));
				out.write(ob);
			}
			socket.close();
		}
	}
}