From 8362b82a88d7513f024bead57fe932976fafa14b Mon Sep 17 00:00:00 2001
From: Metatheria <farina@etud.insa-toulouse.fr>
Date: Wed, 2 Dec 2020 11:27:34 +0100
Subject: [PATCH] =?UTF-8?q?syst=C3=A8me=20de=20messagerie=20multithread?=
 =?UTF-8?q?=C3=A9=20bidirectionnel=20de=20l'espace?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/chat/ReceiveThread.class | Bin 0 -> 1158 bytes
 src/chat/SendThread.class    | Bin 0 -> 1564 bytes
 src/chat/socket_client.class | Bin 1658 -> 1356 bytes
 src/chat/socket_client.java  | 120 +++++++++++++++++++++++++++++------
 src/chat/socket_server.class | Bin 1392 -> 0 bytes
 src/chat/socket_server.java  |  37 -----------
 6 files changed, 101 insertions(+), 56 deletions(-)
 create mode 100644 src/chat/ReceiveThread.class
 create mode 100644 src/chat/SendThread.class
 delete mode 100644 src/chat/socket_server.class
 delete mode 100644 src/chat/socket_server.java

diff --git a/src/chat/ReceiveThread.class b/src/chat/ReceiveThread.class
new file mode 100644
index 0000000000000000000000000000000000000000..cb76c242a22fb3c178eedbf1b150c3fd9faedf4a
GIT binary patch
literal 1158
zcmZWo>rN9v6#j-@rY&18g#s1PiXtty3W{8cAVt7xp+HF!_+z%qfGcIUS+)dU#Rrhz
z7%fH;9>6E@B?QlGsT9p-Cp%}(Ip5{X{=EEg0U(L>02<)pa4Yb@%h2*cJyH`z)!0jH
zzPE(B!{D9K4c(q)aK++zKYZ|W1QawvVF+#rP3T9Wmg_E=md(J@98C;ir<oz_L{3;o
z!pfQ2zOVxbqD8{BGPq;ucs_tOv~z?NbfA-=^@c*qG>bwt82FJ|EQ{<eLq}{op7}2$
zDSJc|+(9>kQmB^YWsO67TVnPoxQF|sN7Xb@B9?8j>rM_shg*{40bw}(bu*DF@9qjq
z>}-$`!s2+y5UHJ|jZ)dp+2qkd^*De&Jm%<E5JQ}y*-5-<&Cs+b?7Aw3&Kd!NsyiSt
zy%>}Z4KZ}Zs%rm9k*-BCB9jtQ$={?Zmt^&PRKXaYGWdw)PDVG#jrJO*Gh^bf8+%C~
z#%UJfShxL{z$C|%f@vggU5DJqLt7k>oo1Q53;zXNqYl?T5b+n7<(O0O67xi>=2cw|
z&9WpbiZs>mHSKyTl6W5$6ugqx(W4d3L&33B*DRe~JeC90O~Z%RG*3g{AB)o1+zaLo
zDQuQPSIY+lVQs2~qPziCnb3kcTh;bg)RGhBSiLRJae^U`Gs~7HmULMdI&^NuJFTb-
z!yb`x$aNq6G618O{sCI$j&3tW()2Yzdl?A~oPiB=e*-_I9m5-1o8Y2#0&Yygk12}2
zh4;Gd7xnPcsdkRw*1%WrGg9LEj?l_b1zn#oKUl%t)pJC*&e6LyT*0F=5XA7bJL0b3
z$+Rcp2|fFaMz<_ELE{%Zk9aDWq0H3D)x`;v4243=6gnkHAdf995>-iT7R}D8V2*^$
zqYDe@p%IKy#w3;~x=c?RSt6W6hH5vcI*V<rqu@k<et3VQl_SW}c8PJ0K8`5I3cr#X
RIoXC3$D)tGvjo<FwLhpb11bOj

literal 0
HcmV?d00001

