Créer un reseau en java

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.OutputStream;

import java.net.ServerSocket;
import java.net.Socket;

import java.util.LinkedList;

public class Commun
{
	public static final int port = 9001;
	
	public static void transfert(String role, InputStream in, OutputStream out, boolean closeOnExit) throws IOException
	{
		System.err.println(role+" transfert");
		
		byte buf[] = new byte[1024];
		
		int n;
		while((n=in.read(buf))!=-1)
			out.write(buf,0,n);
		
		if (closeOnExit)
		{
			in.close();
			out.close();
		}
	}
	
	public static void envoi(String role, LinkedList<String> serveurs, File fichier) throws IOException
	{
		System.err.println(role+" envoi");
		// Ouverture de la communication
		Socket sock = new Socket(serveurs.getFirst(),Commun.port);
		ObjectOutputStream out = new ObjectOutputStream(sock.getOutputStream());
	
		// Envoi de l'en-tête
		out.writeInt(serveurs.size());
		for (String srv : serveurs)
			out.writeUTF(srv);
						
		// Envoi du fichier
		Commun.transfert(
			role,
			new FileInputStream(fichier),
			out,
			true);
		
		// Fermeture de la communication
		sock.close();
	}
	
	public static LinkedList<String> recevoir(String role, File fichier) throws IOException 
	{
		System.err.println(role+" recevoir");
					
		// Ouverture d'une communication
		Socket sock = new ServerSocket(Commun.port).accept();
		ObjectInputStream in = new ObjectInputStream(sock.getInputStream());
		
		// Réception de l'en-tête
		int n = in.readInt();
		
		LinkedList<String> serveurs = new LinkedList<String>();
		
		for (int i=0; i<n; i++)
			serveurs.add(in.readUTF());
							
		// Réception du fichier
		Commun.transfert(
				role,
				in,
				new FileOutputStream(fichier),
				true);
		
		// Fermeture de la communication
		sock.close();
				
		return serveurs;
	} 
	
	public static void repeter(String role, LinkedList<String> serveurs, File fichier) throws IOException
	{		
		// Client
		if (serveurs!=null && serveurs.size()>0)
			envoi(role, serveurs,fichier);
		
		// Serveur
		serveurs = recevoir(role, fichier);
		serveurs.removeFirst();
		
		// On recommence
		repeter(role, serveurs, fichier);
	}
	
	public static void main(String...args) throws IOException
	{
		// Serveur
		new Thread() 
		{
			@Override
			public void run()
			{
				try {
					repeter("Thread 1",null,new File("D:\\test2.png"));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}.start();
				
		final LinkedList<String> serveurs = new LinkedList<String>();
			serveurs.add("localhost");
			serveurs.add("localhost");
			serveurs.add("localhost");
		
		// Client
		new Thread() 
		{
			@Override
			public void run()
			{
				try {
					repeter("Thread 2",serveurs,new File("D:\\test1.png"));
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}.start();
	}
}