2. 程式人生 > >c++ 網絡編程（六）TCP/IP LINUX下 socket編程 多播與廣播 實現一次發送所有組客戶端都能接收到

c++ 網絡編程（六）TCP/IP LINUX下 socket編程 多播與廣播 實現一次發送所有組客戶端都能接收到

阿新 • • 發佈：2018-09-09
send all users 代碼示例 proto 次數 不可 的人 ssa

原文作者：aircraft

原文鏈接：https://www.cnblogs.com/DOMLX/p/9614288.html

一.多播

鍥子：有這麽一種情況，網絡電臺可能需要同時向成千上萬的用戶傳輸相同的數據，如果用我們以前講過的傳輸形式，每個用戶都傳輸一次，這樣肯定是不合理的。因此，就引入了多播技術來解決這個問題，它可以同時向大量用戶發送相同數據。其基本原理是這樣的：有個多播組，只要加入這個組裏的所有客服端，服務端發送的數據它們都能收到，具體傳輸到多播組裏的每個客戶是由路由完成的(如果路由器不支持多播或網絡堵塞，實現多播也會使用隧道技術)

    • 多播的數據傳輸特點如下：
      1，多播服務器端針對特定多播組，只需發送1次數據，該組內的所有所有客服端都能接收數據。


      2，多播組數可在IP地址範圍內任意增加。

    • 設置生存時間和加入多播組的方法
      1，設置生存時間：只指服務端發送的數據包最遠能傳遞的距離，用整數表示，並且每經過1個路由器就減1，當為0時，該數據包無法再被傳遞，只能銷毀。因此，這個值設置過大將影響網絡流量。當然，設置過小也會無法傳遞到目標（通過套接字可選項設置，示例代碼中有使用方法）。

      2，加入多播組：也是通過套接字可選項設置，示例代碼中有使用方法，這裏只介紹多播組的結構體ip_mreq。

    • struct ip_mreq
      {
      struct in_addr imr_multiaddr; //多播組的IP地址
      struct in_addr imr_interface; //加入的客服端主機IP地址

      }

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

#define TTL 64    //數據包生存時間，即最多可以傳遞經過第64個路由時銷毀
#define BUF_SIZE 30
void error_handling(char *message);

int main(int
 
 argc, const char * argv[]) {
    int send_sock;
    struct sockaddr_in mul_adr;
    int time_live = TTL;
    FILE *fp;
    char buf[BUF_SIZE];
    if (argc != 3) {
        printf("Usage : %s <GroupIp> <Port> \n", argv[0]);
        exit(1);
    }

    //基於UDP的多播
    send_sock = socket(PF_INET, SOCK_DGRAM, 0);
    memset(&mul_adr, 0, sizeof(mul_adr));
    mul_adr.sin_family = AF_INET;
    mul_adr.sin_addr.s_addr = inet_addr(argv[1]);
    mul_adr.sin_port = htons(atoi(argv[2]));

    //設置生存時間(除了這裏其它基本和UDP編寫一樣)
    setsockopt(send_sock, IPPROTO_IP, IP_MULTICAST_TTL, (void *)&time_live, sizeof(time_live));

    if((fp = fopen("/Users/app05/Desktop/test.txt", "r")) == NULL)
        error_handling("fopen() error");

    while (!feof(fp)) //如果文件結束，則返回非0值，否則返回0
    {
        fgets(buf, BUF_SIZE, fp);
        sendto(send_sock, buf, strlen(buf), 0, (struct sockaddr *)&mul_adr, sizeof(mul_adr));
        sleep(1); //只是為了加個傳輸數據時間間隔，沒有特殊意義
    }

    fclose(fp);
    close(send_sock);
    return 0;
}

void error_handling(char *message)
{
    fputs(message, stderr);
    fputc(‘\n‘, stderr);
    exit(1);
}

接收者（receiver）:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

#define BUF_SIZE 30
void error_handling(char *message);

int main(int argc, const char * argv[]) {
    int recv_sock;
    int str_len;
    char buf[BUF_SIZE];
    struct sockaddr_in adr;
    struct ip_mreq join_adr; //多播組結構體

    if(argc != 3)
    {
        printf("Usage : %s <GroupIp> <Port> \n", argv[0]);
        exit(1);
    }

    recv_sock = socket(PF_INET, SOCK_DGRAM, 0);
    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)
        error_handling("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));

    while (1) {
        str_len = recvfrom(recv_sock, buf, BUF_SIZE - 1, 0, NULL, 0);//只需要多播組IP地址，不關心自己主機地址
        if(str_len < 0)
            break;
        buf[str_len] = 0;
        fputs(buf, stdout);
    }

    close(recv_sock);
    return 0;
}


