发帖 回复
返回列表
  • 1321阅读
  • 1回复

[原创]Qt低版本多网卡组播 [复制链接]

 上一主题 下一主题
离线spygg
侠客
 
只看楼主 正序阅读 楼主  发表于: 2024-11-10
最近在某个项目中，发现了一个低版本Qt(Qt5.7)的bug，导致组播无法正常使用，经过一番排查，终于找到了原因，特此记录。


环境

  • Qt：5.7.0 mingw32
  • 操作系统：windows 11


现象

在Qt5.7.0版本中，使用组播发送数据时，发现数据无法接收，经过长时间的排查，发现是Qt的bug，具体现象如下： 1. 在Qt5.7.0版本中，使用组播发送数据时，发现数据无法接收。 2. 使用串口调试工具，发现发送的数据包没有问题（无论何种情况都可以）。 3. 使用wireshark抓包，发现发送的数据包没有问题。 4. 使用Qt自带的组播收发例子，本机测试发现可以正常接收数据， 但是当收发处于两台电脑时不能接收。


排查步骤

  1. 使用调试工具
  2. 使用地址 0.0.0.0: port 不能接收到数据
  3. 使用地址 192.168.1.100: port 可以接收到数据
  4. 使用地址 239.255.255.255: port 不能接收到数据
  5. 测试自带的组播收发例子
  6. 本机测试可以正常接收数据
  7. 两台电脑测试不能接收数据


尝试解决

经过一顿搜索，加上长时间的摸索（本机的虚拟网卡太多），长时间折腾后发现只有一个网卡的时候可以正常。必须祭出终极大杀器 socket sdk 如果还不行都不知道该怎么办了，结果测试竟然可行
复制代码
  1. #include <stdio.h>  
  2. #include <winsock2.h>  
  3. #include <ws2tcpip.h>  
  4. #pragma comment(lib, "ws2_32.lib")
  7. void sendData(SOCKET sock)
  8. {
  9.     struct sockaddr_in dest_addr; // 目标地址结构体
  11.      // 设置目标地址
  12.      memset(&dest_addr, 0, sizeof(dest_addr));
  13.      dest_addr.sin_family = AF_INET; // IPv4
  14.      dest_addr.sin_port = htons(groupPort); // 目标端口号
  15.      dest_addr.sin_addr.s_addr = inet_addr(groupIp); // 目标IP地址
  18.     char *sendData = "hello world";
  19.     sendto(sock, sendData, strlen(sendData), 0, (const struct sockaddr *)&dest_addr, sizeof(dest_addr));
  20. }
  23. int main(int argc, char* argv[])
  24. {
  26.     unsigned short groupPort = 37080;
  27.     char *bindIp = "192.168.8.112";
  28.     char *localIp = "192.168.8.112";
  29.     char *groupIp = "239.255.255.250";
  31.     printf("%s\n%s\n%s\n%d\n", bindIp, localIp, groupIp, groupPort);
  33.     if(argc >= 5){
  34.         bindIp = argv[1];
  35.         localIp = argv[2];
  36.         groupIp = argv[3];
  37.         groupPort = atoi(argv[4]);
  38.     }
  42.     int iRet = 0;
  43.     WSADATA wsaData;
  44.     WSAStartup(MAKEWORD(2, 2), &wsaData);
  46.     SOCKET sock = socket(AF_INET, SOCK_DGRAM, 0);
  48.     sockaddr_in addr;
  49.     addr.sin_family = AF_INET;
  50.     addr.sin_addr.S_un.S_addr = inet_addr(bindIp);//INADDR_ANY;
  51.     //addr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
  52.     addr.sin_port = htons(groupPort);
  54.     bool bOptval = true;
  55.     iRet = setsockopt(sock, SOL_SOCKET, SO_REUSEADDR, (char*)&bOptval, sizeof(bOptval));
  56.     if (iRet != 0) {
  57.         printf("setsockopt fail:%d", WSAGetLastError());
  58.         return -1;
  59.     }
  61.     iRet = bind(sock, (sockaddr*)&addr, sizeof(addr));
  62.     if (iRet != 0) {
  63.         printf("bind fail:%d\n", WSAGetLastError());
  64.         return -1;
  65.     }
  66.     printf("socket:%d bind success\n", sock);
  68.     ip_mreq multiCast;
  69.     multiCast.imr_interface.S_un.S_addr = inet_addr(localIp);
  70.     multiCast.imr_multiaddr.S_un.S_addr = inet_addr(groupIp);
  71.     iRet = setsockopt(sock, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&multiCast, sizeof(multiCast));
  72.     if (iRet != 0) {
  73.         printf("setsockopt fail:%d\n", WSAGetLastError());
  74.         return -1;
  75.     }
  77.     printf("udp group start: %d, %d\n", IPPROTO_IP, IP_ADD_MEMBERSHIP);
  79.     int len = sizeof(sockaddr);
  80.     char strRecv[1024] = { 0 };
  82.     while (true)
  83.     {
  84.         memset(strRecv, 0, sizeof(strRecv));
  85.         iRet = recvfrom(sock, strRecv, sizeof(strRecv) - 1, 0, (sockaddr*)&addr, &len);
  86.         if (iRet <= 0) {
  87.             printf("recvfrom fail:%d", WSAGetLastError());
  88.             return -1;
  89.         }
  90.         printf("recv data:%s\n", strRecv);
  91.     }
  93.     closesocket(sock);
  94.     WSACleanup();
  96.     return 0;
  97. }

