打印

使用socket发送组播包

[复制链接]
578|0
手机看帖
扫描二维码
随时随地手机跟帖
跳转到指定楼层
楼主
keer_zu|  楼主 | 2023-11-22 10:33 | 只看该作者 回帖奖励 |倒序浏览 |阅读模式



代码如下:
#include "fun_interface.h"
#include <unistd.h>
#include <string>
struct in_addr localInterface;
struct sockaddr_in groupSock;
int sd;
char databuf[1024] = "Multicast test message lol!";

int datalen = sizeof(databuf);

typedef struct {
    std::string dip;
    int sock;
    struct sockaddr_in gsock;
} test_item_t;

test_item_t sock_items[] = {
{
    .dip = "225.0.0.128"
},
{
    .dip = "225.0.0.120"
},
{
    .dip = "225.0.0.111"
},
{
    .dip = "225.0.0.110"
},
{
    .dip = "239.202.0.11"
},
{
    .dip = "239.202.255.251"
}
};

int init_sock()
{
    int sd;
    int items_size = sizeof(sock_items)/sizeof(test_item_t);
    printf("== size:%d\n",items_size);
    for(int i = 0;i < items_size;i ++) {
        sd = socket(AF_INET, SOCK_DGRAM, 0);
        if(sd < 0) {
            perror("Opening datagram socket error");
            return -1;
        } else {
            printf("open socket ....ok\n");
            sock_items[i].sock = sd;
        }

        memset((char *) &sock_items[i].gsock, 0, sizeof(sock_items[i].gsock));
        sock_items[i].gsock.sin_family = AF_INET;
        //groupSock.sin_addr.s_addr = inet_addr("226.1.1.1");
        sock_items[i].gsock.sin_addr.s_addr = inet_addr(sock_items[i].dip.c_str());
        sock_items[i].gsock.sin_port = htons(4321);

        localInterface.s_addr = inet_addr("192.168.1.12");
        //localInterface.s_addr = inet_addr("172.16.16.90");

        if(setsockopt(sd, IPPROTO_IP, IP_MULTICAST_IF, (char *)&localInterface, sizeof(localInterface)) < 0){
            perror("Setting local interface error");
            return -1;
        }else
            printf("Setting the local interface...OK\n");
    }

    return 0;
}

int main()
{
    int items_size = sizeof(sock_items)/sizeof(test_item_t);
   
    if(init_sock() != 0) {
        exit(1);
    }
    /* Send a message to the multicast group specified by the*/
    /* groupSock sockaddr structure. */
    /*int datalen = 1024;*/
    for(int i = 0;i < 100;i ++) {
        for(int j = 0;j < items_size;j ++ ) {
            if(sendto(sock_items[j].sock, databuf, datalen, 0, (struct sockaddr*)&sock_items[j].gsock, sizeof(sock_items[j].gsock)) < 0) {
                perror("Sending datagram message error");
            } else
                printf("Sending datagram message...OK\n");
        }
        sleep(3);
    }
   
    return 0;
}


使用特权

评论回复

相关帖子

发新帖 我要提问
您需要登录后才可以回帖 登录 | 注册

本版积分规则

个人签名:qq群:49734243 Email:zukeqiang@gmail.com

1349

主题

12426

帖子

53

粉丝