objectreceiver.java.bak

我在学校写的assignment,是一个java-based 实时通讯工具。 用socket写的

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

public class ObjectReceiver implements Runnable{
	
	private static int port = 1234;
	//private Socket socket;
	//private ObjectInputStream objectIS;
	//private ServerSocket serversocket;
	public static boolean stopIt = false;
	public UserInterface ui= null;
	
	public ObjectReceiver(int port, UserInterface ui)
	{
		this.port = port;
		this.ui = ui;
	}
	
	public void run()
	{
		startReceiverServer();
	}
	
	public void startReceiverServer()
	{
	
  		
  		Socket socket = null;
		ObjectInputStream objectIS = null;
		ServerSocket serversocket = null;
    		
    		while (!stopIt)
    		{
    			
			try
			{
	    			serversocket = new ServerSocket(port);
				
				System.out.println("The ObjectReceiver is started.");
			
			socket = serversocket.accept();
				
				while (true)
	    			{   
	    				System.out.println("1");
					
					objectIS = new ObjectInputStream(socket.getInputStream());
	      
					message msg = (message) objectIS.readObject();
					System.out.println("Message from " + msg.getSender() + ":");
					System.out.println(msg.getString());
				//System.out.println("Token: " + msg.getToken());
				
					if (ui == null)
						System.out.println("ui is null");
					else 
						System.out.println("ui is not null");
	      				ui.insertTextToDisplay(msg.getString());
	      				System.out.println("ui finish insert text");
	      			}
	      		}
	      		catch (UnknownHostException ex) 
	      		{
	      			System.out.println("211");
	      			System.out.println(ex);
	    		}
	    		catch (IOException ex) 
	    		{
		    		System.out.println("222");
	      			System.out.println(ex);
	      		}
	     		catch (ClassNotFoundException ex) 
	     		{
		     		System.out.println("233");
	      			System.out.println(ex);
	    		}
	    		finally
	    		{
	    			try
	    			{    			
	    				if (objectIS != null)
	    					objectIS.close();
	      				if (socket!= null)
		      				socket.close();
	      				if (serversocket != null)
	      					serversocket.close();
	    			}
	    			catch(Exception ex)
	    			{
	    				//do nothing
	    			}
	    		}
	    	}
    	
    	
    	
    	}
    		
}