import java.io.*;
import java.net.*;
import java.util.*;
/**類ServerDatagram是數據報通信的服務器端程序，該程序用于實現：
當有一個客戶端連接到端口上時，就新建一個線程，該線程讀取當前
路徑下thirdFile.txt文件中的內容，每次讀取一行，將讀取的內容
通過數據報傳送到客戶端并在客戶端顯示出來*/
public class ServerDatagram{
	public static void main(String[] args){
		try{
			/*生成一個ServerDataThread類的對象，在ServerDataThread類中實現了數據報通信的服務器端處理*/
			ServerDataThread threadObj = new ServerDataThread();
			/*ServerDataThread類是Thread類的子類，因此threadObj也是一個線程對象*/
			threadObj.start();
		}catch(IOException e){}
	}
}
/**ServerDataThread類是Thread類的子類，用于進行數據報通信*/	
class ServerDataThread extends Thread{
	/*聲明一個DatagramSocket對象，初始值為null，用于數據報的接收和發送*/
	protected DatagramSocket socketObj = null;
	/*聲明一個BufferedReader類的對象，初值為null，用于創建一個輸入流*/
	protected BufferedReader buffObj = null;
	/*聲明一個布爾變量existData，用于判斷輸入流中是否還有數據*/
	protected boolean existData = true;
	/**構造方法ServerDataThread()實例化DatagramSocket對象，并創建輸入流*/
	public ServerDataThread() throws IOException{
		/*通過端口將服務器端和客戶端連接起來*/
		//socketObj = new DatagramSocket(3325);
		/*進行文件例外處理，因為有可能文件不存在*/
		try{
			/*聲明一個FileReader對象，這樣服務器端就可以對當前路徑下的thirdFile.txt文件進行讀取操作*/
			FileReader fileObj = new FileReader("thirdFile.txt");
			/*實例化BufferedReader對象，以提供文件讀取的效率*/
			buffObj = new BufferedReader(fileObj);
		}catch(FileNotFoundException e){
			System.err.println("文件對象不存在");
		}
	}
	/**方法run()實現數據報通信*/	
	public void run(){
		/*while循環用于判斷當前文件流中是否還存在數據*/
		while(existData)
		{
			try{
				/*聲明一個byte類型的數組buf，用于存放數據報中的數據*/
				byte[] buf=new byte[256];
				/*生成一個DatagramPacket對象，用于接收數據報中的數據*/
				DatagramPacket packetObj = new DatagramPacket(buf,buf.length);
				/*接收數據報*/
				//socketObj.receive(packetObj);
				/*聲明一個字符串變量tempStr*/
				String tempStr = "";
				/*聲明一個字符串變量totalStr，用于存儲文件內容*/
				String totalStr = "";
				/*根據文件流對象是否存在進行不同的處理*/
				if(buffObj == null)//文件對象不存在
					tempStr	= "This file Object doesn't exist!";
				else//文件對象存在
				{
					try{
						/*下面的if語句判斷文件是否還有數據*/
						while((tempStr = buffObj.readLine())!=null)
						{
							totalStr += tempStr+"\n";
						}
						/*沒有數據時，就將文件流關閉*/
						buffObj.close();
						/*將布爾變量賦值為false*/
						existData = false;
						/*給字符串變量賦值，表示文件流到達結尾處*/
						tempStr = "No more data in file.This is the end";
					}catch(IOException e){
						tempStr = "IOException occurred in server.";
					}
				}
				/*將字符串轉換成byte型*/
				buf = totalStr.getBytes();
				/*獲得數據報對應的IP地址*/
				InetAddress ipAddress=packetObj.getAddress();
				/*獲得數據報的端口號*/
				int portObj=packetObj.getPort();
				/*重新實例化DatagramPacket對象，用于發送數據報*/
				packetObj=new DatagramPacket(buf,buf.length,ipAddress,portObj);
				/*發送數據報*/
				socketObj.send(packetObj);
			}catch(IOException e){
				/*如果出現例外，對例外進行跟蹤，并輸出跟蹤信息*/
				e.printStackTrace();
				/*出現例外，將布爾變量existData置為false，以控制while循環*/
				existData = false;
			}
		}
		/*將數據報關閉*/
		socketObj.close();
	}
}