¿Por qué recibo el doble de datos enviados a través de la difusión UDP?

Question

Tengo un problema con el código de abajo. Lo que hace es enviar la fecha / hora actual usando la difusión UDP y escucha a este mensaje. Mi uso actual de este código es local, utilizo el enviar y recibir en la misma aplicación, en el mismo equipo. Yo no lo probamos entre 2 ordenadores todavía.

public class Agent
{
    public static int Port = 33333;
    public delegate void OnMessageHandler(string message);

    Socket socketSend;
    Socket socketReceive;

    bool receiving = false;
    Thread receiveThread;

    public event OnMessageHandler OnMessage;

    public Agent()
    {
        socketSend = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        socketSend.EnableBroadcast = true;

        socketSend.Connect(new IPEndPoint(IPAddress.Broadcast, Port));

        socketReceive = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        socketReceive.EnableBroadcast = true;

        socketReceive.Bind(new IPEndPoint(IPAddress.Any, Port));
    }

    public void Start()
    {
        Console.WriteLine("Agent started!");

        receiving = true;
        receiveThread = new Thread(new ThreadStart(Receive));
        receiveThread.IsBackground = true;
        receiveThread.Start();
    }

    public void Stop()
    {
        receiving = false;

        socketSend.Close();
        socketReceive.Close();

        receiveThread.Join();

        Console.WriteLine("Agent ended.");
    }

    public void Send(string message)
    {
        Console.WriteLine("Sending : {0}", message);
        byte[] bytes = Encoding.Convert(Encoding.Unicode, Encoding.UTF8, Encoding.Unicode.GetBytes(message));
        socketSend.Send(bytes);
        Console.WriteLine("Message sent.");
    }

    protected void Receive()
    {
        Console.WriteLine("Thread started!");
        while (receiving)
        {
            try
            {
                if (socketReceive.Available > 0)
                {
                    byte[] bytes = new byte[socketReceive.Available];

                    Console.WriteLine("Waiting for receive...");

                    int bytesReceived = socketReceive.Receive(bytes, SocketFlags.None);
                    Console.WriteLine("Bytes received : {0}", bytesReceived);

                    string message = Encoding.UTF8.GetString(bytes);
                    Console.WriteLine("Received message : {0}", message);
                    OnMessage(message);
                }
                else
                {
                    Console.Write(".");
                    Thread.Sleep(200);
                }
            }
            catch (SocketException ex)
            {
                if (ex.SocketErrorCode == SocketError.Interrupted)
                {
                    break;
                }
                else
                {
                    throw;
                }
            }
        }
        Console.WriteLine("Thread ended.");
    }
}

El problema que tengo es que envía los datos una vez (al hacer clic en un botón) pero recibe el doble de la cantidad esperada. Por ejemplo, una fecha / hora normal es de 19 bytes de longitud, pero la primera vez disponible es> 0, su valor es de 38. La recepción de llamadas siguiente sólo se agarra 19 bytes y el bucle continúa con los siguientes 19 bytes. Eso significa que reciba mi mensaje y dos veces y lo quiero sólo una vez, por supuesto.

Ejemplo de salida:

Agent started!
Thread started!
..........Sending : 29/07/2009 12:05:04
Message sent.
Waiting for receive...
Bytes received : 19
Received message : 29/07/2009 12:05:04
Waiting for receive...
Bytes received : 19
Received message : 29/07/2009 12:05:04
......Thread ended.
Agent ended.

Answer 1

socketReceive.Bind(new IPEndPoint(IPAddress.Any, Port));

Al unirse a todas las direcciones IP, que voy a recibir de bucle local y a través de la red también.

Answer 2

Le aconsejo que probar esto en un destino especificado IP primero. De esta manera la topografía de la red tendrá un efecto menor, y puedes moverlo a una dirección de difusión cuando todo funciona de la forma esperada.