组播收不到数据

发布于 2019-03-19 17:17:31 浏览：2865 订阅该版

1、硬件：正点原子阿波罗F429
2、想实现接受来自239.255.255.1 的多播数据，程序在linux可用，但是移植到到RT-Thread调试了很久都没有结果，希望有大兄弟能指点一下迷津
下面是我在调试过程中在网上找的一些参考资料：
STM32F4板子使用LWIP进行组播收发数据的完整过程，附代码
[_https://blog.csdn.net/xueyushenzhou/article/details/51381466_](https://blog.csdn.net/xueyushenzhou/article/details/51381466)

基于stm32f107 stm32cube 和 LWIP 协议实现 udp 组播通信
[_https://blog.csdn.net/zhanglifu3601881/article/details/85080907_](https://blog.csdn.net/zhanglifu3601881/article/details/85080907)

附件一直上传不成功，稍后上传
代码版本1的截图（内容同附件1）：
void udpclient(int argc, char **argv)
{
    int recv_sock;
    int str_len;
    char buf[BUF_SIZE];
    struct sockaddr_in adr;
    struct ip_mreq join_adr; //多播组结构体

if(argc != 3)
 {
 //rt_kprintf("Usage : %s <GroupIp> <
![25,25](file:///C:\Users\YEJIAS~1\AppData\Local\Temp\ksohtml7992\wps1.png)
ort> ", argv[0]);
 return;
 }

recv_sock = socket(AF_INET, SOCK_DGRAM, 0);
    rt_memset(&adr, 0, sizeof(adr));
    adr.sin_family = AF_INET;
    adr.sin_addr.s_addr = htonl(INADDR_ANY);
    adr.sin_port = htons(atoi(argv[2]));

if(bind(recv_sock, (struct sockaddr *)&adr, sizeof(adr)) == -1)
        rt_kprintf("bind() error");

//加入多播组
    join_adr.imr_multiaddr.s_addr = inet_addr(argv[1]);
    join_adr.imr_interface.s_addr = htonl(INADDR_ANY);
    setsockopt(recv_sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (void *)&join_adr, sizeof(join_adr));

附件2的内容void udpclient(int argc, char **argv){ int bytes_read; char recv_data[BUFSZ]; socklen_t addr_len; struct sockaddr_in myAddr,client_addr; int addrlen = 0; int sock, count; int res; unsigned char loop = 1; //设置IP_MULTICAST_LOOP //设置IP_MULTICAST_TTL 为1,即该多播最多只能经过一个路由器 unsigned char ttl = 1;
 struct ip_mreq mreq; rt_memset(&(myAddr), 0, sizeof(myAddr)); rt_memset(&(client_addr), 0, sizeof(client_addr));
 /* 创建一个socket，类型是SOCK_DGRAM，UDP类型 */ if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1) { rt_kprintf("Socket error "); return; }
 /* 初始化预连接的服务端地址 */ myAddr.sin_family = AF_INET; myAddr.sin_addr.s_addr = INADDR_ANY; myAddr.sin_port = htons(PORT);
 //绑定本地套接字 /*绑定socket*/ if(bind(sock, (struct sockaddr *)&myAddr, sizeof(myAddr)) != 0) { rt_kprintf("bind error "); return; } //设置IP_MULTICAST_LOOP /*设置回环许可*/ if (setsockopt(sock, IPPROTO_IP, IP_MULTICAST_LOOP, &loop, sizeof(loop)) != 0) { rt_kprintf("setsockopt IP_MULTICAST_LOOP error "); return; }
 //设置IP_MULTICAST_TTL 为1,即该多播最多只能经过一个路由器 if (setsockopt(sock, IPPROTO_IP, IP_MULTICAST_TTL, &ttl, sizeof(ttl)) != 0) { rt_kprintf("setsockopt IP_MULTICAST_TTL error "); return; } //对struct ip_mreq这个结构体赋值 if (argc > 1) { if ((res = inet_pton(AF_INET, argv[1], &mreq.imr_multiaddr)) == -1)//设置IP地址 { rt_kprintf("setsockopt IP_MULTICAST_TTL error "); return; } else if(res == 0) {rt_kprintf("IP error,please scanf again<224.0.0.1 ~ 239.255.255.255> "); return; } }else { rt_kprintf("Usage:%s (224.0.0.1 ~ 239.255.255.255) ", argv[0]); return; }//mreq.imr_multiaddr.s_addr = inet_addr("239.255.255.1"); /*广播地址*/ mreq.imr_interface.s_addr = INADDR_ANY; //将本机加入多播组中 if (setsockopt (sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) != 0) { rt_kprintf("setsockopt IP_ADD_MEMBERSHIP error "); return ; }
 rt_kprintf("Multicast is starting,waitting for information of Multicast..... "); addrlen = sizeof(client_addr); while (1) { rt_kprintf("wait UDP data "); /* 从sock中收取最大BUFSZ - 1字节数据 */ bytes_read = recvfrom(sock, recv_data, BUFSZ - 1, 0, NULL, 0); recv_data[bytes_read] = '\0'; /* 把末端清零 */ rt_kprintf("%s", recv_data);
 /* 线程休眠一段时间 */ rt_thread_delay(50); }
 /* 关闭这个socket */ closesocket(sock);}

5 个回答

beli 2019-03-19

这家伙很懒，什么也没写！

beli 2019-03-20

这家伙很懒，什么也没写！

void udpclient(int argc, char **argv)
{
    int myFd, clientFd;
    struct sockaddr_in myAddr, clientAddr;
    struct ip_mreq mreq;
    int addrlen = sizeof(clientAddr);
    char buf[MAXBUF];
    char addrTemp[INET_ADDRSTRLEN];
	
	int db_Value=0;
	
	int i,fd_pipe_w;

rt_memset(&myAddr, 0,sizeof(myAddr));
    rt_memset(&clientAddr, 0,sizeof(clientAddr));
    //创建套接字,datagrams
    if((myFd = socket(AF_INET, SOCK_DGRAM, 0)) == -1) {

}
    
    //设置本地地址端口信息
    myAddr.sin_family  = AF_INET;
    myAddr.sin_addr.s_addr = INADDR_ANY;
    if (argc == 3) {
        myAddr.sin_port = htons(atoi(argv[2]));
    } else {
        myAddr.sin_port = htons(PORT);
    }

//绑定本地套接字
    if(bind(myFd, (struct sockaddr *)&myAddr, sizeof(myAddr)) != 0) {

}

//设置IP_MULTICAST_LOOP 
    unsigned char loop = 1;
    if (setsockopt(myFd, IPPROTO_IP, IP_MULTICAST_LOOP, &loop, sizeof(loop)) != 0) {

return ;
    }

//设置IP_MULTICAST_TTL 为1,即该多播最多只能经过一个路由器
    unsigned char ttl = 1;
    if (setsockopt(myFd, IPPROTO_IP, IP_MULTICAST_TTL, &ttl, sizeof(ttl)) != 0) {

return ;
    }

//对struct ip_mreq这个结构体赋值
    if (argc > 1) {  //设置IP地址
        int res;
        if ((res = inet_pton(AF_INET, argv[1], &mreq.imr_multiaddr)) == -1) {

exit(errno);
        } else if(res == 0) {
            rt_kprintf("IP地址无效\n");
            rt_kprintf("请输入一个多播地址:224.0.0.1 ~ 239.255.255.255\n");
            return ;
        } 
    } else {
        rt_kprintf("Usage:%s 多播地址(224.0.0.1 ~ 239.255.255.255)\n", argv[0]);
        return ;
    }
    mreq.imr_interface.s_addr =  INADDR_ANY;
    //将本机加入多播组中
    if (setsockopt (myFd, IPPROTO_IP, IP_ADD_MEMBERSHIP, &mreq, sizeof(mreq)) != 0) {

exit(errno);
    }

rt_kprintf("Multicast is starting,waitting for information of Multicast.....\n");
    while (1)
	{
        rt_memset(buf, 0,sizeof(buf));
		    rt_kprintf("wait UDP data\r\n");
        if (recvfrom(myFd, buf, sizeof(buf) - 1, 0, (struct sockaddr *)&clientAddr, &addrlen) == -1) 
		    {

return ;
        }
				rt_kprintf(".......\r\n");
				/* 线程休眠一段时间 */
        rt_thread_delay(50);
    }
    //退出广播组
    if (setsockopt (myFd, IPPROTO_IP, IP_DROP_MEMBERSHIP, &mreq, sizeof(mreq)) != 0) {

exit(errno);
    }

return;
}