как клиент может получать более одного широковещательного сообщения, когда транслируется более одного сервера?

Я использую system.Net.Socket для отправки и получения сообщений с сервера на клиент. Но я сталкиваюсь с проблемой, когда несколько серверов передают сообщение, а затем программа-приемник внезапно закрывается.

Код моего сервера для вещания выглядит следующим образом.

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

public class Broadcst
{
    public static void Main()
    {
        Socket sock = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp);
        IPEndPoint iep1 = new IPEndPoint(IPAddress.Broadcast, 9050);
        IPEndPoint iep2 = new IPEndPoint(IPAddress.Parse("192.168.1.255"), 9050);

        string hostname = Dns.GetHostName();
        byte[] data = Encoding.ASCII.GetBytes(hostname);

        sock.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.Broadcast, 1);
        sock.SendTo(data, iep1);
        sock.SendTo(data, iep2);
        sock.Close();
    }
}

Мой код приемника для клиента выглядит следующим образом...

  using System;
    using System.Net;
    using System.Net.Sockets;
    using System.Text;

    public class RecvBroadcst
    {
        public static void Main()
        {
            Socket sock = new Socket(AddressFamily.InterNetwork,
                            SocketType.Dgram, ProtocolType.Udp);

While(true){
  IPEndPoint iep = new IPEndPoint(IPAddress.Any, 9050);
            sock.Bind(iep);
            EndPoint ep = (EndPoint)iep;
            Console.WriteLine("Ready to receive...");

            byte[] data = new byte[1024];
            int recv = sock.ReceiveFrom(data, ref ep);
            string stringData = Encoding.ASCII.GetString(data, 0, recv);
            Console.WriteLine("received: {0}  from: {1}",
                                  stringData, ep.ToString());

            data = new byte[1024];
            recv = sock.ReceiveFrom(data, ref ep);
            stringData = Encoding.ASCII.GetString(data, 0, recv);
            Console.WriteLine("received: {0}  from: {1}",
                                  stringData, ep.ToString());

}
            sock.Close();
        }
    }

Итак, как клиент может получить более одного широковещательного сообщения, если существует более одного широковещательного сервера?

когда я снова отправляю сообщение с сервера, возникает ошибка, например: «Обычно разрешено только одно использование каждого адреса сокета (протокол/сетевой адрес/порт)»


c# sockets broadcastreceiver client-server inter-process-communicat
person User 1531343    schedule 18.09.2012    source источник
comment
Ваша программа-приемник «внезапно завершает работу», как только она получает одно сообщение, потому что именно так вы ее написали. Если вы хотите, чтобы он получал более одного сообщения, измените код соответствующим образом. В чем здесь вопрос?   -  person user207421    schedule 18.09.2012
comment
я вставил этот код, пока он верен, но при отправке следующего сообщения с сервера он должен быть близок к тому, чтобы иметь какое-либо сообщение. см. мой обновленный вопрос   -  person User 1531343    schedule 18.09.2012
comment
Программа не просто закрывается. Это не удается из-за необработанного исключения. Важно интерпретировать это исключение.   -  person usr    schedule 18.09.2012

Ответы (2)


arrow_upward
2
arrow_downward

Вы вызываете Bind для одного и того же экземпляра Socket с одними и теми же параметрами несколько раз (по одному на итерацию). Вы должны позвонить Bind один раз.

person usr    schedule 18.09.2012

arrow_upward
0
arrow_downward

Я решил проблему с изменением моего кода выше, следуя на стороне получателя. Я просто привязывал сокет каждый раз, поэтому сейчас я привязываю его один раз и каждый раз повторяю только входящие данные из указанного порта.

using System;
using System.Net;
using System.Net.Sockets;
using System.Text;

public class RecvBroadcst
{
    public static void Main()
    {
       Socket sock = new Socket(AddressFamily.InterNetwork,
                           SocketType.Dgram, ProtocolType.Udp);
     //  int port_no=Convert.ToInt32(sock.RemoteEndPoint);


         int portnumber = 9050;

            sock = new Socket(AddressFamily.InterNetwork,
                           SocketType.Dgram, ProtocolType.Udp);
            IPEndPoint iep = new IPEndPoint(IPAddress.Any,portnumber);
            sock.Bind(iep);
            EndPoint ep = (EndPoint)iep;
            Console.WriteLine("Ready to receive...");
          // int port_no = Convert.ToInt32(sock.RemoteEndPoint);
            while (true)
            {

                byte[] data = new byte[1024];
                int recv = sock.ReceiveFrom(data, ref ep);
                string stringData = Encoding.ASCII.GetString(data, 0, recv);
                Console.WriteLine("received: {0}  from: {1}",
                                      stringData, ep.ToString());

                //data = new byte[1024];
                //recv = sock.ReceiveFrom(data, ref ep);
                //stringData = Encoding.ASCII.GetString(data, 0, recv);
                //Console.WriteLine("received: {0}  from: {1}",
                //                      stringData, ep.ToString());

                data = null;
            }
            //portnumber--;


        sock.Close();
    }
}

Я только что добился успеха .. спасибо за ответ. это очень помогает.

person User 1531343    schedule 19.09.2012