authentification avec pass et user

projet/.classpath

-<?xml version="1.0" encoding="UTF-8"?>
-<classpath>
-	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/JavaSE-15">
-		<attributes>
-			<attribute name="module" value="true"/>
-		</attributes>
-	</classpathentry>
-	<classpathentry kind="src" path="src"/>
-	<classpathentry kind="output" path="bin"/>
-</classpath>

projet/.settings/org.eclipse.jdt.core.prefs

-eclipse.preferences.version=1
-org.eclipse.jdt.core.compiler.codegen.inlineJsrBytecode=enabled
-org.eclipse.jdt.core.compiler.codegen.targetPlatform=15
-org.eclipse.jdt.core.compiler.codegen.unusedLocal=preserve
-org.eclipse.jdt.core.compiler.compliance=15
-org.eclipse.jdt.core.compiler.debug.lineNumber=generate
-org.eclipse.jdt.core.compiler.debug.localVariable=generate
-org.eclipse.jdt.core.compiler.debug.sourceFile=generate
-org.eclipse.jdt.core.compiler.problem.assertIdentifier=error
-org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
-org.eclipse.jdt.core.compiler.problem.enumIdentifier=error
-org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=warning
-org.eclipse.jdt.core.compiler.release=enabled
-org.eclipse.jdt.core.compiler.source=15

projet/src/module-info.java

-module projet {
-}
\ No newline at end of file

projet/src/projet/Client.java

-package projet;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.PrintWriter;
-import java.net.Socket;
-import java.util.Scanner;
-
-public class Client {
-
-   public static void main(String[] args) {
-      
-      final Socket clientSocket;
-      final BufferedReader in;
-      final PrintWriter out;
-      final Scanner sc = new Scanner(System.in);//lire à partir du clavier
-  
-      try {
-         /*
-         * les informations du serveur ( port et adresse IP
-         * 127.0.0.1 est l'adresse local de la machine
-         */
-         clientSocket = new Socket("127.0.0.1",5000);
-   
-         //flux pour envoyer
-         out = new PrintWriter(clientSocket.getOutputStream());
-         //flux pour recevoir
-         in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
-   
-         Thread envoyer = new Thread(new Runnable() {
-             String msg;
-              @Override
-              public void run() {
-                while(true){
-                  msg = sc.nextLine();
-                  out.println(msg);
-                  out.flush();
-                }
-             }
-         });
-         envoyer.start();
-   
-        Thread recevoir = new Thread(new Runnable() {
-            String msg;
-            @Override
-            public void run() {
-               try {
-                 msg = in.readLine();
-                 while(msg!=null){
-                    System.out.println("Serveur : "+msg);
-                    msg = in.readLine();
-                 }
-                 System.out.println("Serveur déconecté");
-                 out.close();
-                 clientSocket.close();
-               } catch (IOException e) {
-                   e.printStackTrace();
-               }
-            }
-        });
-        recevoir.start();
-   
-      } catch (IOException e) {
-           e.printStackTrace();
-      }
-  }
-}

projet/src/projet/Serveur.java

-package projet;
-
-import java.io.BufferedReader;
-import java.io.IOException;
-import java.io.InputStreamReader;
-import java.io.PrintWriter;
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.util.Scanner;
-
-public class Serveur {
- 
-   public static void main(String[] test) {
-  
-     final ServerSocket serveurSocket  ;
-     final Socket clientSocket ;
-     final BufferedReader in;
-     final PrintWriter out;
-     final Scanner sc=new Scanner(System.in);
-  
-     try {
-       serveurSocket = new ServerSocket(5000);
-       clientSocket = serveurSocket.accept();
-       out = new PrintWriter(clientSocket.getOutputStream());
-       in = new BufferedReader (new InputStreamReader (clientSocket.getInputStream()));
-       Thread envoi= new Thread(new Runnable() {
-          String msg;
-          @Override
-          public void run() {
-             while(true){
-                msg = sc.nextLine();
-                out.println(msg);
-                out.flush();
-             }
-          }
-       });
-       envoi.start();
-   
-       Thread recevoir= new Thread(new Runnable() {
-          String msg ;
-          @Override
-          public void run() {
-             try {
-                msg = in.readLine();
-                //tant que le client est connecté
-                while(msg!=null){
-                   System.out.println("Client : "+msg);
-                   msg = in.readLine();
-                }
-                //sortir de la boucle si le client a déconecté
-                System.out.println("Client déconecté");
-                //fermer le flux et la session socket
-                out.close();
-                clientSocket.close();
-                serveurSocket.close();
-             } catch (IOException e) {
-                  e.printStackTrace();
-             }
-         }
-      });
-      recevoir.start();
-      }catch (IOException e) {
-         e.printStackTrace();
-      }
-   }
-}

projetSR/.classpath