经过对比发现Qt的源码中地址 mreq4.imr_interface.s_addr 赋值时候 QHostAddress firstIP = addressEntries.first().ip();可能为IPV6地址，导致IPV6地址赋值给IPV4地址，导致组播失败。
复制代码
  1. if (iface.isValid()) {
  2.             const QList<QNetworkAddressEntry> addressEntries = iface.addressEntries();
  3.             if (!addressEntries.isEmpty()) {
  4.                 QHostAddress firstIP = addressEntries.first().ip();
  5.                 mreq4.imr_interface.s_addr = htonl(firstIP.toIPv4Address());
  6.             } else {
  7.                 d->setError(QAbstractSocket::NetworkError,
  8.                             QNativeSocketEnginePrivate::NetworkUnreachableErrorString);
  9.                 return false;
  10.             }
  11.         } else {
  12.             mreq4.imr_interface.s_addr = INADDR_ANY;
  13.         }




解决方案

  1. 1.更新Qt版本，最新版的Qt已经修复了这个问题
  2. if (iface.isValid()) {
  3.             const QList<QNetworkAddressEntry> addressEntries = iface.addressEntries();
  4.             bool found = false;
  5.             for (const QNetworkAddressEntry &entry : addressEntries) {
  6.                 const QHostAddress ip = entry.ip();
  7.                 if (ip.protocol() == QAbstractSocket::IPv4Protocol) {
  8.                     mreq4.imr_interface.s_addr = htonl(ip.toIPv4Address());
  9.                     found = true;
  10.                     break;
  11.                 }
  12.             }
  13.             if (!found) {
  14.                 d->setError(QAbstractSocket::NetworkError,
  15.                             QNativeSocketEnginePrivate::NetworkUnreachableErrorString);
  16.                 return false;
  17.             }
  18.         } else {
  19.             mreq4.imr_interface.s_addr = INADDR_ANY;
  20.         }


[size=; font-size: 0.9em,0.9em]修改代码如下 在工程文件中添加
[size=; font-size: 0.9em,0.9em]
复制代码
  1. //添加头文件
  2. #ifdef Q_OS_WIN32
  3. #include <winsock2.h>
  4. #include <ws2tcpip.h>
  5. #endif
  6. //...........................
  8.             //Qt 5.7 bug fix, 第一个IP可能为ip v6
  9.             if (firstIP.protocol() == groupAddress.protocol()) {
  10.                 ok = udpsock->joinMulticastGroup(groupAddress, iface);
  11.             } else {
  12. #ifdef Q_OS_WIN32
  13.                 for (int i = 0; i < addressEntries.size(); i++) {
  14.                     QHostAddress addrTemp = addressEntries.at(i).ip();
  15.                     if (addrTemp.protocol() == groupAddress.protocol()) {
  16.                         ip_mreq multiCast;
  17.                         multiCast.imr_interface.S_un.S_addr = inet_addr(
  18.                             addrTemp.toString().toUtf8().constData());
  19.                         multiCast.imr_multiaddr.S_un.S_addr = inet_addr(
  20.                             groupAddress.toString().toUtf8().constData());
  21.                         int res = setsockopt(udpsock->socketDescriptor(),
  22.                                              0,
  23.                                              12,
  24.                                              (char *) &multiCast,
  25.                                              sizeof(multiCast));
  27.                         ok = (res == 0);
  28.                         break;
  29.                     }
  30.                 }
  31. #else
  32.                 ok = udpsock->joinMulticastGroup(groupAddress, iface);
  33. #endif





血的经验

  1. 使用三方标准工具测试
  2. 使用原始sdk测试
  3. Qt也可能存在bug
  4. 搜索引擎可能存在误导
  5. csdn === 田文镜
签名就是这么浪
回复
举报
分享到 淘江湖 新浪 QQ微博 QQ空间 开心 人人 豆瓣 网易微博 百度 鲜果 白社会 飞信
离线tanyue.esec
侠客
只看该作者 1楼 发表于: 2024-11-10
  
回复
举报
发帖 回复
返回列表
快速回复
限100 字节
 
上一个 下一个