From 8f1c3e6a9b940669e7ae26d0e991014c29a457f7 Mon Sep 17 00:00:00 2001 From: moukhlis Date: Sat, 5 Dec 2020 12:35:25 +0100 Subject: [PATCH] Implementation TCP --- Implementation/src/ChatApp.class | Bin 4573 -> 4822 bytes Implementation/src/ChatApp.java | 6 +++++- Implementation/src/MessageHorodate.class | Bin 1534 -> 2562 bytes Implementation/src/Runner.class | Bin 371 -> 420 bytes Implementation/src/RunnerTCPEcoute.class | Bin 1700 -> 1715 bytes Implementation/src/RunnerTCPEnvoi.class | Bin 1577 -> 1591 bytes Implementation/src/TCPEchange.class | Bin 2293 -> 2479 bytes Implementation/src/TCPEchange.java | 10 +++++++--- 8 files changed, 12 insertions(+), 4 deletions(-) diff --git a/Implementation/src/ChatApp.class b/Implementation/src/ChatApp.class index be374c099849da135c5a45bcdf2c03bb19d4d3c9..416b24c8078eac522e1299c07c9a03e9a60a8f3c 100644 GIT binary patch delta 1002 zcmZ8gNla5w6g{te`Q^2=r4=J0=9d{Xpc09SLljAjU_t~nNL>8D6Dp;x9f&)3>Qa3R z<3{7kjSDrVQ5PyoRKy7toT&3Wg>_nvd7|6_TB1^oQ)W5)r^VWxw; zIBl+Ls~Kk*QkUz&F5%_q#d#HdR$RbE2FH56OE358zP9p)aM0sxqd>7CqI*LOnX=#H z+ElW}jLQtUjlvh!!=5gowF<4p@AHX`9=}i1yF`nz(N6hFacJj?}4cAo+STTqj z47{WEIy{x9j0Wfk0K=%CN`l3F%=G309S?GUwtJ zL(Vdx`GnS4qz3}R>lIo+4{6DM+-|pQN^6sYX_a8C-HZ zcgYicrtKZadkm}iU_~uH$~f;~pJk7wK>5m`$;-;*iHtLD#&-rw^=ONnnK2^WR=4t- zp+Ii1PT~1=et$s5L7isI}lB`4wVz(>aOM1be{NMC@{VMVZ0QG}x11O0ttw*I44Czr=0! zyah&4Hlz@4Mmn}o>08GnDMXRc0Qqz1W^|7$Jq+ytJs4tg*zTJ4zmxxUQiw4EU?<@$ zR3?g@?wF8cGqUQOt9miQ?QYWFJDi^HLOnsZ$SwJFi5s>jO?qC`B1&&=4yz z4-3&u7Ne%caL6SYkXh-2?} z+`PT(&``n6ixHj?Wqz7H6Z`ZY^A*Qy%xQRIAd9!c(NV@$t zc@j{Tuo9{UT|-5~84WQo4NdhFd>8k8$_{f)qU_5kgj*2DR(hvSDZ#WTnWsoF5zVHh zU^CPuBtfMFf)%OOul_<-$9?jv#PsM~M!nA-jqWD)Vl>?;*()Tw8A`wosLQH}5B?GR z8dJw)Q6@r!B}6bnr5~?KvKDQ!0rIaR%gEMsoI}f5x-dwx>=HOZIEy{l;<)8_DOkaCydXoERbLRps!fO43kT#S6wt%g)Nok-ULc)tssEs5ANm?inozA`Y+&%Z4=RD`!bMwbP^=AN1;71KT z=v5HV5kyE}+a2Sskti9J<;10>J7&QZ2%WSlmU~*DcWiuN6I5(cpy}8QU7#;(I*zey z&e}D*Xt<_;UNjxosu-?e)hKSs%)3^}a`gbb4Lyo;#E0}U?yN)pW1r*`~r;aFg@w)`!gCQ)&(=hb%ga=`dj@K|G z5OD8TsUy-V_6iUKuwTdP7!epO8!P6tT`3suRm;82mE#%}*AX}})`_hx$nnnaVF>IG zlj#G}{FuOjE=JN_4r+`orX!9C$t+{b+YLGd2FAMRhtZ2k=_4U*Rm@buHlA`_hnD$tMUT6IoBwxIWtDVwQKhU9<}246&prpjY_d(IwKj|URkZCIxDwj zr|n>#O|Of3YqX8lpK85lzKLn0RLWVdnNsly0~P06x_we;Du`JV4URndGbTz%m!9;w zlw`I&=}TTD;Zx{se9cEj2#viiU8$J0>5}0%CP{lJFxtUaHyRXtFEI4~s%$L{&ajVV z*u$nD*U*t8*^ZLpGpJRz`*317eD>z@n{XX3Hnpwt;9yyccUM*ZdPI^OV>>lm-&pufAV zjze=o(N2$e^$@iR~mc-Qm6o(hXM>g=L=XG!$$D0Nl zuunt78HRovR^zaUBSabaITk*>j<+-M-l^~m7lEnYF`JDCTBNynuqn+Q3%qof4EmHO zL(yP7^g?MJ`DExZw4@SM)^R;NoK%!!YDA4c`vp6qN<5-Y)$sxNB0W^a0;QS44;3s~0gqyfSD=`F~Q&~}PR>6vbH2;Ny6AFLfaK0A$8zFuZ ue=!HWDDy-QDzpYBGK4Cz-Sx(M-uS6EKJdmbyzwh~1Zfxe7T@6qME?c*ZEO7i delta 587 zcmZ8eOHUI~6#mZiG39o6*h&-%ZF$tTQ(#11bx=_$P#(1^#OQ*>1SW(8YSO6-R|rdX z{DVgC>Lh?H=qgFGv zx3kr%xxa5Zj(`qBLj+F=-CkX1@sq$aOsJUDFokJ(tSp5HhOCE2+s_Mx2UM}0)^5XUS-VZ!%#w&3x zW1A!h+H#{|H|O^($FUt1@8nrjr}y%Abb`XNQ%&_JkmN>$K>X+##xi@W?1%Zx$hw+7 zIA@EvcR(+qjE_0jgEsa$kmBk-q|wg|6S<&%6AEu&Jds)}=|7>mOn`5;yBP4zOANYr z5=6UP6g~6oKdC%F9@B<7{3GBR+c zCg+!yqymN586+ppj1-q(U49VHDE<6~e3k{20R7%nkz zGF%4A$uO{iQ~*Wwfiy@rzt$E8_8kno5K4F>P>7KMq4_!kJHrj2LAQXSvOqZ|1~~w* C=o^^; delta 133 zcmZ3&{F#aC)W2Q(7#J8V8Kfq1^)RzDh)mocDK5;w2o&RH-~p0MKsGCb5Rep|tj{Rz zF9sCjV_*i7CmC26PBCyYoCeB?Gq8bF07X@RG)Omx))of#9Spo1fow(wkS;EuSqu#4 Q8Q2*v0!1W%Y$gUt0Gav`6aWAK diff --git a/Implementation/src/RunnerTCPEcoute.class b/Implementation/src/RunnerTCPEcoute.class index 56d894419d3316b1d6472d83507402f51b8fbd63..c2603f842c38313c9a8936249ffd2a0c1f5ee28f 100644 GIT binary patch delta 117 zcmZ3&yP0>wB{^B=qSVBa%=|os6!p?Pg^~;)HwDN}P0lYZN!|ExCJS#K0}Dew11CcP z10O@-1Py8c1ORIQ2>@&W4ghVFmIaeF zaR3Maa{w0rbpR~@cK|W~cmOs4c>p>9dH_lQjQ~;rkN{QykpNu)lmK7=k^o@mfiouN`dh!g`OpQ1O4u(Vq0fr<7Rfc4sObUZJLn=cK0|Nsy Q10x3mBSS8b$;6Nc0BxihWdHyG delta 103 zcmdnavyx}SOD2B4kc^_##1w_%lEk8t)RfI^%*{-)feb7RehfkkK@8#y!3;7CAqtZ3ofa7ov~MXgxO8+tgW zh1GSXte83SdC?A^hz=QkbaL>ok|U8f67yzWw-zl^Qwny8k3>Z5;?P$2>Y9~UG}JZC z@}dht5#2KOpl9=Hayfur83Ot^bVp~O2G3ANI+ru4{^ZQQOA_`Hyv7X-OiufMoT{l2 zynYOb7?d%D;mx0Np?!p6p``1YxpZp&v}%+riiu*Bm5teHF48=Pgotq&`*Fb5xto0l zIkY~@(91^NiwPVSaYUvDrtBx&kd(wRcENLYzbg?sP9^3DD|P3bVH!Dwm6$@BMVzz^ z*CDA3(=txujQy2sP@2Fw88bL<|L#gO&tgtQM#l4)xBc!UITvIsV#&_9Cn)WbjLW!U zKXMN=zlf_MuF1HLWxM7c^m-A%%Q6(aV!Qc-)Q%jhr`ajKH$H_G88>l;gJc;bN?u=K zx~zPBs|?L;4t%t(;2jQ~I|>eKbs54;FA1-62&L^Mp;xl-ri=>S zvhN6cxp(Z(1(kdFndb}t+i=nB0z3#hJha}kzwzv}zlJ4ZtVooI%O`Z13!nZA DIXW8@ delta 1169 zcmYL}%Trr*6vscmikxpP;m=SFBJGxvAT?{^-b^ZlKhuN(iaH-5SQ z!;iq@e6(Z4I(2-Cx+|%zR4iu|V~Kov%_(bhNfzBebpMh;BTYKZCM_JYKT|6z@QJI*-^yVp_J|^AEBE1s{v|){bm$y4IYy_V z+x|iY?W}96qgzqCa4na!3X2mLCUaZ)tU)i2==7QNGhqMb>h*OIcG5-c`>t3pCh)UT zK9#Yi@`e0Ls%RNRIqrB2+2`FOK7&V1Mi{kkx_f-RoG_*Hxc!|w=0C|Pozo^yaK`@2 zJuHV$noMxk?$<^o?3~F{OxYQ&+kc*?b!JRvnX^CDdfYk}cD`vb40IMu5-i$3X))hC zOHSE~_C2jV7$s@)JfjLE`s9*o$dT9aZkSx9uybx$741JfoxWAJOkQK#*1X5m8+NZZt=_Xg_I_S^9hZy? zXb31?dA=!DP*x?YXJ8j~M_v?f$sSRn87fm#-*{_RuC3nv z=l3+sMJlu=!;+@$E%-(yfGx~-G;N}t!c zvDfEUdm7KFng3;-t+1M`3VmhfTV8G06in&%+FaO?JMvI&vAe|Hm%FO=?SFrri|qBV zT*H+7_M3>}7m^WaX;c7C$W=Syk4Z}>1^E<{oEGmhOfxQ@%S4sC4%a`8oe diff --git a/Implementation/src/TCPEchange.java b/Implementation/src/TCPEchange.java index 6088a46..405b5f7 100644 --- a/Implementation/src/TCPEchange.java +++ b/Implementation/src/TCPEchange.java @@ -20,7 +20,9 @@ import java.io.InputStreamReader; 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())); @@ -52,8 +54,10 @@ public class TCPEchange { 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(); @@ -87,7 +91,7 @@ class RunnerTCPEnvoi implements Runnable { } @Override public void run() { - System.out.println("Thread started"); + System.out.println("Creation d'un thread d'envoi"); String msg; while(true){ msg = sc.nextLine(); @@ -102,7 +106,7 @@ class RunnerTCPEnvoi implements Runnable { class RunnerTCPEcoute implements Runnable { final Socket link; private ChatApp app ; - + public RunnerTCPEcoute(Socket link,ChatApp app ) { this.link = link; this.app = app; @@ -110,7 +114,7 @@ class RunnerTCPEcoute implements Runnable { @Override public void run() { - System.out.println("Thread started"); + System.out.println("Creation d'un thread d'ecoute"); try { PrintStream output = new PrintStream(link.getOutputStream()); //InputStream is = link.getInputStream();