Modification des fichiers serveurs et client pour optimiser la communication TCP

Author: lduf

src/Client.go

@@ -9,6 +9,7 @@ import (
 	"os"
 	"path/filepath"
 	"strconv"
+	"strings"
 	"time"
 )
 
@@ -107,15 +108,15 @@ func main() {
 		outfile := fmt.Sprintf("out/%v", filepath.Base(filename)) // ou nomme le fichier de sortir en fonction de celui d'entrée
 		content := ""
 		for {
-			resultString, err := reader.ReadString('\n') //Là on attend la réponse du serveur (par le reader instancié plus tôt)
+			resultString, err := reader.ReadString('#') //Là on attend la réponse du serveur (par le reader instancié plus tôt)
 
 			if err != nil { //dès qu'on a une erreur on arrete de recevoir
 				fmt.Printf("Fin de traitement du serveur \n")
 				break //on sort de la boucle
 			}
 
 			//fmt.Printf("Réponse du serveur : %v \n ", resultString) DEBUG
-			content += resultString //on incremente content avec les résultats récupérés à chaque passage dans le for
+			content += strings.TrimSuffix(resultString, "#") //on incremente content avec les résultats récupérés à chaque passage dans le for
 
 		}
 		fmt.Printf("Réception et traitement des données in : %s\n", time.Since(s))

src/Server.go

@@ -227,6 +227,7 @@ func handleConnection(connect net.Conn) {
 
 	var slice []elementGraph
 	var noeuds []int
+	var out string
 	start := time.Now()
 	for { //équivalent While true
 		inputLine, err := connectReader.ReadString('\n') //on récupère la ligne envoyée par le client jusqu'au retour à la ligne
@@ -258,13 +259,22 @@ func handleConnection(connect net.Conn) {
 	fmt.Printf("Dijkstra done in : %s\n", time.Since(start))
 
 	start = time.Now()
+	out = ""
+	//writer := bufio.NewWriter(connect)
 	for letter, graph := range ways {
 		for l, way := range graph {
-			out := fmt.Sprintf("%v %v %v %v \n", letter, l, way, distances[letter][l]) // 1 2 [1 3 4 8 4 2] 56 //point de départ | point d'arrivé | liste des points par lesquels je passe | poids
-			//fmt.Printf("Envoie de : %v", out) DEBUG
-			io.WriteString(connect, fmt.Sprintf("%s", out))
+			out += fmt.Sprintf("%v %v %v %v \n", letter, l, way, distances[letter][l]) // 1 2 [1 3 4 8 4 2] 56 //point de départ | point d'arrivé | liste des points par lesquels je passe | poids
+			//fmt.Printf("Envoie de : %v", out) //DEBUG
+			/*writer.WriteString(out)
+			err := writer.Flush()
+			if err != nil {
+				fmt.Printf("%s", err)
+			}*/
 		}
 	}
+
+	out += "#"
+	io.WriteString(connect, fmt.Sprintf("%s ", out))
 	fmt.Printf("Envoie des données en : %s\n", time.Since(start))
 }