W5100S-EVB-PICO进行UDP组播数据回环测试(九)

前言

        上一章我们用我们的开发板作为UDP客户端连接服务器进行数据回环测试,那么本章我们进行UDP组播数据回环测试。

什么是UDP组播?

        组播是主机间一对多的通讯模式, 组播是一种允许一个或多个组播源发送同一报文到多个接收者的技术。组播源将一份报文发送到特定的组播地址,组播地址不同于单播地址,它并不属于特定某个主机,而是属于一组主机。一个组播地址表示一个群组,需要接收组播报文的接收者都加入这个群组。

IPv4组播地址

IANA将D类地址空间分配给IPv4组播使用。IPv4地址一共32位,D类地址最高4位为1110,地址范围从224.0.0.0到239.255.255.255,具体分类及含义见下图。

连接方式

使开发板和我们的电脑处于同一网段方便测试:

  • 开发板通过交叉线直连主机
  • 开发板和主机都接在路由器LAN口

测试工具

  • 网路调试工具(具有UDP组播模式的功能)
  • wireshark抓包工具

UDP组播数据回环测试

1. 相关代码

我们打开库文件找到其中的multicast.c文件,先看下传入的参数有:socket端口号、数据收发缓存、组播MAC地址、组播IP地址和组播端口;根据数据手册组播模式在打开socket端口前需要先初始化组播的MAC地址、IP地址和端口,端口打开后判断是否收到数据,收到就进行回传,并在串口打印显示;代码如下所示:

int32_t multicast_loopback(uint8_t sn, uint8_t* buf, uint8_t* multicast_mac, uint8_t* multicast_ip, uint16_t multicast_port)
{
   int32_t  ret;
   uint16_t size, sentsize;
   uint8_t destip[4];
   uint16_t destport, port=50000;
   
   switch(getSn_SR(sn))
   {
      case SOCK_UDP :
         if((size = getSn_RX_RSR(sn)) > 0)
         {
            if(size > DATA_BUF_SIZE) size = DATA_BUF_SIZE;
            ret = recvfrom(sn, buf, size, destip, (uint16_t*)&destport);
            buf[ret]=0x00;
            printf("recv from [%d.%d.%d.%d][%d]: %s\r\n",destip[0],destip[1],destip[2],destip[3],destport,buf);
            if(ret <= 0)
            {
#ifdef _MULTICAST_DEBUG_
               printf("%d: recvfrom error. %ld\r\n",sn,ret);
#endif
               return ret;
            }
            size = (uint16_t) ret;
            sentsize = 0;
            while(sentsize != size)
            {
               ret = sendto(sn, buf+sentsize, size-sentsize, destip, destport);
               if(ret < 0)
               {
#ifdef _MULTICAST_DEBUG_
                  printf("%d: sendto error. %ld\r\n",sn,ret);
#endif
                  return ret;
               }
               sentsize += ret; // Don't care SOCKERR_BUSY, because it is zero.
            }
         }

         break;
      case SOCK_CLOSED:
#ifdef _MULTICAST_DEBUG_
         printf("%d:Multicast Loopback start\r\n",sn);
#endif
         setSn_DIPR(0, multicast_ip);
         setSn_DPORT(0, multicast_port);
         setSn_DHAR(0, multicast_mac);
         if((ret = socket(sn, Sn_MR_UDP, port, Sn_MR_MULTI)) != sn)
            return ret;
#ifdef _MULTICAST_DEBUG_
         printf("%d:Opened, UDP Multicast Socket\r\n", sn);
         printf("%d:Multicast Group IP - %d.%d.%d.%d\r\n", sn, multicast_ip[0], multicast_ip[1], multicast_ip[2], multicast_ip[3]);
         printf("%d:Multicast Group Port - %d\r\n", sn, multicast_port);
#endif
         break;
      default :
         break;
   }
   return 1;
}

主程序仍旧是初始化网络配置信息,并且初始化组播相关配置信息,这里的组播MAC地址值得一提:为了在本地物理网络上实现组播信息的正确传输,需要在链路层使用组播MAC地址。以太网传输IPv4单播报文的时候,目的MAC地址使用的是接收者的MAC地址。但是在传输组播数据时,其目的地不再是一个具体的接收者,而是一个成员不确定的组,所以要使用IPv4组播MAC地址,即IPv4组播地址映射到链路层中的地址。IANA规定,IPv4组播MAC地址的高24位为0x01005e,第25位为0,低23位为IPv4组播地址的低23位,映射关系如下图所示。

知道了映射关系后我们能很容易根据组播IP地址得到对应的组播MAC地址,例如我们本次测试的组播地址224.1.1.11对应的组播MAC地址为01-00-5e-01-01-0b。我们这里直接用数组初始化相关信息后传入测试函数,在主函数里循环调用即可,如下所示:

#define SOCKET_ID 0
#define ETHERNET_BUF_MAX_SIZE (1024 * 2)

void network_init(void);

wiz_NetInfo net_info = {
    .mac = {0x00, 0x08, 0xdc, 0x16, 0xed, 0x2e},
    .ip = {192, 168, 1, 10},
    .sn = {255, 255, 255, 0},
    .gw = {192, 168, 1, 1},
    .dns = {8, 8, 8, 8},
    .dhcp = NETINFO_STATIC};

