pour chemszer

src/Main.java

@@ -1,7 +1,5 @@
 public class Main {
     public static void main(String[] args){
-        User user1 = new User("elyes");
-
-
+        User user1 = new User("elyes2");
     }
 }

src/SendMessage.java

@@ -7,31 +7,22 @@
 
 public class SendMessage {
 
-    private static DatagramSocket socket_envoi;
-    private static DatagramSocket socket_ecoute;
-
-    public static DatagramSocket getSocketEcoute() {
-        return socket_ecoute;
-    }
-
-    public static DatagramSocket getSocketEnvoi(){
-        return socket_envoi;
-    }
-
     public static void sendMessage(InetAddress address, int port, User user) throws IOException {
-
+        
         try {
             sleep(1000);
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
 
+        //String data = user.getPseudo();
         String data = user.getPseudo();
         DatagramPacket packet = new DatagramPacket(data.getBytes(),
-                data.getBytes().length, address, port);
-        System.out.println("J'ai bien envoyé mon paquet à " + address+ "sur le port : " + port + "\n temps : "+ System.currentTimeMillis());
-
-        socket_envoi.send(packet);
+                data.getBytes().length, address, 45047);
+        System.out.println("J'ai renvoyé mon paquet apres l'ecoute sur le port : " + 45047);
+
+
+        User.getSocketEcoute().send(packet);
 
 
     }

src/ThreadReceive.java

@@ -45,6 +45,8 @@ public static void receiveMessage() throws IOException {
 
 
             ajoutUserListe(recvStr, addr.toString());
+            SendMessage.sendMessage(addr, port, user);
+
 
         }
 

src/ThreadSend.java

@@ -1,6 +1,8 @@
 import java.io.IOException;
 import java.net.DatagramPacket;
 import java.net.InetAddress;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 public class ThreadSend extends Thread{
 
@@ -11,18 +13,13 @@ public ThreadSend(String name, User user){
     }
 
     public void run(){
+
         try {
-            for(int i=0;i<10;i++) {
-                sendMessageBroadcast(user);
-                try {
-                    sleep(3000);
-                } catch (InterruptedException e) {
-                    e.printStackTrace();
-                }
-            }
-        } catch (IOException e) {
-            e.printStackTrace();
+            sendMessageBroadcast(user);
+        } catch (IOException ex) {
+            Logger.getLogger(ThreadSend.class.getName()).log(Level.SEVERE, null, ex);
         }
+
     }
 
     public static void sendMessageBroadcast(User user) throws IOException {

src/User.java

@@ -31,7 +31,7 @@ public User(String pseudo){
 
         System.out.println("J'ai crée un utilisateur ; son pseudo est : " + pseudo );
         Thread threadSend = new ThreadSend("thread send", this);
-       // threadSend.start();
+        threadSend.start();
 
         Thread threadReceive = new ThreadReceive("thread receive", this);
         threadReceive.start();