void error_handling(char *message)
{
    fputs(message, stderr);
    fputc(‘\n‘, stderr);
    exit(1);
}

二.廣播

廣播在功能上和多播是一樣的，都是同時可以向大量客戶傳遞數據。但他們在網絡範圍上有區別，多播可以跨越不同的網絡，只要加入了多播組就能接收數據。但廣播只能向同一網絡中的主機傳輸數據。
廣播分為：直接廣播與本地廣播，直接廣播sender的IP地址只需指定網絡地址，主機地址全部填255。這樣處在這個網絡地址裏的所有主機就可以接收數據了。而本地廣播sender的IP地址寫255.255.255.255，這樣本地網絡所有主機就可以接收數據了。

//將SO_BROADCAST可選項設置為1就表示開啟了套接字廣播功能，默認是關閉的。
int bcast = 1;
setsockopt(send_sock, SOL_SOCKET, SO_BROADCAST, (void *) &bcast, sizeof(bcast));

下面就多播的代碼示例稍作修改，本地廣播的示例如下：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

#define TTL 64    //數據包生存時間，即最多可以傳遞經過第64個路由時銷毀
#define BUF_SIZE 30
void error_handling(char *message);

int main(int argc, const char * argv[]) {
    int send_sock;
    struct sockaddr_in mul_adr;
    int time_live = TTL;
    FILE *fp;
    char buf[BUF_SIZE];
    if (argc != 3) {
        printf("Usage : %s <GroupIp> <Port> \n", argv[0]);
        exit(1);
    }

    //基於UDP的多播
    send_sock = socket(PF_INET, SOCK_DGRAM, 0);
    memset(&mul_adr, 0, sizeof(mul_adr));
    mul_adr.sin_family = AF_INET;
    mul_adr.sin_addr.s_addr = inet_addr(argv[1]);
    mul_adr.sin_port = htons(atoi(argv[2]));

    //設置生存時間(除了這裏其它基本和UDP編寫一樣)
    //setsockopt(send_sock, IPPROTO_IP, IP_MULTICAST_TTL, (void *)&time_live, sizeof(time_live));

    /*add:廣播修改處*/
    //默認套接字是關閉廣播的，開啟如下：
    int so_brd = 1;  //設置為1就可以開啟廣播
    setsockopt(send_sock, SOL_SOCKET, SO_BROADCAST, (void *)&so_brd, sizeof(so_brd));

    if((fp = fopen("/Users/app05/Desktop/test.txt", "r")) == NULL)
        error_handling("fopen() error");

    while (!feof(fp)) //如果文件結束，則返回非0值，否則返回0
    {
        fgets(buf, BUF_SIZE, fp);
        sendto(send_sock, buf, strlen(buf), 0, (struct sockaddr *)&mul_adr, sizeof(mul_adr));
        sleep(1); //只是為了加個傳輸數據時間間隔，沒有特殊意義
    }

    fclose(fp);
    close(send_sock);
    return 0;
}

void error_handling(char *message)
{
    fputs(message, stderr);
    fputc(‘\n‘, stderr);
    exit(1);
}

另一個修改：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <arpa/inet.h>
#include <sys/socket.h>

#define BUF_SIZE 30
void error_handling(char *message);

