serverpoint.java

socket线程处理,进行多线成处理程序。

package hall;
import java.net.*;
import java.util.*;
import java.io.*;

/**-----------------------------------
* <br>功能概述：服务器监听线程
------------------------------------*/
public class ServerPoint extends Thread{
	static int SERVERPORT = 8088;
 	
 	public ServerPoint(){
	}//ServerPoint()

	public void run(){
		ClientThread.log("服务器端程序启动....");
		try{
		ServerSocket server = new ServerSocket (SERVERPORT);
		//保持监听
		while(true){
			Socket client = server.accept();		                
		        //创造一个线程
		        ClientThread ct = new ClientThread(client);
		        ct.start();
		}
		}
		catch( Exception e ){
			ClientThread.log("服务器端程序关闭....");
		        System.exit(0);
		}
	}//run()
	
	public static void main(String arg[]){
		ServerPoint sp = new ServerPoint();
		sp.start();	
	}//main()
}/** ServerPoint */

/**-----------------------------------
* <br>功能概述：实现和一个客户的对话线程
------------------------------------*/
class ClientThread extends Thread{
	private Socket s;
	public ClientThread(Socket s){
		this.s = s;
	}//ClientThread()
	
	public void run(){
		try{
		//接收消息流对象
		BufferedReader brSocketReader = new BufferedReader(
			new InputStreamReader(s.getInputStream()));
		//发送消息流对象
		PrintWriter pwSocketWriter = new PrintWriter(
	      		new OutputStreamWriter(s.getOutputStream()),true);
		String strGetMSG = brSocketReader.readLine();
		log("客户端发送来的信息是:" + strGetMSG);
		//发送反馈信息
		pwSocketWriter.println(getFeedBackInfo(strGetMSG));
	
 		brSocketReader.close();
 		pwSocketWriter.close();
 		s.close();
 		}
 		catch(Exception e){
 			e.printStackTrace();
 		}
	}//run()
	
	static void log(String strInfo){
		System.out.println(strInfo);
	}//log()
	
	public String getFeedBackInfo(String strInfo){
		String s = "";
		for(int i=strInfo.length()-1;i>=0;i--){
			s += String.valueOf(strInfo.charAt(i));
		}
		log("反馈信息是：" + s);
		return s;
	}//getFeedBackInfo()
}/** ClientThread */