diff --git a/src/chat/SendThread.class b/src/chat/SendThread.class
new file mode 100644
index 0000000000000000000000000000000000000000..6ad599ab5ea7617f98c772f945224bfd37cf53e7
GIT binary patch
literal 1564
zcmaJ>T~iZD6g^D>1LMd?BJv@tvVxKTMqO83;;tWAS)+ldK@fbfnxus>lb+N}4<%Lp
zkgfd#KD$L=ORIeJ!T+T0?MWzRHz^-_y64Wh=iYPs&i(xL{YL;<Y?$am%s|{iH+mQb
zU-2EDak$*dtZaLNR~UM3+R|3PF~nw4t9|H2p8?atF<1;{Nyy3}us869CwWaUBnn47
zCFR+2E2};GEevQkgI6k^@O^C?vXBUEH8Sump=~ED4C5q2yzY96f#pq%V$8s}g;SVd
z7&>CV>$;BMk~nv`6NutVhLbZJsYv`5BC9!0TR4NW4Ay4TZB_e($~FxA$S@EROQA9)
zw_Fv<#3ZJ4X{I%8gtR3ppIS9=fgu_C*>2_$X;o{Ut%Rq2Qx?*gCEhKeih-&JiW~*6
zF^tZ%awMnd7fSOy=5@%64CAek|Ho{kRugo6mn>Yy6^4--uZo;2%UrG5YMV~J;!^nx
zH#+3pt|D5kmN1>gRSQ4k8dbKgMLAUC;SO}V0yiQR$QSRuE{nRdUD<~PWDVT3@GGc)
zBE41G^_8G1#N2@Hcet6-VfmUR%J$+mL$|c6mnTi!#Z?2jNSLtDhs9jzkXO6Rb_-n}
zHCfKBP!9|gY$=w5+NSVU_@<+~!V5_A@si@@>JqQFtY*m#ys}udH6-DOZStb**g~p{
zx(i4rb)52*$LmW%ZMzkJpa)APmQghDNMG4whN+_tw&jjn6`5w?o42^g%gXh38UBn4
zYXO_2_qnV%!k;R*ZZ)W9+qFe3|8ZQ|t&0xu=Mj8y^OY#8Y_u&}6gloVC2DTEoDvm?
zEin3*@=^*f=WyQ_z5%M}bep(NIU9J!aQgdDnm$c|I7?%pi+Vmzi$)JUp=U|B)BFf`
zni;ffR5yMH!#z4J(t9`U<LLvi^lSr0dai-v>G=i*)5GxwlJDp%BOGDSL(e3|IDtNz
zK>fs*#0bV{axnZsUz?l_LTJvXv41eKG`Ei*{=&l#m|Rcq5%V6B2RK*wfb;9K`<RIz
zU~YMytOl*Y_s9VI_$jVE-+ueF5dRy$ByR2FPRRB4+ul10V&N8b{B=rQr*$QiH$frK
z(CHi|FohJR>F2sYxOqaRNbW2On8RawU%@5ZC%=BgzL1lF(KiOJ4<Uv;S-bE64{7hE
SI0afy2oIQadWtoyW9(m6SA{+R

literal 0
HcmV?d00001

diff --git a/src/chat/socket_client.class b/src/chat/socket_client.class
index 6ad3586ee4c0cc6e07a35754453a2b113350b192..3736fd9819d52ad60e41bf2c9fb063b59a2979a9 100644
GIT binary patch
literal 1356
zcmZ`&*-{fh6g?f1^bkkc!Kg@Zfdr7KQIJHDMbIFd1SlyN95M|KBr|blLgDhL-(vYF
z4~ZpJzWC;U_#5KwArw$RD%CUh_L+OmJ-7SMzn{MVq_7Zz4^<p~6#)bpYS*<*EuPcN
zwfM}+y2!c=!TW}3xPuH;(byt~!qDu23@biTTwN8m(C37v3!5Xv5Z>QQn}wpAac!aH
z_qMB{;w;BG6*Z_m!jyUMxFXNsGfal2$rCE1La0W))Y!mqK6)Y~wip6OlLR$0G#r5T
z=u@#pso=bdFfLFtR*`x;Ae*%fvm!U8;1WY*%p~z2BDqdYw}s<~h%Wz*YnYmASY|SW
z%V^_>sA$I(BHWjKs1ie<AnOuQMULkzxnh`WBuEOrrs6s}7!-0!pEOLt&=`&Fb$A%9
zAj;6bFG@trV*d9x+mfmZmhDCyt7vBhsp>*EM~{jd=w+z$RC#sMrYqKjO-u#Nb_9i|
z$Vw}?$<T2+)nOMD+-7L2U^gwYEMi*uh~8Orjhx|Vt|;0`jynuz=R{T*n_~X0>@<V~
z`sA$o8T`?-^df-)6-jvt1CFcNF2{X_P)3;g{wFC6%1<6LBv0`3xM#;R9#IMd93zKD
zmYx~g%8G&<tAa<wZyFnkb~)g26_4d~xi`n0$&sc`94osa+~sV}5Yk2esHM}`YUK2$
zi}@8{&uc3=%J}n|Jkrh47sr*v7O7Ci)v_B?TEW9}%#x-Ppd52Y?~8YSq&MEo#|_C<
ze?(NToI4%NCv?5#&j;!XL0Ts$YNaQmXP~PL_MKiBp3*9}fd#s1lbE7+g0dFMR#W!N
z4*1dzs+YELri{8W8Yj2WQh%|8*6tFnPRXFN68u1HP{#3txX&*Ww<?KbU<Zk%)-vuU
zd6<`QPnJk3J4h{s13h7-$zR5UWH1~oVd(4bUyo_Dgt70Qz>oNdVd_Xqo<KdVFKK;+
z3wVt-ETa=|5Qm0-tY8RP@<7KlR`DEbgj%P}1{~zDg*;WV@ConmnKIK<DGJ{%ffSAz
b4$kq6F<R)FCV*Y(8*RvCn3QA)@5B6mpk7Q;

literal 1658
zcmaJ>?NZxD6g_KfWK<;tgGmg<F)bu^LhLsE#%bE(LgU8ZBqpXLZBrpHpjg&=q%~9C
zq;JsQ$qzgeX8HjA*@x)QK0@hT$pq23^^B#}?z!ild-v@A{`afj0F?2Qju=KX#0?}c
z%5dqqd0>_t)7>l8cb;=gGK}7_U0dE|7|9o!V@P65gKpq080X-PLtpX^p+t{@(zSrd
z7NrNC?aGGqxY;QuagpJ2MYt|8+wNXYik#2A1MU@zMIDzgp&?~p5>pJ5LkJkOuA*~X
z%8(CJ1X_uo=*oqrhG~ZJAk^iu)DTvi%OtKaj5)$Goqgd;9cj#{dS@A?hp<!&%_Qa+
zW><Y_?l`u;ucTH>^_(A+;geVmS1I^Z;!1CKmwUYRh?_0$X_#looUT>fZf{V3xUAB@
zYhVG33>Wvfi~y)P`NHeYMHb3Ba=5NE=NYaHG*fe<kU~>O7B>{=CbjPj6s8TDbL-!I
z-STY7Jte7R;61!g%_B+mo_sA@<vY_9T_I6R_(0|RkYVO5-#N^a&@&$!_ynIa#B8;7
z|50KV%LaM!4nvac(yG}mXP7$89^L2^nfI=NFYqO`tYfx0dCD^7mM!;bMBC;{pW)h&
z%^j2yB~xXP@hXwtRO_ohTf8f6;U=-l5O?kNyoPTWF8G0^o>`8~T{3#SB3h(!T#4Q2
zb#}P7NuHsZc*j(=PUoKv^C=NEq-nL+&2E6#utDjEKpFIg=y?`jvlVOVT>7Fi8J)rv
zAtZUz?5=aUFIxWiC>lC8@mNDsb!m%XA@E~Rw(TB>HZO%|CT!fAX-VN7GW-&4*#H=l
z-ZR~n!~KPt5ba*K{AN*+nR9`ghh07d9<4RJYRb{Q8BkPA$7zs7>FU@fTU2V*)s4+%
z#$Z(G67edI>HFN*@IAxg8x;-{uHi?9?EgdQ&I_x=Jl5!bRKFM)8GV$V_vmYm-i+Rf
z8-1`BG+?OGQ!N7q#_%of(^x_O48j2M5?boQ5yp>^-cDVfi2u<?rluy}4kokP$H;Bp
zJi<GDT<fE-evBpcS&a8_d*c}4`b&HiE-%M3@gsb;oVb-qyu#<e5x)BM<gbA6Ya)CR
zNa5gEA?-@sZ4w4d&;_2N<333>Owox?Q|vSzAcHN;U<b1lF^64Tg-g}fC}I(@69ObO
vtZPVX$ZA-kCvZXpjAqqi1tX{vI7Y~a^iERxNA&*=Pv}dh(Np|@XUO~mY~rp-

diff --git a/src/chat/socket_client.java b/src/chat/socket_client.java
index 07186e4..8932dc0 100644
--- a/src/chat/socket_client.java
+++ b/src/chat/socket_client.java
@@ -9,26 +9,108 @@ import java.net.ServerSocket;
 import java.net.Socket;
 import java.net.DatagramSocket;
 
+class SendThread extends Thread {
+	String username;
+	String address;
+	String message;
+	int port;
+	
+	SendThread(String in_username, String in_address, String in_message, int in_port)
+	{
+		username = in_username;
+		address = in_address;
+		message = in_message;
+		port = in_port;
+	}
+	public void run()
+	{
+		Socket link;
+		Boolean connected = false;
+		PrintWriter out;
+		
+		while(!connected)
+		{
+			try
+			{
+				 link = new Socket(address, port);
+			     out = new PrintWriter(link.getOutputStream(),true);
+			     out.println(username + ":" + message);
+
+				 connected = true;
+			}
+			catch(IOException e)
+			{
+				System.out.println("nik1!");
+				connected = false;
+			}	
+		}
+		
+	}
+}
+
+class ReceiveThread extends Thread {
+	
+	int port;
+	ReceiveThread(int in_port)
+	{
+		port = in_port;
+	}
+	public void run()
+	{
+		try
+	    {
+			ServerSocket servSocket = new ServerSocket(port);
+			Boolean exit = false;
+			
+	        while(!exit)
+	        {
+		        Socket link = servSocket.accept();
+		        BufferedReader in = new BufferedReader(new InputStreamReader(link.getInputStream()));
+	        	String message = in.readLine();
+	            if(message == "exit")
+	            	exit = true;
+	            else
+	                System.out.println(message);
+	            
+	            link.close();
+	        }
+	        
+	    }
+	    catch(IOException e)
+	    {
+	    	System.out.println("nik2 !");
+	    }
+	}
+}
 public class socket_client {
     public static void main (String [] args)
     {
-        try
-        {
-            System.out.println("Connecting to server...");
-            Socket link = new Socket("localhost", 1234);//remplacer localhost par l'adresse IP du serveur
-            System.out.println("Establishing I/O streams...");
-            BufferedReader in = new BufferedReader(new InputStreamReader(link.getInputStream()));
-            PrintWriter out = new PrintWriter(link.getOutputStream(),true);
-            BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
-            while(true)
-            {
-                String message = console.readLine();
-                out.println("CLIENT:" + message);
-            }
-        }
-        catch(IOException e)
-        {
-            System.out.println("nik!");
-        }
+          /*  System.out.println("Connecting to server...");
+            System.out.println("Establishing I/O streams...");*/
+    		try
+    		{
+	            BufferedReader console = new BufferedReader(new InputStreamReader(System.in));
+	            System.out.print("Entrez l'adresse de destination:");
+	            String address = console.readLine();
+	            System.out.print("Entrez le numéro de port source:");
+	            int sport = Integer.parseInt(console.readLine());
+	            System.out.print("Entrez le numéro de port destination:");
+	            int dport = Integer.parseInt(console.readLine());
+	            System.out.print("Entrez votre nom d'utilisateur:");
+	            String username = console.readLine();
+	            SendThread t1;
+	            ReceiveThread t2 = new ReceiveThread(sport);
+	            t2.start();
+	            while(true)
+	            {
+	            	String message = console.readLine();
+	                t1 = new SendThread(username, address, message, dport);
+	                t1.start();
+	            }
+    		}
+    		catch(IOException e)
+    		{
+    			System.out.println("nik3!");
+    		}
     }
-}
\ No newline at end of file
+}
diff --git a/src/chat/socket_server.class b/src/chat/socket_server.class
deleted file mode 100644
index 294f771dce76bf99945a0c97cf7d174fa5aef63f..0000000000000000000000000000000000000000
GIT binary patch
literal 0
HcmV?d00001

literal 1392
zcmZux*-{fh6g>?g9m0eqED{tAiWo!__l3CPiUy)aQBcbol7<=yGt^{)`lR3C2gtKN
z1WT&?03UtzPb^D3JqeJgNmb8u-`n?`bLVt_`~BrBfHa<m(S&A+fPoeS1v+1vt7fWb
z+KZ{|{7aSh1cDbV+wv|6G$%%9!U&;NB5a@yhCtU&`h?>Ym1zseRkK)D*#&{V#N24+
zpNzCbyFjnMZYwX9Q|_vAb54Fqd0|A*si|}c1QL^@Gp*=Gk3_G5KJ03smwQw4)G}E)
zWs>Zz;#f}Vo@?1&&U2NyoDLx-(0}!nX?d2t7|%PlO-Ytx$CJrqJdEAgBQa=TFZKy^
z`-~bZP|b?2SER1qM4c7_uwq&_B!VFW`*DDsGV^)0LN?urnr>g8uZ&y{3PiWL6im<b
zSx6jWr?#*s$_oq1RfPx2EGSoER3Nq$o3vNTHD%Rs7-KjhanwK(DS?iimimwa?TgB*
z+a<7Tix_3r1=3+8a9sEO1p8If`B#dTI)YO=>9kh3-S8?GwnF0U-(7s{TAp$>&+`Vx
zktRt}%9g!tB^s~RECSX?Na_qOYCL*xU<a=uXRd0=D+aD&Lco}>x^PBY(0A;dW_{hj
z4crt6(G`V^Wi!;Xh3b2~_BlhiP2Z{47L7QDI|lCRGtrVSIwd7BRi|z;d*ikK*7Q;c
zS?1W*QhZ3_zCfhpcmGAn_ciNXa|#6P(74m(<$2{kH0O(42`rlyebtwE`aff_P|h>+
zOH<~GpD*!*`2R_jm}@*3zBL8HIj8LA)lExdMH@&ZwNo&Jdp!L5*90m+kmCc+2Kf|x
zwj5rE_{bN597i1nTKRv7M|@|h800p|)pyOGAu}6@%ytF7ucKq?6Qa@n3I>i;5TDkQ
zVNNzMGP{Aq?9mEX`q(;7jt4eyM$gX$)^TCHWvqhB?=c(;RB&xP7z;*keL!14*Iq*#
z%fx~#v$pwzJ0{m)WOU_eE`9X5m9UBo#b~y75arlTejVuKzaL!`7R5ncDCg0GTf9)F
zx%vn(Ji`DA*n=W799{+`9AKq5Uh!DJ#V}@A=_G=i+!T~}ED@53NQ_C0NO}~%^ffa3
V6S8SjcZn%_$b?AhDYrJ^*&jN^N8SJc

diff --git a/src/chat/socket_server.java b/src/chat/socket_server.java
deleted file mode 100644
index cdda7b3..0000000
--- a/src/chat/socket_server.java
+++ /dev/null
@@ -1,37 +0,0 @@
-//package chat; 
-import java.net.*;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.PrintWriter;
-
-public class socket_server {
-	public static void main (String [] args)
-    {
-        try
-        {
-            Boolean exit = false;
-            ServerSocket servSocket = new ServerSocket(1234);
-            System.out.println("Awaiting connection ... ");
-            Socket link = servSocket.accept();
-            System.out.println("Awaiting data ... ");
-            BufferedReader in = new BufferedReader(new InputStreamReader(link.getInputStream()));
-            PrintWriter out = new PrintWriter(link.getOutputStream(),true);
-            
-            while(!exit)
-            {
-                String message = in.readLine();
-                if(message == "exit")
-                    exit = true;
-                else
-                    System.out.println(message);
-            }
-            link.close();
-        }
-        catch(IOException e)
-        {
-            System.out.println("nik !");
-        }
-    }
-}