我正在写一个C程序,它可以多播一个数据包。用于多播的同一个套接字在所有接口上都被订阅到多播组。这意味着发送方将接收到自己的数据包。我希望套接字接收两次消息,一次在loopback接口上,另一次在eth0接口上。下面是相同的代码。
#define MULTICAST_PORT 1112
#define MULTICAST_GROUP "239.0.0.1"
int create_multi_receiver()
{
// Send is also through this socket
int fd = socket(AF_INET, SOCK_DGRAM, 0);
struct sockaddr_in in_servaddr;
struct ip_mreq mreq;
// Bind UDP server
bzero(&in_servaddr, sizeof(in_servaddr));
in_servaddr.sin_family = AF_INET;
in_servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
in_servaddr.sin_port = htons(MULTICAST_PORT);
if (bind(fd, (struct sockaddr *)&in_servaddr, sizeof(in_servaddr)) == -1)
error_exit("bind error in UDP");
mreq.imr_multiaddr.s_addr = inet_addr(MULTICAST_GROUP);
mreq.imr_interface.s_addr = htonl(INADDR_ANY);
if (setsockopt(fd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) < 0)
error_exit("setsockopt");
int opt = 1;
if (setsockopt(fd, IPPROTO_IP, IP_PKTINFO, &opt, sizeof(opt)) < 0)
error_exit("setsockfd");
return fd;
}
struct msg *recv_multi_msg(int udpfd)
{
struct msg nmb_msg; /* space to msg into */
struct iovec vector[1]; /* file name from the child */
struct msghdr msg; /* full message */
struct cmsghdr *cmsg; /* control message with the fd */
/* set up the iovec for the file name */
vector[0].iov_base = &nmb_msg;
vector[0].iov_len = sizeof(nmb_msg);
/* the message we're expecting to receive */
memset(&msg, 0, sizeof(msg));
msg.msg_name = NULL;
msg.msg_namelen = 0;
msg.msg_iov = vector;
msg.msg_iovlen = 1;
/* overprovisioning buffer for now */
char cmbuf[128];
msg.msg_control = cmbuf;
msg.msg_controllen = sizeof(cmbuf);
printf("Receiving message..\n");
if (recvmsg(udpfd, &msg, 0) == -1)
{
perror("recvmsg multireceiver");
return NULL;
}
printf("received message..\n");
// TODO: Test this part, very high chance of error
for ( // iterate through all the control headers
struct cmsghdr *cmsg = CMSG_FIRSTHDR(&msg);
cmsg != NULL;
cmsg = CMSG_NXTHDR(&msg, cmsg))
{
// ignore the control headers that don't match what we want
if (cmsg->cmsg_level != IPPROTO_IP ||
cmsg->cmsg_type != IP_PKTINFO)
{
continue;
}
struct in_pktinfo pi;
memcpy(&pi, CMSG_DATA(cmsg), sizeof(pi));
printf("Destination IP: %s\n", inet_ntoa(pi.ipi_spec_dst));
// in_addr_t ip = (nmb_msg.mtype) >> 16;
// if (pi.ipi_spec_dst.s_addr != ip)
// return NULL;
// break;
}
return NULL;
// Do some stuff later
}
void send_multi_msg(int udpfd, int udsfd)
{
struct msg msg;
if (recv(udsfd, &msg, sizeof(msg), 0) > 0)
{
struct sockaddr_in addr;
int alen;
bzero(&addr, sizeof(addr));
addr.sin_family = AF_INET;
addr.sin_addr.s_addr = inet_addr(MULTICAST_GROUP);
addr.sin_port = htons(MULTICAST_PORT);
alen = sizeof(addr);
printf("sending %s\n", msg.mtext);
if (sendto(udpfd, &msg, sizeof(msg), 0, (struct sockaddr *)&addr, alen) == -1)
perror("sendto in multicast");
}
}
但是,我只收到eth0数据包。为什么会这样呢?IP_MULTICAST_LOOP
在默认情况下是启用的。
我试过检查StackOverflow,但没有一个问题得到满意的回答。
2条答案
按热度按时间r3i60tvu1#
通过网络发送的IP数据包可以是fragmented。接收的网络堆栈将重组这些片段。这称为IP重组。
分段由IP标识符和偏移量来标识。RFC如果您发送一个IP数据包,它会得到一个标识符。您的网络堆栈会丢弃所有已经收到的“分段”。因此,您只会收到一个数据包一次,尽管它可能有多条路径指向您的网络适配器。
qvsjd97n2#
当你用
sendto
发送多播数据报时,它只在一个接口上发送数据包,所以你只收到一个数据包,因为你只发送了一个数据包。默认情况下,
sendto
用于多播的接口通常是系统上的第一个非环回网络接口。您可以通过在发送套接字上设置IP_MULTICAST_IF
选项来控制使用哪个接口。因此,如果您想在多个接口上发送,则需要多次调用sendto
,并在每次发送前设置IP_MULTICAST_IF
。您还使用了
INADDR_ANY
作为加入多播组的接口。这通常也是第一个非环回接口。如果您运行程序,然后在它仍在运行时运行netstat -ng
,您可以看到加入了哪个接口。如果要侦听多个接口上的多播,则需要为每个接口设置
IP_ADD_MEMBERSHIP
选项。