+<?xml version="1.0" encoding="UTF-8"?>
+<classpath>
+	<classpathentry kind="src" output="target/classes" path="src/main/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="src" output="target/test-classes" path="src/test/java">
+		<attributes>
+			<attribute name="optional" value="true"/>
+			<attribute name="maven.pomderived" value="true"/>
+			<attribute name="test" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.jdt.launching.JRE_CONTAINER/org.eclipse.jdt.internal.debug.ui.launcher.StandardVMType/J2SE-1.5">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="con" path="org.eclipse.m2e.MAVEN2_CLASSPATH_CONTAINER">
+		<attributes>
+			<attribute name="maven.pomderived" value="true"/>
+		</attributes>
+	</classpathentry>
+	<classpathentry kind="output" path="target/classes"/>
+</classpath>

projet/.project → projetSR/.project

 <?xml version="1.0" encoding="UTF-8"?>
 <projectDescription>
-	<name>projet</name>
+	<name>projetSR</name>
 	<comment></comment>
 	<projects>
 	</projects>
@@ -10,8 +10,14 @@
 			<arguments>
 			</arguments>
 		</buildCommand>
+		<buildCommand>
+			<name>org.eclipse.m2e.core.maven2Builder</name>
+			<arguments>
+			</arguments>
+		</buildCommand>
 	</buildSpec>
 	<natures>
 		<nature>org.eclipse.jdt.core.javanature</nature>
+		<nature>org.eclipse.m2e.core.maven2Nature</nature>
 	</natures>
 </projectDescription>

projetSR/.settings/org.eclipse.core.resources.prefs

+eclipse.preferences.version=1
+encoding//src/main/java=UTF-8
+encoding//src/test/java=UTF-8
+encoding/<project>=UTF-8

projetSR/.settings/org.eclipse.jdt.core.prefs

+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.5
+org.eclipse.jdt.core.compiler.compliance=1.5
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.5

projetSR/pom.xml

+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <groupId>org.sr</groupId>
+  <artifactId>projetSR</artifactId>
+  <version>1.0-SNAPSHOT</version>
+  <packaging>jar</packaging>
+
+  <name>projetSR</name>
+  <url>http://maven.apache.org</url>
+
+  <properties>
+    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+  </properties>
+
+  <dependencies>
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>3.8.1</version>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+</project>

projetSR/src/main/java/org/sr/App.java

+package org.sr;
+
+/**
+ * Hello world!
+ *
+ */
+public class App 
+{
+    public static void main( String[] args )
+    {
+        System.out.println( "Hello World!" );
+    }
+}

projetSR/src/main/java/org/sr/Authentification.java

+package org.sr;
+
+import java.io.*;
+import java.net.Socket;
+import java.util.StringTokenizer;
+
+public class Authentification {
+    private Socket mysocket = null;
+    private BufferedReader myBufferedReader = null;
+    private BufferedWriter myBufferedWriter = null;
+    private String adress;
+    private int port;
+    private String user;
+    private String passWord;
+	
+	public synchronized void connect() throws IOException {
+    	if (mysocket != null) {
+            throw new IOException("erreur FTP");
+        }
+        
+        mysocket = new Socket(adress, port);
+        myBufferedReader = new BufferedReader(new InputStreamReader(mysocket.getInputStream()));
+        myBufferedWriter = new BufferedWriter(new OutputStreamWriter(mysocket.getOutputStream()));
+
+        String reponse = receive();
+        
+        if (!reponse.startsWith("220 ")) throw new IOException("erreur" + reponse);
+
+        sendCommande("USER " + user);
+        reponse = receive();
+       
+        if (!reponse.startsWith("331 ")) throw new IOException("erreur" + reponse);
+
+        sendCommande("PASS " + passWord);
+        reponse = receive();
+        if (!reponse.startsWith("230 ")) throw new IOException("erreur" + reponse);
+    }
+    
+	private void sendCommande(String line) throws IOException {
+        if (mysocket == null) {
+            throw new IOException("erreur ftp");
+        }
+        try {
+        	myBufferedWriter.write(line + "\r\n");
+        	myBufferedWriter.flush();
+        } catch (IOException e) {
+            mysocket = null;
+            throw e;
+        }
+    }
+    private String receive() throws IOException {
+        String line = myBufferedReader.readLine();
+        return line;
+    }
+	
+	
+
+}

projetSR/src/test/java/org/sr/AppTest.java

+package org.sr;
+
+import junit.framework.Test;
+import junit.framework.TestCase;
+import junit.framework.TestSuite;
+
+/**
+ * Unit test for simple App.
+ */
+public class AppTest 
+    extends TestCase
+{
+    /**
+     * Create the test case
+     *
+     * @param testName name of the test case
+     */
+    public AppTest( String testName )
+    {
+        super( testName );
+    }
+
+    /**
+     * @return the suite of tests being tested
+     */
+    public static Test suite()
+    {
+        return new TestSuite( AppTest.class );
+    }
+
+    /**
+     * Rigourous Test :-)
+     */
+    public void testApp()
+    {
+        assertTrue( true );
+    }
+}