ChatApp-AL-NM/Implementation/src/TCPEchange.java

import java.io.InputStream;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.io.OutputStream;
import java.net.DatagramSocket;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;

/**
* <p>
* Classe representant les échanges TCP entre utilisateurs.
* </p>
*/
public class TCPEchange {
	
	public static void demarrerSession(ChatApp app,Utilisateur User2 ) throws IOException {
		System.out.println("Demmarrage d'une session de clavardage");
		Socket s = new Socket(User2.getIp(),5000);
		System.out.println("Socket de demarrage d'une session cree");
		ExecutorService exec = Executors.newFixedThreadPool(1000);
		exec.submit(new RunnerTCPEcoute(s,app));
    	exec.submit(new RunnerTCPEnvoi(s,app,app.getMe()));
		
	}
	
	public static void envoiTCP(ChatApp app,Utilisateur User2, String Msg, int type ) {
		// On cree un messagehorodate
		MessageHorodate mh =  new MessageHorodate(app.getMe(), User2, Msg, type);
		if( type == 1 ) {
			// on ajoute le msg à son historique 
			Historique h = app.getHist(User2.getPseudo());
			h.addMessage(mh);
			// on update la liste des historiques de app 
			app.majHistorique(User2.getPseudo(), h);
		}
		
		try {
            Socket s = new Socket(User2.getIp(), User2.getPort());
            PrintStream output = new PrintStream(s.getOutputStream());
            output.println(mh.toString());
            output.close();
            s.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
	}
	
	public static void ecouteTCP(ChatApp app) {
		ServerSocket ss = null;
		ExecutorService exec = Executors.newFixedThreadPool(1000);
		System.out.println("Ecoute TCP activee");
		try {
			ss = new ServerSocket(5000);
			System.out.println("Socket d'ecoute cree");
	        while(true) {
	        	System.out.println("Attente Session de clavardage");
	        	Socket link = ss.accept();
	        	exec.submit(new RunnerTCPEcoute(link,app));
	        	exec.submit(new RunnerTCPEnvoi(link,app,app.getMe()));
	            }
	        } 
		catch (Exception e) {
	            e.printStackTrace();
	        }
	    }
}


//ENVOI
class RunnerTCPEnvoi implements Runnable {
	final Socket link;
	private ChatApp app ;
	private Utilisateur Destinataire;
	final BufferedReader in;
    final PrintWriter out;
    final Scanner sc=new Scanner(System.in);
    

    public RunnerTCPEnvoi(Socket link,ChatApp app, Utilisateur user2 ) throws IOException {
        this.link = link;
        this.app = app;
        this.Destinataire = user2;
        this.out = new PrintWriter(link.getOutputStream());
        this.in = new BufferedReader (new InputStreamReader (link.getInputStream()));
    }
    @Override
    public void run() {
    System.out.println("Creation d'un thread d'envoi");
    String msg;
    while(true){
        msg = sc.nextLine();
        MessageHorodate mh = new MessageHorodate(Destinataire,app.getMe(),msg,1);
        out.println(mh.toString());
        out.flush();
     }
}
}

// Reception
class RunnerTCPEcoute implements Runnable {
		final Socket link;
		private ChatApp app ;
		
	    public RunnerTCPEcoute(Socket link,ChatApp app ) {
	        this.link = link;
	        this.app = app;
	    }

	    @Override
	    public void run() {
	        System.out.println("Creation d'un thread d'ecoute");
	        try {
	        	PrintStream output = new PrintStream(link.getOutputStream());
	        	//InputStream is = link.getInputStream();
	        	BufferedReader in = new BufferedReader (new InputStreamReader (link.getInputStream()));
	            
	            String line = in.readLine();
	            String msg = "";
	            while (line != null) {
	                System.out.println("Received: "+ msg);
	                /*if((line.split(" ")[0].equals("Destinataire"))) {
	                	if(msg != "") {
	                		MessageHorodate mh = MessageHorodate.stringToMessageHorodate(msg);
	                		// on ajoute le msg à son historique 
	            			Historique h = app.getHist(mh.);
	            			h.addMessage(mh);
	            			// on update la liste des historiques de app 
	            			app.majHistorique(User2.getPseudo(), h);
	                		
	                	}
	                }*/
	            // On recree un messagehorodate à partir du message reçu
	            
	    		// on ajoute le msg à son historique 
	            
	    		// on update la liste des historiques de app 
	            
	            }
	            System.out.println("Finishing thread");
	            
	            
	            	in.close();
					link.close();
				} catch (IOException e) {
					e.printStackTrace();
				}
	       
	        }
	    }