quoteserverthread.java

贪食蛇的实现源码

package com.henry.networkings;

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

public class QuoteServerThread extends Thread{

	/**
	 * @param args
	 */
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		DatagramSocket socket=null;
		BufferedReader in = null;
		
		boolean moreQuotes = true;
		public QuoteServerThread()throws IOException{
			this("QuoteServerThread");
		}
		
		public QuoteServerThread(String name)throws IOException{
			super(name);
			socket = new DatagramSocket(4445);
			
			try{
				in = new BufferedReader(new FileReader("one=liners.txt"));
				
			}catch(Exception e){
				e.printStackTrace();
			}
		}
	
	}

	public void run(){
		while(moreQuotes){
			try{
				byte[] buf = new byte[256];
				DatagramPacket packet = new DatagramPacket(buf,buf.length);
				
				socket.receive(packet);
				
				String dString = null;
				if(in == null){
					dString=new Date().toString();
				}else{
					dString=getNextQuote();
				}
				buf=dString.getBytes();
				InetAddress address = packet.getAddress();
				
				int port = packet.getPort();
				
				packet = new DatagramPacket(buf,buf.length,address,port);
				socket.send(packet);
			}catch(Exception e){
				moreQuotes=false;
			}
		}
		socket.close();
	}


protected String getNextQuote(){
	String returnValue=null;
	try{
		if((returnValue=in.readLine())==null){
			in.close();
			moreQuotes=false;
			returnValue="No more quotes Goodbye";
		}
	}catch(Exception e){
		e.printStackTrace();
		returnValue="IOException occurred in server";
	}
	return returnValue;
}
}