zion.freetzi.com

/**
 * @(#)Server.java
 *
 *
 * @author 
 * @version 1.00 2010/12/3
 */
 
import javax.swing.*;
import java.io.*;
import java.net.*;
 
public class Server
{
	public static void main (String[] args)
	{
		try
		{
			ServerSocket ss = new ServerSocket(2889);
			System.out.println("Server start and waiting client...");
			Socket socket = ss.accept();
 
			ObjectOutput out = new ObjectOutputStream(socket.getOutputStream());
			ObjectInput in = new ObjectInputStream(socket.getInputStream());
 
			byte[] dataReceive = (byte[])in.readObject();
 
			JFileChooser choose = new JFileChooser();
 
			try
			{
				UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
				SwingUtilities.updateComponentTreeUI(choose);
			}
			catch(Exception e)
			{
			}
 
			int result = choose.showSaveDialog(null);
 
			if(result==JFileChooser.APPROVE_OPTION)
			{
				String filePath = choose.getSelectedFile().toString();
 
				File file = new File(filePath);
				FileOutputStream fos = new FileOutputStream(file);
				fos.write(dataReceive);
				fos.close();
				JOptionPane.showMessageDialog(null, "File telah selesai disimpan di "+filePath+"!");
			}
		}
		catch(IOException ioe)
		{
		}
		catch(ClassNotFoundException cnfe)
		{
		}
	}
}

/**
 * @(#)Client.java
 *
 *
 * @author 
 * @version 1.00 2010/12/3
 */
 
import javax.swing.*;
import java.io.*;
import java.net.*;
 
public class Client
{
	public static void main (String[] args)
	{
		try
		{
			Socket socket = new Socket("localhost",2889);
 
			ObjectOutput out = new ObjectOutputStream(socket.getOutputStream());
			ObjectInput in = new ObjectInputStream(socket.getInputStream());
 
			JFileChooser choose = new JFileChooser();
 
			try
			{
				UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
				SwingUtilities.updateComponentTreeUI(choose);
			}
			catch(Exception e)
			{
			}
 
			int result = choose.showOpenDialog(null);
 
			if(result==JFileChooser.APPROVE_OPTION)
			{
				String filePath = choose.getSelectedFile().toString();
 
				File file = new File(filePath);
				FileInputStream fis = new FileInputStream(file);
				int size = fis.available();
				byte[] dataSend = new byte[size];
				int length = fis.read(dataSend);
 
				out.writeObject(dataSend);
				out.flush();
			}
		}
		catch(IOException ioe)
		{
		}
	}
}

/**
 * @(#)JFileChooserExample.java
 *
 *
 * @author 
 * @version 1.00 2010/12/15
 */
 
import java.io.File;
import javax.swing.JFileChooser;
import javax.swing.SwingUtilities;
import javax.swing.UIManager;
 
public class JFileChooserExample
{
	public static void main (String[] args)
	{
		JFileChooser choose = new JFileChooser();
 
		try
		{
			UIManager.setLookAndFeel(UIManager.getSystemLookAndFeelClassName());
			SwingUtilities.updateComponentTreeUI(choose);
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
 
	    choose.setSelectedFile(new File("Nama File.ext")); //Disini default file name-nya dibuat.
 
	    int pilihan = choose.showSaveDialog(null);
	}
}

/**
 * @(#)Factory.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
public class Factory
{
	private String item;
 
	public Factory()
	{
	}
 
	public synchronized void insertItem(String newItem)
	{
		while(item!=null)
		{
			System.out.print("P >>> Item masih ada. ");
			System.out.println("Producer menunggu.");
 
			try
			{
				/*
				Method wait harus berada dalam blok try catch
				dimana exception yang ditangkap
				adalah InterruptedException
				*/
				wait(); //Berhenti apabila item masih berisi
			}
			catch(InterruptedException ie)
			{
			}
 
			System.out.print("P >>> Item telah kosong. ");
			System.out.println("Producer dapat memasukkan item!");
		}
 
		System.out.println("P >>> Insert : "+newItem);
		this.item = newItem;
		notify();
	}
 
	public synchronized void consumeItem()
	{
		while(item==null)
		{
			System.out.print("C >>> Item masih kosong. ");
			System.out.println("Consumer menunggu.");
 
			try
			{
				/*
				Method wait harus berada dalam blok try catch
				dimana exception yang ditangkap
				adalah InterruptedException
				*/
				wait(); //Berhenti apabila item kosong
			}
			catch(InterruptedException ie)
			{
			}
 
			System.out.print("C >>> Item sudah ada.");
			System.out.println("Consumer dapat mengambil item!");
		}
 
		System.out.println("C >>> Consume: "+item);
		String theItem = item;
 
		item = null;
		notify();
	}
}

/**
 * @(#)Producer.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
public class Producer extends Thread
{
	private Factory factory;
 
	public Producer(Factory factory)
	{
		this.factory = factory;
	}
 
	public void run()
	{
		for(int i=1; i<=5; i++)
		{
			factory.insertItem("Product "+i);
			delay((int)(Math.random()*100));
		}
	}
 
	public void delay(int millis)
	{
		try
		{
			Thread.sleep(millis);
		}
		catch(InterruptedException ie)
		{
		}
	}
}

/**
 * @(#)Consumer.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
 
public class Consumer extends Thread
{
	private Factory factory;
 
	public Consumer(Factory factory)
	{
		this.factory = factory;
	}
 
	public void run()
	{
		for(int i=0; i<5; i++)
		{
			factory.consumeItem();
			delay((int)(Math.random()*100));
		}
	}
 
	public void delay(int millis)
	{
		try
		{
			Thread.sleep(millis);
		}
		catch(InterruptedException ie)
		{
		}
	}
}

/**
 * @(#)MiniFactorySimulation.java
 *
 *
 * @author 
 * @version 1.00 2010/7/14
 */
 
 
public class MiniFactorySimulation
{
	public static void main (String[] args)
	{
		/*Kita membuat satu objek dari class Factory.*/
		Factory factory = new Factory();
 
		/*
		Objek factory yang kita ciptakan diatas
		kita share ke objek producer & consumer
		yang akan kita buat di bawah ini.
		Ingat, objek factory yang ada
		di objek producer & consumer adalah sama.
		*/
 
		Producer producer = new Producer(factory);
		Consumer consumer = new Consumer(factory);
 
		producer.start();
		consumer.start();
	}
}