sockclient.java

来自「Lucene+nuctch一书的全部源码 测试源码 和几个简单的项目」· Java 代码 · 共 63 行

package chapter10;

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;

class SockClient extends Thread{
	private Socket socket;
	private BufferedReader in;
	private PrintWriter out;
	private  int counter =0;
	private int id= counter++;
	private static int threadcount=0;
	final int port=5000;
	
	public  static int threadCount(){
		return threadcount;
	}
	
	public SockClient(InetAddress addr){
		System.out.println("Making client:"+id);
		threadcount++;
		try{
			socket=new Socket(addr,port);
		}catch(IOException e){
		}
		try{
			in=new BufferedReader(
			new InputStreamReader(
			socket.getInputStream()));
			out=new PrintWriter(
					new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),true);  
			start();
		}catch(IOException e){
			try{
				socket.close();
			}catch(IOException e2){}
		}
	}
	
	public void run(){
	try{
		for (int i=0;i<25;i++){
		out.println("Client:"+id+":"+i);
		String str=in.readLine();
		System.out.println(str);
		}
		out.println("END");
	}catch(IOException e){
	}finally{
		try{
			socket.close();
		}catch(IOException e){}
		threadcount--;
		}
	}
}