echoobjectserver.java

java 完全探索的随书源码

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

public class EchoObjectServer
{
  public static final int PORT = 7;

  // Default Constructor
  public EchoObjectServer()
  {
    super();
  }

  public void startEcho()
  {
    Socket clientSocket = null;

    try
    {
      // Create a Server Socket on the
      ServerSocket server = new ServerSocket( PORT );
      // Wait for a single client to connect
      System.out.println( "Waiting on a client to connect" );
       clientSocket = server.accept();

      System.out.println( "Client requested a connection to the echo object server" );
      ObjectInputStream input = new ObjectInputStream( clientSocket.getInputStream() );

      PrintWriter output = new PrintWriter( clientSocket.getOutputStream(), true);
      System.out.println( "Echo Object Server recieved an echo object" );
      output.println( "Hello" );
      Object obj = input.readObject();
      if ( obj instanceof EchoObject )
      {
        EchoObject echoObj = (EchoObject)obj;
        StringBuffer buf = new StringBuffer( "Client Name: " );
        buf.append( echoObj.getClientName() );
        buf.append( " sent msg: " );
        buf.append( echoObj.getMsg() );

        System.out.println( buf.toString() );
      }
      else
      {
        System.out.println( "Unknown data sent" );
      }

      System.out.println( "echo server exiting..." );
      clientSocket.close();
    }
    catch( ClassNotFoundException ex )
    {
      System.out.println( "Unknown object type sent" );
      System.exit( -1 );
    }
    catch( IOException ex )
    {
      System.err.println( "Failed I/O: " + ex );
      System.exit( -1 );
    }

  }

  public static void main(String[] args)
  {
    EchoObjectServer echoServer = new EchoObjectServer();
    echoServer.startEcho();
  }
}