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.out.println("Invalid client");
			out.close();
			in.close();
			connection.close();
		}
		catch	(IOException ioe)
		{
			System.err.println("IOException !");
		}
	}
}