Java网络通信套接字

（一）第一个例子是简单的Socket通信，一个客户端和一个服务器线程：

/**
 * SimpleClient.java
 */
package network;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class SimpleClient {

	public static void main(String[] args) {
		Socket socket = null;
		BufferedReader reader = null;
		PrintWriter writer = null;
		try {			
			//请求建立通信套接字
			socket  = new Socket("localhost",8089);
			
			//获取输入输出流
			reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			writer = new PrintWriter(socket.getOutputStream(), true);	//true means autoFlush 
			
			//while(true){
				writer.println("hello, I am Client\n");
				String mess = reader.readLine();
				System.out.print("Client Receive:"+mess);
			//}
			
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			try {
				if(socket != null) socket.close();
				if(reader != null) reader.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
			if(writer != null) writer.close();
		}
	}
}

/**
 * SimpleServer.java
 */
package network;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class SimpleServer {

	public static void main(String[] args) {
		ServerSocket ss = null;	//用于接收请求的Socket
		Socket socket = null;	//用于通信的Socket
		BufferedReader reader = null;
		PrintWriter writer = null;
		
		try {
			
			ss = new ServerSocket(8089);
			System.out.print("waiting for new request...\n");
			socket = ss.accept();	//等待请求，建立通信Socket
			
			reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			writer = new PrintWriter(socket.getOutputStream(), true);
			
			String mess = reader.readLine();
			System.out.print("Server Receive:"+mess);
			writer.println("Yes, I can hear you");
			
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

（二）第二个列子是在服务器端，采用多线程方式处理来自客户端的请求：

/**
 * TCPClient.java
 */
package network;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class TCPClient {
	private static int id = 0;
	
	public static void main(String[] args) {
		
		String host = "localhost";
		int port = 8060;
		Socket socket = null;
		BufferedReader in = null;
		PrintWriter out = null;
		
		try {
			
			//创建五个请求服务器连接的客户端
			for(int i=0;i<5;i++){
				
				//创建通信套接字
				socket = new Socket(host, port);
				
				//获取套接字的输入输出流
				in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				out = new PrintWriter(socket.getOutputStream(), true);
				
				//向服务器发送消息
				out.println("hello, i am client "+(++id));
			}
			
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			
			System.out.print("Closing Socket...\n");
			try {
				if(socket != null) socket.close();
				if(in != null) in.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
			if(out != null) out.close();
		}
	}
}

/**
 * TCPServer.java
 */
package network;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class TCPServer {
	public static void main(String[] args) {

		int port = 8060;
		Socket socket = null;
		ServerSocket server = null;
		
		try {			
			//创建服务器套接字
			server = new ServerSocket(port);
			
			while(true){
				
				//接收来自客户端的请求，建立通信套接字
				System.out.print("waiting for new request...\n");
				socket = server.accept();
				
				//创建一个线程处理该请求
				Thread t = new Thread(new ServerThread(socket));
				t.start();
			}
			
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			
			try {
				if(server != null) server.close();
				if(socket != null) socket.close();
			} catch (IOException e) {
				e.printStackTrace();
			}			
		}
	}
}

/**
 * 处理来自客户端请求的线程
 * */
class ServerThread implements Runnable{
	private Socket socket;
	
	public ServerThread(Socket s){
		this.socket = s;
	}
	
	public void run() {
		BufferedReader in = null;
		PrintWriter out = null;
		
		try {
			//获取套接字的输入输出流
			in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			out = new PrintWriter(socket.getOutputStream(), true);
			
			//读取客户端发送来的消息
			String s = in.readLine();
			System.out.println("recv:"+s);
			//out.write("accept");
			
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			
			System.out.print("Closing Connection...\n");
			try {
				if(socket != null) socket.close();
				if(in != null) in.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
			if(out != null) out.close();
		}		
	}	
}