Chat/ChatMessage.cs

@@ -5,7 +5,8 @@ using System.Text;
 
 namespace ClientUdp
 {
-    public enum Commande { 
+    public enum Commande
+    {
         POST, GET, HELP, QUIT, STOPSERVEUR, SUBSCRIBE, SUBSCRIBEv2, UNSUBSCRIBE
     };
 
@@ -25,15 +26,30 @@ namespace ClientUdp
             this.commande = commande;
             this.commandeType = type;
             this.dataSize = data.Length;
+            this.pseudo = pseudo;
             this.data = data;
         }
 
         public ChatMessage(byte[] buffer)
         {
+            // Decodage du buffer de bytes en ASCII vers un string
+            String msg = System.Text.Encoding.ASCII.GetString(buffer, 0, nBytes);
         }
 
         public byte[] GetBytes()
         {
+            byte[] b = new byte[bufferSize];
+
+            b[0] = (byte)this.commande;
+            b[1] = (byte)this.commandeType;
+            Encoding.ASCII.GetBytes(pseudo, 0, pseudo.Length, b, 2);
+            Encoding.ASCII.GetBytes(data, 0, data.Length, b, 33);
+        }
+
+        public static byte[] GetBytes(Commande commande, CommandeType type, String pseudo, String data)
+        {
+            ChatMessage chatCommande = new ChatMessage(commande, type, pseudo, data);
+            return chatCommande.GetBytes;
         }
 
         public override string ToString()
@@ -42,4 +58,4 @@ namespace ClientUdp
         }
 
     }
-}
+}
\ No newline at end of file

Chat/clientUdp/clientUdp/ChatMessage.cs

+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+
+namespace ClientUdp
+{
+    public enum Commande
+    {
+        POST, GET, HELP, QUIT, STOPSERVEUR, SUBSCRIBE, SUBSCRIBEv2, UNSUBSCRIBE
+    };
+
+    public enum CommandeType { REQUETE, REPONSE };
+
+    class ChatMessage
+    {
+        public const int bufferSize = 1500;
+        public const int pseudoSize = 20;
+        public const int messageSize = bufferSize - (pseudoSize + 2);
+
+        public Commande commande;               // commande
+        public CommandeType commandeType;       // type (Requête/Réponse)
+        public int dataSize;                    // taille de la donnée
+        public String pseudo;                   // pseudo
+        public String data;                     // données de la commande
+
+        public ChatMessage(Commande commande, CommandeType type,String pseudo, String data)
+        {
+            this.commande = commande;
+            this.commandeType = type;
+            this.dataSize = data.Length;
+            if (pseudo.Length > pseudoSize)
+            {
+                pseudo = pseudo.Substring(0, pseudoSize);
+            }
+            this.pseudo = pseudo;
+            if (data.Length > messageSize)
+            {
+                data = data.Substring(pseudoSize+2, messageSize);
+            }
+            this.data = data;
+        }
+
+        public ChatMessage(byte[] buffer)
+        {
+            this.commande = (Commande)buffer[0];
+            this.commandeType = (CommandeType)buffer[1];
+            // Decodage du buffer de bytes en ASCII vers un string
+            this.pseudo = System.Text.Encoding.ASCII.GetString(buffer, 2, pseudoSize).TrimEnd('\0');
+            this.data = System.Text.Encoding.ASCII.GetString(buffer, pseudoSize+2, bufferSize-(pseudoSize+2)).TrimEnd('\0');
+            this.dataSize = data.Length;
+        }
+
+        public byte[] GetBytes()
+        {
+            byte[] b = new byte[bufferSize];
+
+            b[0] = (byte)this.commande;
+            b[1] = (byte)this.commandeType;
+            Encoding.ASCII.GetBytes(pseudo, 0, pseudo.Length, b, 2);
+            Encoding.ASCII.GetBytes(data, 0, data.Length, b, 22);
+            return b;
+        }
+
+        public static byte[] GetBytes(Commande commande, CommandeType type, String pseudo, String data)
+        {
+            ChatMessage chatCommande = new ChatMessage(commande, type, pseudo, data);
+            return chatCommande.GetBytes();
+        }
+
+        public override string ToString()
+        {
+            return "[" + commande + "," + commandeType + ",\"" + pseudo + "\"," + dataSize + ",\"" + data + "\"]";
+        }
+
+    }
+}
\ No newline at end of file

Chat/clientUdp/clientUdp/ClientUdp.cs

