UDP组播未接收到消息

3

我正在尝试制作一个简单的UDP组播示例,其中一条消息从一个程序发送,从另一个程序接收,但现在输出仅为:

Connected
Message Sent

and

bind
setup multicast

请问我应该怎么做才能成功接收信息?谢谢!!以下是完整的代码:

int main(int argc, char *argv[])
{

int udp_socket_info;
struct sockaddr_in udp_server;
char* message="test";

    //create socket
    udp_socket_info = socket(AF_INET, SOCK_DGRAM, 0);
    if (udp_socket_info == -1) {
    puts("Could not create socket");
    }

//assign local values
    udp_server.sin_addr.s_addr = inet_addr("225.0.0.37"); //multicast address
    udp_server.sin_family = AF_INET;
    udp_server.sin_port = htons( 1100 );

    //checks connection 
    if (connect(udp_socket_info, (struct sockaddr *)&udp_server, sizeof(udp_server)) < 0) {
    perror("Connection error");
    }
    puts("Connected");

    //sends message
    if( sendto(udp_socket_info , message , strlen(message) , 0, (struct sockaddr *)&udp_server, sizeof(udp_server)) < 0) {     
perror("Send failed");
    }
    puts("Message Sent");

}

第二个程序是什么?
int main(int argc, char *argv[])
{

//initialize udp socket and structures
int udp_socket_info;
struct sockaddr_in udp_server;
struct sockaddr addr;
struct ip_mreq mreq;
socklen_t fromlen;
fromlen = sizeof addr;
char incoming_message[100];

    //create udp socket
    udp_socket_info = socket(AF_INET, SOCK_DGRAM, 0);
    if (udp_socket_info == -1) {
    puts("Could not create socket");
        }

    // set up 
memset((char*)&udp_server,0,sizeof(udp_server));
    udp_server.sin_family=AF_INET;
    udp_server.sin_port = htons( 1100 );
udp_server.sin_addr.s_addr = inet_addr("192.168.0.100"); //local address

    // bind 
    if (bind(udp_socket_info,(struct sockaddr *)&udp_server, sizeof(udp_server)) < 0) {
  perror("bind error");
  exit (1);
      }
puts("bind");

 // use setsockopt() to join multicast group
 mreq.imr_multiaddr.s_addr=inet_addr("225.0.0.37"); //multicast address
 mreq.imr_interface.s_addr= htonl(INADDR_ANY); //can use local address here too
 if (setsockopt(udp_socket_info, IPPROTO_IP,IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0) {
  perror("setsockopt");
  exit (1);
      }
puts("setup multicast");

    //Receive an incoming message
    if( recvfrom(udp_socket_info, incoming_message , sizeof(incoming_message), 0, &addr, &fromlen) < 0) {
puts("Received failed");
exit (1);
    }
    puts("Message received");
    puts(incoming_message);
}

你尝试过使用网络嗅探程序,比如Wireshark,来验证发送程序是否正确地发送了数据包吗? - TezlaCoil
2个回答

2

在绑定接收套接字时,应该将其绑定到INADDR_ANY而不是本地接口地址。否则,您可能会面临发送方通过不同的路径无法到达套接字的风险。在某些平台上,您可以将其绑定到多播地址本身。

注意,当您遇到错误时,仅打印自己设计的消息是不够的。该消息必须包含errnostrerror()的结果。例如,调用perror()


2

您的接收器不应该绑定到本地地址,而是应该绑定到INADDR_ANY或您打算加入的多播地址。在Linux系统上,绑定到本地地址会破坏多播。

请注意,如果您绑定到多播地址,这意味着您只会接收该多播地址的数据包。如果您想从多个多播地址接收或者也想接收单播数据包,则需要绑定到INADDR_ANY

加入多播组时,使用INADDR_ANY会使您在默认网络接口上加入指定的组。通常最好明确指定一个接口。

正如EJP所提到的,您应该始终使用perror来打印任何系统或库调用的错误消息,以确保打印出有意义的错误消息。

Wireshark是这类程序的重要工具。它可以帮助您确保数据包正在进出您期望的网络接口。

此外,如果发送方和接收方位于不同的网络段,则需要通过IP_MULTICAST_TTL套接字选项设置TTL。您还需要确保它们之间的任何路由器都配置为传递多播流量。


1
VG。它真的会破坏组播吗?我本以为只要在绑定和加入时使用相同的IP地址,并且发送者在该路由上,它就应该工作。但是我已经多年没有接触过Linux系统了。 - user207421
它确实如此。我曾经有一个Windows用户使用UFTP,要求绑定到特定的地址,所以我添加了这个功能。他用得很好,但第二天我收到了Linux用户的投诉,所以我不得不撤销这个更改。 - dbush
@EJP:你是正确的——它确实不行。我的Ubuntu完全可以在绑定到多播IP/端口的套接字上接收多播。但通过connect()就很麻烦了。比方说,如果你想在同一个套接字上发送和接收多播数据包,你不能使用connect()来设置目标多播地址,因为它会阻止你接收数据。原因是在连接的套接字上接收到的数据包必须具有源地址=连接的地址,而这在多播情况下永远不可能出现。 - wick
绑定到多播地址实际上是可以的。但是当你绑定到本地地址时,Linux会出现问题。我已经进行了编辑以澄清区别。 - dbush

网页内容由stack overflow 提供, 点击上面的
可以查看英文原文,
原文链接