wiz_NetInfo get_info;
static uint8_t ethernet_buf[ETHERNET_BUF_MAX_SIZE] = {0,};
static uint8_t multicast_mac[6]= {0x01,0x00,0x5e,0x01,0x01,0x0b};   // multicast mac address
static uint8_t multicast_ip[4]  = {224, 1, 1, 11};  // multicast ip address
static uint16_t multicast_port  = 30000; // multicast port

int main()                                                          
{   
    stdio_init_all();
    sleep_ms(2000);
    network_init();

    while(true)
    {
        multicast_loopback(SOCKET_ID, ethernet_buf, multicast_mac, multicast_ip, multicast_port);
        // multicast_recv(SOCKET_ID, ethernet_buf, multicast_mac, multicast_ip, multicast_port);
        sleep_ms(500);
    }
    

}

void network_init(void)
{
    uint8_t temp;
    wizchip_initialize();
    printf("W5100s udp multicast example.\r\n");
    sleep_ms(2000);
    wizchip_setnetinfo(&net_info);
    print_network_information(get_info);
    sleep_ms(2000);   
}

 2. 测试现象

我们编译烧录完成后,打开串行监视器,打开wireshark输入过滤条件<ip.addr == 224.1.1.11>然后开启监听,打开网络调试工具点击创建连接,类型选择UDP(组播模式),目标IP选择224.1.1.11,端口为3000(其他非特殊端口也可以),本机端口指定为30000(本次测试组播端口为30000)是为了方便我们在调试工具看到组播组收到数据,参数配置完成后我们点击创建,然后在发送区输入123点击发送测试,在调试工具接收区可以看到成功收到2次,一次是PC端发送给组播组的,另一次是我们开发板作为组播组成员收到PC端发送给组播组的数据后回传的;如下图所示:

 

相关链接: 

本章相关例程链接https://gitee.com/wiznet-hk/w5100s-evb-pico-routine.git本章所用网络调试助手资源获取链接https://download.csdn.net/download/WIZnet2012/88252449


http://www.niftyadmin.cn/n/4968637.html

相关文章

SpringBoot项目转为非Web项目

在微服务开发时&#xff0c;有时候某个服务可能并不需要是一个web项目&#xff0c;这时候应该怎么做呢&#xff1f; 去除pom中的web-starter 替换spring-boot-starter-web为spring-boot-starter&#xff0c;如果其他pom引入了web则需要逐一排除 <dependency><…

单选框显示信息,前端-服务器端代码

需求&#xff1a;编辑用户信息&#xff0c;其中&#xff0c;所属组织需要去后台组织表中查询当前所有组织&#xff0c;而员工和状态是前端页面写死的枚举类型 前端VUE代码&#xff1a; <template><div class"app-container"><el-form :model"f…

【数据流】分类与使用

数据流 1.数据流分类 可以实现将数据和其类型一并读写&#xff0c;分为数据输出流DataOutputStream和数据输入流DataInputStream 数据输出流&#xff1a;DataOutputStream继承OutputStream&#xff0c;因此支持写字节的相关方法 数据输入流&#xff1a;DataInputStream继承…

SpringBoot案例-配置文件-@ConfigurationProperties

问题分析 在往期的配置参数的文章中&#xff0c;对于阿里云OSS的参数时设置在yml配置文件中&#xff0c;然后使用Value&#xff08;”${}“&#xff09;对参数进行赋值&#xff0c;具体如下&#xff1a; 此种方法比较繁琐 问题解决 使用注解 Data 为变量自动生成get/set方…

区块链上地址与银行账户有什么区别?

在区块链世界中&#xff0c;除了交易还有另一个基础要素&#xff1a;地址。在日前推出的Onchain AML合规技术方案&#xff0c;也有一个与区块链地址密切相关的概念&#xff1a;KYA(Know Your Address&#xff0c;了解你的地址)。 那问题来了&#xff0c;区块链地址究竟有什么用…

直播预告|没有 “专业” 的向量数据库,大模型就玩不转了吗?

向量数据库曾寂寂无名&#xff0c;然而随着生成式 AI 大模型的爆发式增长&#xff0c;其热度被推向了前所未有的巅峰。 不久前&#xff0c;诸多向量数据库公司纷纷宣布完成融资&#xff1a;Pinecone 完成 1 亿美元 B 轮融资&#xff0c;WeaviateBV 获得 5000 万美元 B 轮融资&a…

C++信息学奥赛1136:密码翻译

#include <iostream> #include <string> using namespace std;int main() {string arr;getline(cin, arr); // 输入字符串&#xff0c;包括空格for (int i 0; i < arr.length(); i) {char a arr[i] 1; // 字符加1if (arr[i] z) {a a; // 如果当前字符是…

学习分享:Ubuntu 下使用 Qt 打开串口报错 Permission denied

Ubuntu 下使用 Qt 打开串口报错 Permission denied 错误描述 提前声明一下&#xff0c;开发环境是 Ubuntu18.04&#xff0c;用户是非 root 用户。 因项目需求&#xff0c;需要使用到 Qt 收发串口数据&#xff0c;曾经写过一个串口调试助手的程序 通俗易懂玩QT&#xff1a;串口…