jbdorderserverthread.java

Java程序设计技巧与开发实例附书源代码。

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

public class JBDOrderServerThread
    extends Thread
{
   private JBDOrderServer server;
   private Socket connection;

   public JBDOrderServerThread(JBDOrderServer _server,
                               Socket _connection)
   {
      server = _server;
      connection = _connection;
      start();
   }

   public void run()
   {
      try
      {
         System.out.println("Connection established. Identifying.");
         ObjectInputStream in = new ObjectInputStream(
             connection.getInputStream());
         ObjectOutputStream out = new ObjectOutputStream(
             connection.getOutputStream());
         if (in.readUTF().equals(JBDOrderServer.CLIENT_ID))
         {
            out.writeUTF(JBDOrderServer.SERVER_ID);
            out.flush();
            if (in.readDouble() == JBDOrderServer.CLIENT_VERSION)
            {
               out.writeDouble(JBDOrderServer.SERVER_VERSION);
               out.flush();
               try
               {
                  CatalogOrder theBill = (CatalogOrder) in.readObject();
                  server.writeOrder(theBill);
               }
               catch (ClassNotFoundException cnfe)
               {
                  System.err.println("Invalid class");
               }
            }
            else
            {
               System.err.println("Invalid version");
            }
         }
         else
         {
            System.err.println("Invalid client");
         }
         out.close();
         in.close();
         connection.close();
         System.out.println("Connection closed.");
      }
      catch (IOException ioe)
      {
         System.err.println("IOException !");
      }
   }
}