:🐛: Serveur arrive à recevoir les données du client.
continuous-integration/drone/push Build is failing Details

pull/6/head
Bruno DA COSTA CUNHA 2 years ago
parent f95ed4d31f
commit 3da35e99cf

@ -24,13 +24,15 @@ class Program
// Receive connection message from server // Receive connection message from server
IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0); IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0);
byte[] receivedData = client.Receive(ref remoteEndPoint); byte[] receivedData = client.Receive(ref remoteEndPoint);
string receivedMessage = Encoding.ASCII.GetString(receivedData); string receivedPort = Encoding.ASCII.GetString(receivedData);
Console.WriteLine("Received message: " + receivedMessage); Console.WriteLine("Received port: " + receivedPort);
// Send data to server // Send data to server
string message = ""; string message = "";
while (message != "exit") while (message != "exit")
{ {
serverEndPoint = new IPEndPoint(IPAddress.Parse("127.0.0.1"), int.Parse(receivedPort));
Console.Write("Enter message to send (or 'exit' to quit): "); Console.Write("Enter message to send (or 'exit' to quit): ");
message = Console.ReadLine(); message = Console.ReadLine();
byte[] data = Encoding.ASCII.GetBytes(message); byte[] data = Encoding.ASCII.GetBytes(message);

@ -38,31 +38,27 @@ class Program
clients[remoteEndPoint] = clientSocket; clients[remoteEndPoint] = clientSocket;
// Send connection message to client // Send connection message to client
string connectionMessage = "Connection established on port " + clientEndPoint.Port.ToString(); string connectionMessage = clientEndPoint.Port.ToString();
byte[] connectionData = Encoding.ASCII.GetBytes(connectionMessage); byte[] connectionData = Encoding.ASCII.GetBytes(connectionMessage);
serverSocket.Send(connectionData, connectionData.Length, remoteEndPoint); serverSocket.Send(connectionData, connectionData.Length, remoteEndPoint);
// Start thread to receive data from client // Start thread to receive data from client
Thread receiveThread = new Thread(ReceiveMessages); Thread receiveThread = new Thread(()=>ReceiveMessages(clientSocket));
receiveThread.Start(clientSocket); receiveThread.Start();
} }
} }
} }
static void ReceiveMessages(object obj) static void ReceiveMessages(UdpClient clientSocket)
{ {
UdpClient clientSocket = (UdpClient)obj;
IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0); IPEndPoint remoteEndPoint = new IPEndPoint(IPAddress.Any, 0);
while (true) while (true)
{ {
byte[] receivedData = clientSocket.Receive(ref remoteEndPoint); byte[] receivedData = clientSocket.Receive(ref remoteEndPoint);
Console.WriteLine("PORRA");
string receivedMessage = Encoding.ASCII.GetString(receivedData); string receivedMessage = Encoding.ASCII.GetString(receivedData);
Console.WriteLine("PORRA2");
Console.WriteLine("Received from " + remoteEndPoint.ToString() + ": " + receivedMessage); Console.WriteLine("Received from " + remoteEndPoint.ToString() + ": " + receivedMessage);
Console.WriteLine("PORRA3");
} }
} }

Loading…
Cancel
Save