IP多播

用户1154259

发布于 2018-01-17 15:26:13

1.1K0

发布于 2018-01-17 15:26:13

文章被收录于专栏：xingoo, 一个梦想做发明家的程序员xingoo, 一个梦想做发明家的程序员

　　　　　　　　　　　　　　　　　　　　　　1 　　多播地址　　　　　　　　　　　　　　　　　　　　

IP多播地址采用D类IP地址确定多播的组，地址范围是224.0.0.0 到 239.255.255.255.

　　　　　　　　　　　　　　　　　　　　　　　2　组管理协议（IGMP）　　　　　　　　　　　　　　

两个多播节点之间的所有路由器必须支持IGMP协议

任何没有开启IGMP的路由器仅简单的丢弃接收到的多播数据

　　　　　　　　　　　　　　　　　　　　　　3　　使用IP多播　　　　　　　　　　　　　　　　　　　　　　　　

1　　　　加入离开组　　

　　　　　IP_ADD_MEMBERSHIP 和 IP_DROP_MEMBERSHIP

下面的代码展示了如何加入组：

    ip_mreq    mcast;
    mcast.imr_interface.S_un.S_addr = INADDR_ANY;
    mcast.imr_multiaddr.S_un.S_addr = ::inet_addr("234.5.6.7"); // 多播地址为234.5.6.7 
　　::setsockopt(s, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&mcast, sizeof(mcast));

下面的代码显示了如何退出组

    ip_mreq    mcast;
    mcast.imr_interface.S_un.S_addr = INADDR_ANY;
    mcast.imr_multiaddr.S_un.S_addr = ::inet_addr("234.5.6.7"); // 多播地址为234.5.6.7 
　　::setsockopt(s, IPPROTO_IP, IP_DROP_MEMBERSHIP, (char*)&mcast, sizeof(mcast));

2 　　　　接收多播数据　　　　

主机在接收IP多播数据之前，必须成为IP多播组的成员。为了接收发送到特定端口的多播封包，有必要绑定到那个本地端口，而不是显示的指定本地地址

如果套接字使用SO_REUSEADDR选项，就可以不止一个进程可以绑定到UDP端口

如下代码所示：

    BOOL bReuse = TRUE;
    ::setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char*)&bReuse, sizeof(BOOL));

如此一来，每个来到这个共享端口的多播或者广播UDP封包都会发送给所绑定此端口的套接字

下面是接收多播封包的代码：

void main()
{
    SOCKET s = ::socket(AF_INET, SOCK_DGRAM, 0);

    // 允许其它进程使用绑定的地址
    BOOL bReuse = TRUE;
    ::setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char*)&bReuse, sizeof(BOOL));


    // 绑定到4567端口
    sockaddr_in si;
    si.sin_family = AF_INET;
    si.sin_port = ::ntohs(4567);
    si.sin_addr.S_un.S_addr = INADDR_ANY;
    ::bind(s, (sockaddr*)&si, sizeof(si));
    
    // 加入多播组
    ip_mreq    mcast;
    mcast.imr_interface.S_un.S_addr = INADDR_ANY;
    mcast.imr_multiaddr.S_un.S_addr = ::inet_addr("192.168.0.1");  // 多播地址为234.5.6.7
    ::setsockopt(s, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&mcast, sizeof(mcast));


    // 接收多播组数据
    printf(" 开始接收多播组上的数据... \n");
    char buf[1280];
    int nAddrLen = sizeof(si);
    while(TRUE)
    {
        int nRet = ::recvfrom(s, buf, strlen(buf), 0, (sockaddr*)&si, &nAddrLen);
        if(nRet != SOCKET_ERROR)
        {
            buf[nRet] = '\0';
            printf(buf);
        }
        else
        {
            int n = ::WSAGetLastError();
            break;
        }
    }
}

3 　　带源地址的IP多播　　　　　　

带源地址的IP多播允许加入组时，指定要接收哪些成员的数据

1 包含方式：指定N个有效的源地址，套接字仅接收来自这些源地址的数据