@@ -16,9 +16,8 @@ namespace ClientUdp
             {
                 
                 //************************************************************** Initialisation
-                string serverIP = "0.0.0.0";    // A changer
-                int serverPort = 000000 ;       // A changer
-
+                string serverIP = "130.79.81.203";    // A changer
+                int serverPort = 11111;       // A changer
 
                 // Création de la socket d'écoute UDP
                 Socket clientSocket = new Socket(
@@ -34,40 +33,69 @@ namespace ClientUdp
                 // Création du EndPoint serveur
                 EndPoint serverEP = new IPEndPoint(IPAddress.Parse(serverIP), serverPort);
 
+                // Création du nouveau chat message
+                ChatMessage[] chatMessages = {
+                    new ChatMessage(Commande.SUBSCRIBE, CommandeType.REQUETE, "William", "Je suis subscribe"),
+                    //new ChatMessage(Commande.POST, CommandeType.REQUETE, "Jean-Pierre", "Hello World !"),
+                    //new ChatMessage(Commande.POST, CommandeType.REQUETE, "Jacques", "aurevoir aurevoir"),
+                    //new ChatMessage(Commande.UNSUBSCRIBE, CommandeType.REQUETE, "William", "Je suis unsubscribe"),
+                    new ChatMessage(Commande.POST, CommandeType.REQUETE, "William", "aurevoir aurevoir"),
+                    //new ChatMessage(Commande.GET, CommandeType.REQUETE, "caca", "pipi"),
+                    /*new ChatMessage(Commande.STOPSERVEUR, CommandeType.REQUETE, "", "")*/};
 
-                // Lecture message au clavier
-                Console.Write("? ");
-                String msg = Console.ReadLine();
-
-
-                //************************************************************** Communications
                 
-                // Encodage du string dans un buffer de bytes en ASCII
-                byte[] buffer = System.Text.Encoding.ASCII.GetBytes(msg);
-                Console.WriteLine("Taille buffer : "+buffer.Length);
-
-                // Envoie du message au serveur
-                int nBytes = clientSocket.SendTo(buffer, 0, buffer.Length, SocketFlags.None, serverEP);
 
-                Console.WriteLine("Nouveau message envoye vers "
-                    + serverEP
-                    + " (" + nBytes + " octets)"
-                    + ": \"" + msg + "\"");
-
-
-                //************************************************************** Conclusion
-                // Fermeture socket
-                Console.WriteLine("Fermeture Socket...");
-                clientSocket.Close();
+                //************************************************************** Communications
 
+                foreach (ChatMessage chatMessage in chatMessages)
+                {
+                    // Encodage du string dans un buffer de bytes en ASCII
+                    byte[] buffer = chatMessage.GetBytes();
+                    Console.WriteLine("Taille buffer : " + buffer.Length);
+                    int nBytes;
+
+                    nBytes = clientSocket.SendTo(buffer, 0, buffer.Length, SocketFlags.None, serverEP);
+                    Console.WriteLine("Nouveau message envoye vers: " + chatMessage);
+
+                    switch (chatMessage.commande)
+                    {
+                        case Commande.POST:
+                            break;
+                        case Commande.GET:
+                            break;
+                        case Commande.STOPSERVEUR:
+                            break;
+                        case Commande.SUBSCRIBE:
+                            while (true)
+                            {
+                                buffer = new Byte[ChatMessage.bufferSize];
+                                nBytes = clientSocket.ReceiveFrom(buffer, buffer.Length, SocketFlags.None, ref serverEP);
+                                ChatMessage cmRecuSub = new ChatMessage(buffer);
+                                Console.WriteLine("Message reçu: " + cmRecuSub);
+                            }
+                            break;
+                        case Commande.UNSUBSCRIBE:
+                            break;
+                    }
+
+                    buffer = new Byte[ChatMessage.bufferSize];
+                    nBytes = clientSocket.ReceiveFrom(buffer, buffer.Length, SocketFlags.None, ref serverEP);
+                    ChatMessage cmRecu = new ChatMessage(buffer);
+                    Console.WriteLine("Message reçu: " + cmRecu);
+                }
+                
 
+              //************************************************************** Conclusion
+              // Fermeture socket
+              Console.WriteLine("Fermeture Socket...");
+              clientSocket.Close();
             }
             catch (SocketException E)
             {
                 Console.WriteLine(E.Message);
                 Console.ReadKey();
             }
-
+            
             Console.ReadKey();
         }
     }

Chat/clientUdp/clientUdp/bin/Debug/clientUdp.vshost.exe.manifest

+<?xml version="1.0" encoding="UTF-8" standalone="yes"?>
+<assembly xmlns="urn:schemas-microsoft-com:asm.v1" manifestVersion="1.0">
+  <assemblyIdentity version="1.0.0.0" name="MyApplication.app"/>
+  <trustInfo xmlns="urn:schemas-microsoft-com:asm.v2">
+    <security>
+      <requestedPrivileges xmlns="urn:schemas-microsoft-com:asm.v3">
+        <requestedExecutionLevel level="asInvoker" uiAccess="false"/>
+      </requestedPrivileges>
+    </security>
+  </trustInfo>
+</assembly>

Chat/clientUdp/clientUdp/clientUdp.csproj

@@ -58,6 +58,7 @@
     <Reference Include="System.Xml" />
   </ItemGroup>
   <ItemGroup>
+    <Compile Include="ChatMessage.cs" />
     <Compile Include="ClientUdp.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
   </ItemGroup>

Chat/clientUdp/clientUdp/obj/x86/Debug/clientUdp.csproj.CoreCompileInputs.cache

+347d8d7d626bd3c2f6896d987099347a913054d2

Chat/clientUdp/clientUdp/obj/x86/Debug/clientUdp.csproj.FileListAbsolute.txt

+\\vfiler-ad-etu.ad.unistra.fr\wguthmann\Bureau\S32\Chat\clientUdp\clientUdp\bin\Debug\clientUdp.exe
+\\vfiler-ad-etu.ad.unistra.fr\wguthmann\Bureau\S32\Chat\clientUdp\clientUdp\bin\Debug\clientUdp.pdb
+\\vfiler-ad-etu.ad.unistra.fr\wguthmann\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.exe
+\\vfiler-ad-etu.ad.unistra.fr\wguthmann\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.pdb
+\\vfiler-ad-etu.ad.unistra.fr\wguthmann\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.csprojResolveAssemblyReference.cache
+U:\Bureau\S32\Chat\clientUdp\clientUdp\bin\Debug\clientUdp.exe
+U:\Bureau\S32\Chat\clientUdp\clientUdp\bin\Debug\clientUdp.pdb
+U:\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.csprojAssemblyReference.cache
+U:\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.csproj.CoreCompileInputs.cache
+U:\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.exe
+U:\Bureau\S32\Chat\clientUdp\clientUdp\obj\x86\Debug\clientUdp.pdb