Java多線程編程實現(xiàn)socket通信示例代碼

　Socket(InetAddress address, int port);
　　Socket(InetAddress address, int port, boolean stream);
　　Socket(String host, int prot);
　　Socket(String host, int prot, boolean stream);
　　Socket(SocketImpl impl)
　　Socket(String host, int port, InetAddress localAddr, int localPort)
　　Socket(InetAddress address, int port, InetAddress localAddr, int localPort)
　　ServerSocket(int port);
　　ServerSocket(int port, int backlog);
　　ServerSocket(int port, int backlog, InetAddress bindAddr)

package me.socketthread;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
public class MultiSocketServer {
	public static void main(String[] args) {
		ServerSocket s = null;
		Socket socket = null;
		try {
			s=new ServerSocket(4567);
			System.out.println("ServerSocket Start:"+s);
			//等待請求,此方法會一直阻塞,直到獲得請求才往下走 
			socket=s.accept();
			System.out.println("得到客戶端地址:"+socket.getInetAddress());
			//調(diào)用線程類
			new ServerSocketThread(socket).start();
		}
		catch (Exception e) {
			try {
				socket.close();
			}
			catch (IOException e1) {
				// TODO Auto-generated catch block 
				e1.printStackTrace();
			}
		}
		finally{
			try {
				s.close();
			}
			catch (IOException e) {
				// TODO Auto-generated catch block 
				e.printStackTrace();
			}
		}
	}
}

package me.socketthread;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class ServerSocketThread extends Thread{
	private Socket socket = null;
	private BufferedReader br = null;
	private PrintWriter pw = null;
	//聲明構(gòu)造函數(shù),接收客戶端請求socket
	public ServerSocketThread(Socket s)
	 {
		this.socket=s;
	}
	@Override
	 public void run() {
		//while(true){ 
		try {
			//注意此處得到的socket的輸入流為socket的輸入流即上方的(private Socket socket = null; )
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			//向客戶端返回消息的PrintWriter對象
			pw=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			String str = br.readLine();
			/* if(str.equals("END")){ 
     br.close(); 
     pw.close(); 
     socket.close(); 
     break; 
    } */
			System.out.println("Client Socket Message:"+str);
			pw.println("Message Received");
			pw.flush();
		}
		catch (Exception e) {
			try {
				br.close();
				pw.close();
				socket.close();
			}
			catch (IOException e1) {
				// TODO Auto-generated catch block 
				e1.printStackTrace();
			}
		}
		// }
	}
}

package me.socketthread;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
public class MultiClientSocket {
	public static void main(String[] args) {
		Socket socket = null;
		BufferedReader br = null;
		PrintWriter pw = null;
		try {
			socket=new Socket("127.0.0.1",4567);
			System.out.println("Socket=" + socket);
			//用于發(fā)送給server端的信息
			pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			//用于接收Server端發(fā)來的信息 
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			// for (int i = 0; i < 10; i++) {
			//注意首先向服務(wù)端發(fā)送消息,再接收服務(wù)端返回的休息,不要寫反了
			pw.println("howdy ");
			pw.flush();
			//flush()一般用于處理中時需要將數(shù)據(jù)立即寫出。將緩沖區(qū)的內(nèi)容輸出
			String str = br.readLine();
			System.out.println("拿到server返回的消息:"+str);
			// } 
			// pw.println("END"); 
			// pw.flush();
		}
		catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		finally {
			try {
				System.out.println("close......");
				br.close();
				pw.close();
				socket.close();
			}
			catch (IOException e) {
				// TODO Auto-generated catch block 
				e.printStackTrace();
			}
		}
	}
}

ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567]

Socket=Socket[addr=/127.0.0.1,port=4567,localport=55258]
拿到server返回的消息:Message Received
close......

ServerSocket Start:ServerSocket[addr=0.0.0.0/0.0.0.0,localport=4567]
得到客戶端地址:/127.0.0.1
Client Socket Message:howdy