int main(int argc, const char * argv[]) {
    int recv_sock;
    int str_len;
    char buf[BUF_SIZE];
    struct sockaddr_in adr;
    //struct ip_mreq join_adr; //多播組結構體

    if(argc != 2)
    {
        printf("Usage : %s <GroupIp> <Port> \n", argv[0]);
        exit(1);
    }

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

    if(bind(recv_sock, (struct sockaddr *)&adr, sizeof(adr)) == -1)
        error_handling("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));

    while (1) {
        str_len = recvfrom(recv_sock, buf, BUF_SIZE - 1, 0, NULL, 0);//只需要多播組IP地址，不關心自己主機地址
        if(str_len < 0)
            break;
        buf[str_len] = 0;
        fputs(buf, stdout);
    }

    close(recv_sock);
    return 0;
}


void error_handling(char *message)
{
    fputs(message, stderr);
    fputc(‘\n‘, stderr);
    exit(1);
}

三.多播與廣播的區別

  • 多播：“多播”也可以稱為“組播”，在網絡技術的應用並不是很多，網上視頻會議、網上視頻點播特別適合采用多播方式。因為如果采用單播方式，逐個節點傳輸，有多少個目標節點，就會有多少次傳送過程，這種方式顯然效率極低，是不可取的；如果采用不區分目標、全部發送的廣播方式，雖然一次可以傳送完數據，但是顯然達不到區分特定數據接收對象的目的。采用多播方式，既可以實現一次傳送所有目標節點的數據，也可以達到只對特定對象傳送數據的目的。 　　IP網絡的多播一般通過多播IP地址來實現。多播IP地址就是D類IP地址，即224.0.0.0至239.255.255.255之間的IP地址。Windows 2000中的DHCP管理器支持多播IP地址的自動分配。

  • 廣播：“廣播”在網絡中的應用較多，如客戶機通過DHCP自動獲得IP地址的過程就是通過廣播來實現的。但是同單播和多播相比，廣播幾乎占用了子網內網絡的所有帶寬。拿開會打一個比方吧，在會場上只能有一個人發言，想象一下如果所有的人同時都用麥克風發言，那會場上就會亂成一鍋粥。集線器由於其工作原理決定了不可能過濾廣播風暴，一般的交換機也沒有這一功能，不過現在有的網絡交換機（如全向的QS系列交換機）也有過濾廣播風暴功能了，路由器本身就有隔離廣播風暴的作用。 　　廣播風暴不能完全杜絕，但是只能在同一子網內傳播，就好像喇叭的聲音只能在同一會場內傳播一樣，因此在由幾百臺甚至上千臺電腦構成的大中型局域網中，一般進行子網劃分，就像將一個大廳用墻壁隔離成許多小廳一樣，以達到隔離廣播風暴的目的。 　　在IP網絡中，廣播地址用IP地址“255.255.255.255”來表示，這個IP地址代表同一子網內所有的IP地址。

  • 最後說一句啦。本網絡編程入門系列博客是連載學習的，有興趣的可以看我博客其他篇。。。。

    好了今天對網絡編程的學習就到這裏結束了，小飛機我要撤了去吃飯了。，，，很多人大學都很迷茫不知道學點什麽好，，，，，管他的，想那麽多幹嘛，先學了再說，對技術如有偏見，那麽你的領域就局限於此了---《一專多精》

    參考博客：https://blog.csdn.net/u010223072/article/details/48269213

    參考書籍：《TCP/IP 網絡編程 --尹聖雨》

c++ 網絡編程（六）TCP/IP LINUX下 socket編程 多播與廣播 實現一次發送所有組客戶端都能接收到

相關推薦

c++ 網絡編程（六）TCP/IP LINUX下 socket編程 多播與廣播 實現一次發送所有組客戶端都能接收到

send all users 代碼示例 proto 次數 不可 的人 ssa 原文作者：aircraft 原文鏈接：https://www.cnblogs.com/DOMLX/p/9614288.html 一.多播 鍥子：有這麽一種情況，網絡電臺可能需要同時向成

c++ 網絡編程（四）TCP/IP LINUX/windows下 socket 基於I/O復用的服務器端代碼 解決多進程服務端創建進程資源浪費問題

linux系統中 cin 通過 sel print 大小 查看 服務 集合 原文作者：aircraft 原文鏈接：https://www.cnblogs.com/DOMLX/p/9613861.html 好了，繼上一篇說到多進程服務端也是有缺點的，每創建一個

c++ 網絡編程（三）TCP/IP 進程間的通信原理與實現代碼

ech nbsp 傳遞數據 lse sock cnblogs 實例代碼 remove %s 原文作者：aircraft 原文鏈接：https://www.cnblogs.com/DOMLX/p/9613027.html 一.進程間通信的基本概念 進程間通信意味著兩個

c++ 網路程式設計（九）TCP/IP LINUX/windows下 多執行緒超詳細教程 以及 多執行緒實現服務端

#define _CRT_SECURE_NO_WARNINGS #include <stdio.h> #include <stdlib.h> #include <process.h> #include <winsock2.h> #include <win

c++ 網路程式設計（九）TCP/IP LINUX/windows下 多執行緒超詳細教程 以及 多執行緒實現服務端

原文作者：aircraft 原文連結：https://www.cnblogs.com/DOMLX/p/9661012.html  先講Linux下（windows下在後面可以直接跳到後面看）： 一.執行緒基本概念 前面我們講過多程序伺服器，但我們知道它開銷很大

真的懂了：TCP協議中的三次握手和四次揮手（關閉連接時, 當收到對方的FIN報文時, 僅僅表示對方不在發送數據了, 但是還能接收數據, 己方也未必全部數據都發送對方了。相當於一開始還沒接上話不要緊，後來接上話以後得讓人把話講完）

流程圖 .cn 服務 soc knowledge ber tcp連接 是什麽 一次 一、TCP報文格式 　　下面是TCP報文格式圖： 　　　　　　　　　　 　　(1) 序號, Seq(Sequence number), 占32位，用來標識從TCP源端向目的端發送的字節

python網絡編程（六）

想要 打電話 HA ima 輸入數據 撥打 news 提示 構建 tcp通信模型 tcp服務器 在程序中，如果想要完成一個tcp服務器的功能，需要的流程如下： socket創建一個套接字 bind綁定ip和port listen使套接字變為可以被動鏈接 accept等待

Python學習筆記（四十五）網絡編程（1）TCP編程

包含 ipv sina spa 包括 現在 com 訪問 等等 摘抄：https://www.liaoxuefeng.com/wiki/0014316089557264a6b348958f449949df42a6d3a2e542c000/001432004374523e49

深層網絡識別貓（吳恩達1課4周編程實例）

.com float 一個 初始 通過 shape https src .cn 第四周編程 目標：建立一個深層的神經網絡識別貓 核心思想： 正向傳播 反向傳播 需要註意的事正反向傳播的初始值， ， ， 數據集：與第一個編程作業的數據集一樣 代

網絡編程（二）——TCP協議、socket

cep 數據請求 b- aps pre alt 技術分享 隱藏 可靠 TCP協議與socket套接字 一、TCP協議 1、可靠傳輸，TCP數據包沒有長度限制，理論上可以無限長，但是為了保證網絡的效率，通常TCP數據包的長度不會超過IP數據包的長度，以確保單個TCP數據包不必

Linux shell 編程（六）：運算

運算 shell let expr 運算 表達式 表達式包含在或(())或[]內， 算數表達式：(()) ((expression)) 這個表達式是根據算術計算的規則來計算的。相當於let expression。 條件計算表達式：[] [expression] 這是內置命令tes

並發編程（六）

lose 接收數據 append 不可 png coroutine ber fc7 spool 異步調用與回調機制 在之前我們有了解過異步調用機制，當我們在發起異步調用後，並不會等待任務結束才返回，而是直接執行下一行代碼，如果異步功能用狀態來通知，那麽調用者就需要每隔一定時

Shell編程（六）awk工具

查找 image eight com bsp 數據 http and strong 1. {print} coins.txt gold 1 1986 USA American Eagle gold 1 196

Android應用開發：網絡工具——Volley（二）

respond sid 開發 多少 called creat miss 相等 eal 引言 在Android應用開發：網絡工具——Volley（一）中結合Cloudant服務介紹了Volley的一般使用方法，當中包括了兩種請求類型StringRequest和JsonOb

Linux 網卡驅動學習（六）（應用層、tcp 層、ip 層、設備層和驅動層作用解析）

local acc 每次 letter auto sizeof style article inode 本文將介紹網絡連接建立的過程、收發包流程，以及當中應用層、tcp層、ip層、設備層和驅動層各層發揮的作用。 1、應用層 對於使用socket進行網絡連接的serv

算法復習——網絡流模板（ssoj）

ddd tde res csr dpf ada spi gyp clj 題目： 題目描述 有 n（0<n<=1000）個點，m（0<m<=1000）條邊，每條邊有個流量 h（0<=h<35000），求從點 start 到點 end 的最

NS3網絡仿真（9）： 構建以太網幀

構造 style lib ans 嘗試 pos height prot art 快樂蝦http://blog.csdn.net/lights_joy/歡迎轉載，但請保留作者信息在NS3使用了一個叫Packet的類來表示一個數據幀，本節嘗試用它構造一個以太網幀。以下是一個

NS3網絡仿真（12）： ICMPv4協議

normal fun rac sequence icmp veh abcde all protoc 快樂蝦http://blog.csdn.net/lights_joy/歡迎轉載，但請保留作者信息ICMP的全稱是 Internet ControlMessage Prot

網絡流模板（Dinic）

edge str tput nod ack getc prior ext freopen 1 #include<iostream> 2 #include<algorithm> 3 #include<cstdio> 4 #incl

java多線程（六）

類型 準備 應用 不支持 訪問 接口類 行為 而且 left 使用Runnable接口創建線程 Runnable接口 只有一個run()方法 Thread類實現了Runable接口 便於多個線程共享資源 Java不支持多繼承，如果已經繼承了某個基類，便要實現