socket学习笔记之五：socket构建多线程通信程序

　下面是原代码，比较简单的功能，提供个参考和入门学习。

１服务器侦听代码：

package test;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class ThreadServer {

	final static int portNo=4444;
	public static void main(String[] args) {
		ServerSocket serverSocket = null;
		try {
		    serverSocket=new ServerSocket(portNo);
			System.out.println("The Server is start:"+serverSocket);
			
			while(true){
				Socket socket=serverSocket.accept();
				new ServerThreadCode(socket);
			}
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			
			try {
				serverSocket.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		
		 
	}

}

 ２服务器逻辑实现代码

package test;

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 ServerThreadCode extends Thread {

	private Socket socket;
	private BufferedReader sin;
	private PrintWriter pw;

	public ServerThreadCode() {
	}

	public ServerThreadCode(Socket s) {
		this.socket = s;
		try {
			sin = new BufferedReader(new InputStreamReader(socket
					.getInputStream()));
			pw = new PrintWriter(new BufferedWriter(new OutputStreamWriter(
					socket.getOutputStream())), true);
			this.start();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	public void run() {
		try {
			
			for (;;) {
				String str = sin.readLine();
				if("byebye".equalsIgnoreCase(str)){
					break;
				}
				System.out.println("In Server the info"+str);
				pw.println(str);
			}
			System.out.println("closing the server socket!");
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}finally{
			System.out.println("close the server socket and the io.");
			try {
				socket.close();
			} catch (IOException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}

	}

}

 ３客户端代码

package test;

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.InetAddress;
import java.net.Socket;

public class ClientThreadCode extends Thread {
	private Socket socket;
	private static int cnt=0;
	private int clientId=cnt++;
	private BufferedReader in;
	private PrintWriter out;
	
	public ClientThreadCode(InetAddress inet){
		try {
			socket=new Socket(inet,4444);
		} catch (IOException e) {
			e.printStackTrace();
		}
		
		try {
			in=new BufferedReader(new InputStreamReader(socket.getInputStream()));
			out=new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);
			this.start();
		} catch (IOException e) {
			e.printStackTrace();
		}
		
		
	}
	public void  run(){
		String str;
		try {
			out.println("Hello Server,My Id is:"+clientId);
			str = in.readLine();
			System.out.println(str);
			out.println("byebye");
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			try {
				socket.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	
		
	}
}

 ４调用客户端的代码

package test;

import java.net.InetAddress;
import java.net.UnknownHostException;

public class ThreadClient {

	public static void main(String[] args) {
		int threadNo=0;
		InetAddress addr;
		try {
			addr = InetAddress.getByName("localhost");
			for(threadNo=0;threadNo<3;threadNo++){
				new ClientThreadCode(addr);
			}
		} catch (UnknownHostException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		
	}

}