2 排除方式：指定N个有效的源地址，套接字将接受这些源地址之外的数据

    SOCKET    s = ::socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);

    // 本地接口
    SOCKADDR_IN    localif;
    localif.sin_family = AF_INET;
    localif.sin_port   = htons(5150);
    localif.sin_addr.s_addr = htonl(INADDR_ANY);
    ::bind(s, (SOCKADDR *)&localif, sizeof(localif));
    
    // 设置ip_mreq_source结构
    struct ip_mreq_source mreqsrc;
    mreqsrc.imr_interface.s_addr = inet_addr("192.168.0.46");
    mreqsrc.imr_multiaddr.s_addr = inet_addr("234.5.6.7");
    
    
    // 添加源地址218.12.255.113
    mreqsrc.imr_sourceaddr.s_addr = inet_addr("218.12.255.113");
    ::setsockopt(s, IPPROTO_IP, IP_ADD_SOURCE_MEMBERSHIP, (char *)&mreqsrc, sizeof(mreqsrc));
    // 添加源地址
    mreqsrc.imr_sourceaddr.s_addr = inet_addr("218.12.174.222");
    ::setsockopt(s, IPPROTO_IP, IP_ADD_SOURCE_MEMBERSHIP, (char *)&mreqsrc, sizeof(mreqsrc));

移除地址可以使用IP_DROP_MEMBERSHIP选项

全部试验源码：

sender.cpp:

///////////////////////////////////
// sender.cpp文件

#include "initsock.h"
#include "stdio.h"
#include <windows.h>

CInitSock theSock;

void main()
{
    SOCKET s = ::socket(AF_INET, SOCK_DGRAM, 0);
    // 有效SO_BROADCAST选项
    BOOL bBroadcast = TRUE;
    ::setsockopt(s, SOL_SOCKET, SO_BROADCAST, (char*)&bBroadcast, sizeof(BOOL));

    // 设置广播地址，这里的广播端口号（电台）是4567
    SOCKADDR_IN bcast;
    bcast.sin_family = AF_INET;
    bcast.sin_addr.s_addr =  ::inet_addr("255.255.255.255");
    bcast.sin_port = htons(4567);

    // 发送广播
    char sz[] = "this is xingoo 123. \r\n";
    while(TRUE)
    {
        ::sendto(s, sz, strlen(sz), 0, (sockaddr*)&bcast, sizeof(bcast));
        ::Sleep(1000);
    }
}

recv.cpp:

#include "Initsock.h"

#include <stdio.h>
#include <windows.h>
#include <Ws2tcpip.h>



// 初始化Winsock库
CInitSock theSock;

void main()
{
    SOCKET s = ::socket(AF_INET, SOCK_DGRAM, 0);

    // 允许其它进程使用绑定的地址
    BOOL bReuse = TRUE;
    ::setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char*)&bReuse, sizeof(BOOL));


    // 绑定到4567端口
    sockaddr_in si;
    si.sin_family = AF_INET;
    si.sin_port = ::ntohs(4567);
    si.sin_addr.S_un.S_addr = INADDR_ANY;
    ::bind(s, (sockaddr*)&si, sizeof(si));
    
    // 加入多播组
    ip_mreq    mcast;
    mcast.imr_interface.S_un.S_addr = INADDR_ANY;
    mcast.imr_multiaddr.S_un.S_addr = ::inet_addr("192.168.0.1");  // 多播地址为234.5.6.7
    ::setsockopt(s, IPPROTO_IP, IP_ADD_MEMBERSHIP, (char*)&mcast, sizeof(mcast));


    // 接收多播组数据
    printf(" 开始接收多播组上的数据... \n");
    char buf[1280];
    int nAddrLen = sizeof(si);
    while(TRUE)
    {
        int nRet = ::recvfrom(s, buf, strlen(buf), 0, (sockaddr*)&si, &nAddrLen);
        if(nRet != SOCKET_ERROR)
        {
            buf[nRet] = '\0';
            printf(buf);
        }
        else
        {
            int n = ::WSAGetLastError();
            break;
        }
    }
}

运行结果：