objectsender.java

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

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


public class ObjectSender{
	
	private String hostname = "169.254.47.181";
	private int port = 1234;
 	private message outputMessage = null;
	private Socket socket = null;
	private ObjectOutputStream objectOS = null;
        		
        		
	public ObjectSender(String hostname, int port)
	{
		this.hostname = hostname;
		this.port = port;
	}
	

		
    	public void startSendService()
    	{
    		try
    		{
    			System.out.println("startSendService");
    			socket = new Socket(hostname, port);
    			objectOS = new ObjectOutputStream(socket.getOutputStream());
    			
    		}
    		catch (Exception e )
    		{
    			System.out.println(e);
    			System.out.println("Cannot connect");
    		}
    	}
    
    
	public void sendObject(String text)
	{
	
 

    		try 
    		{
			
      			outputMessage = new message();	
			System.out.println("1");
			
      			outputMessage.setSender(InetAddress.getLocalHost().toString());
      			
      			System.out.println("2");
      			outputMessage.setString(text);
            		System.out.println("3");
      				
      		
      			System.out.println("4");
      			//synchronized(objectOS)
      			//{
      			System.out.println("4.5 " + text);
      			System.out.println("send to host : " + hostname + "  at port : " + port);
      			if (objectOS == null)
      				System.out.println("objectOS is null");
      				objectOS.writeObject(outputMessage);
      			//}
      			System.out.println("5");
      		

		}	
		catch (UnknownHostException ex) {
			System.out.println(ex);
			System.out.println("ABC");
		}
		catch (IOException ex) {
			System.out.println(ex);
			System.out.println("DEF");
		}
		finally 
		{
			try
			{
				/*
				if (objectOS != null)
				{
					objectOS.close();
				}
				if (socket != null)
				{
					socket.close();
				}
				*/
			}
			catch(Exception e )
			{
				//do nothing
			}
		}	
			
    	
  	}
}