talkserversc.java

一个网上考试系统的服务器端程序

import java.net.*;
import java.io.*;


public class TalkServersc extends Thread
{
	Socket server;
	TalkServersc(){}
	TalkServersc(Socket _server)
	{
		server = _server;
	}
	public void run()
	{
		try
		{
			BufferedReader input = new BufferedReader(new InputStreamReader(server.getInputStream()));
			PrintWriter output = new PrintWriter(server.getOutputStream());

		//	BufferedReader sin = new BufferedReader(new InputStreamReader(System.in));
		while(true)
		{ 
			if(input.readLine().equals("Client>>要求发送试卷名"))
			  {
			   
			   File root = new File("./");
			   System.out.println("你的文件所在的当前路径"+root.getAbsolutePath());
			   StringBuffer fileread=new StringBuffer("");
			   String[] filelist = root.list(new FilenameFilter()
		     {
			    public boolean accept(File dir,String name)
			    {
				    if(name.endsWith(".txt"))
				    	  return true;
				     else
					     return false;
			    }
		     });
			  	for(int i=0;i<filelist.length;i++){
			  		if(i!=(filelist.length-1)){
			  		fileread.append(filelist[i]);fileread.append(",");
			  		                 }
			  		    else fileread.append(filelist[i]);
			  		}
			  		output.println(fileread.toString());
			  		output.flush();
			  	}
			  if(input.readLine().equals("Client>>要求发送试卷内容"))
			    {
			     String name=input.readLine();
			  	 FileInputStream fis=new FileInputStream(name);
		       InputStreamReader isr=new InputStreamReader(fis);
		       BufferedReader br1=new BufferedReader(isr);
		       StringBuffer fileread2=new StringBuffer("");
		       output.println(br1.readLine());
		       output.flush();
		       output.println(br1.readLine());
		       output.flush();
		       String s1=br1.readLine();
		       while((!s1.equals("endend"))){
		       	fileread2.append(s1); s1=br1.readLine();
		       	}
		       output.println(fileread2.toString());
		       output.flush();
		       br1.close();
		       output.close();
		       input.close();
		       server.close();
		       break;
			  	}
		}
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}
	public static void main(String[] args) 
	{
		try
		{
			ServerSocket ss = new ServerSocket(5000);
			while(true)
			{
				System.out.println("正在等待连接......");
				Socket server = ss.accept();
				System.out.println("成功连接，Client："+server.getInetAddress());
				new TalkServersc(server).start();
			}						
			//ss.close();	
		}
		catch (Exception e)
		{
			e.printStackTrace();
		}
	}
}