【问题标题】:How to broadcast Message using UDP sockets locally?如何在本地使用 UDP 套接字广播消息?
【发布时间】:2012-06-23 13:09:53
【问题描述】:

我想在本地向许多应用程序广播消息。为此,我认为 UDP 套接字是最好的 IPC,请纠正我。

为此,我使用以下代码:

对于广播:

/*
** broadcaster.c -- a datagram "client" that can broadcast
*/

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>

#define SERVERPORT 4950    // the port users will be connecting to

int main(int argc, char *argv[])
{
    int sockfd;
    struct sockaddr_in their_addr; // connector's address information
    struct hostent *he;
    int numbytes;
    int broadcast = 1;
    //char broadcast = '1'; // if that doesn't work, try this

    if (argc != 3) {
        fprintf(stderr,"usage: broadcaster hostname message\n");
        exit(1);
    }

    if ((he=gethostbyname(argv[1])) == NULL) {  // get the host info
        perror("gethostbyname");
        exit(1);
    }

    if ((sockfd = socket(AF_UNIX, SOCK_DGRAM, 0)) == -1) {
        perror("socket");
        exit(1);
    }

    // this call is what allows broadcast packets to be sent:
    if (setsockopt(sockfd, SOL_SOCKET, SO_BROADCAST, &broadcast,
        sizeof broadcast) == -1) {
        perror("setsockopt (SO_BROADCAST)");
        exit(1);
    }

    their_addr.sin_family = AF_UNIX;     // host byte order
    their_addr.sin_port = htons(SERVERPORT); // short, network byte order
    their_addr.sin_addr = *((struct in_addr *)he->h_addr);
    memset(their_addr.sin_zero, '\0', sizeof their_addr.sin_zero);

    if ((numbytes=sendto(sockfd, argv[2], strlen(argv[2]), 0,
             (struct sockaddr *)&their_addr, sizeof their_addr)) == -1) {
        perror("sendto");
        exit(1);
    }

    printf("sent %d bytes to %s\n", numbytes,
        inet_ntoa(their_addr.sin_addr));

    close(sockfd);

    return 0;
}

然后去听:

/*
** listener.c -- a datagram sockets "server" demo
*/

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>

#define MYPORT "4950"    // the port users will be connecting to

#define MAXBUFLEN 100

// get sockaddr, IPv4 or IPv6:
void *get_in_addr(struct sockaddr *sa)
{
    if (sa->sa_family == AF_INET) {
        return &(((struct sockaddr_in*)sa)->sin_addr);
    }

    return &(((struct sockaddr_in6*)sa)->sin6_addr);
}

int main(void)
{
    int sockfd;
    struct addrinfo hints, *servinfo, *p;
    int rv;
    int numbytes;
    struct sockaddr_storage their_addr;
    char buf[MAXBUFLEN];
    socklen_t addr_len;
    char s[INET6_ADDRSTRLEN];
    int optval = 1;

    memset(&hints, 0, sizeof hints);
    hints.ai_family = AF_UNSPEC; // set to AF_INET to force IPv4
    hints.ai_socktype = SOCK_DGRAM;
    hints.ai_flags = AI_PASSIVE; // use my IP

    if ((rv = getaddrinfo(NULL, MYPORT, &hints, &servinfo)) != 0) {
        fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(rv));
        return 1;
    }

    // loop through all the results and bind to the first we can
    for(p = servinfo; p != NULL; p = p->ai_next) {
        if ((sockfd = socket(p->ai_family, p->ai_socktype,
                p->ai_protocol)) == -1) {
            perror("listener: socket");
            continue;
        }

        if(setsockopt(sockfd, SOL_SOCKET,SO_REUSEADDR, &optval, sizeof optval) != 0)
        {
            perror("listener: setsockopt");
            continue;   
        }   

        if (bind(sockfd, p->ai_addr, p->ai_addrlen) == -1) {
            close(sockfd);
            perror("listener: bind");
            continue;
        }

        break;
    }

    if (p == NULL) {
        fprintf(stderr, "listener: failed to bind socket\n");
        return 2;
    }

    freeaddrinfo(servinfo);

    printf("listener: waiting to recvfrom...\n");

    addr_len = sizeof their_addr;
    if ((numbytes = recvfrom(sockfd, buf, MAXBUFLEN-1 , 0,
        (struct sockaddr *)&their_addr, &addr_len)) == -1) {
        perror("recvfrom");
        exit(1);
    }

    printf("listener: got packet from %s\n",
        inet_ntop(their_addr.ss_family,
            get_in_addr((struct sockaddr *)&their_addr),
            s, sizeof s));
    printf("listener: packet is %d bytes long\n", numbytes);
    buf[numbytes] = '\0';
    printf("listener: packet contains \"%s\"\n", buf);

    close(sockfd);

    return 0;
}

问题是我必须像这样传递IP 192.168.1.255 但在实际场景中可能没有eth0接口,只会有环回。那我该如何实现呢?

【问题讨论】:

    标签: c linux sockets ipc


    【解决方案1】:

    服务器不应绑定到您从getaddrinfo 获得的地址,而应绑定到127.255.255.255(用于环回接口)。

    有关广播服务器/客户端的现成示例,请参阅http://www.ccplusplus.com/2011/09/udp-broadcast-client-server-example.html

    【讨论】:

    • 我已经尝试了很多次这个例子,但是在运行时我总是得到Success: Bad server address 并且没有任何效果:(
    【解决方案2】:

    Unix 域套接字不支持多路/广播。

    可以在本地接口127.0.0.1广播。

    【讨论】:

    • 已更新,只使用一直存在的本地接口。
    • 在这种情况下,我只能收听一个客户端。
    • 您可以在本地接口上进行多播,以便多个客户端接收数据报。
    • 任何参考链接都会有所帮助.. :)
    【解决方案3】:

    虽然最初的问题没有明确说明,但我相信最初的提问者想要“广播”到在同一操作系统实例上运行的多个应用程序(同一台计算机到旧计时器)。

    在监听器示例中使用 'SO_REUSEADDR' 以及 Yuvi 的后续 cmets 支持这一点,最后建议使用 IP 多播。

    应该澄清原来的问题。

    我相信在使用 SO_REUSEADDR 时,在单个 UDP 端口上使用多个绑定器的数据包分发因操作系统而异。 我在最近的 Windows 上的经验是,在她释放她的绑定之前,一个单一的“绑定器”被专门提供所有数据包,此时,另一个绑定器被选择并呈现所有收到的数据包,直到她释放,等等......

    这显然与最近的 Linux 内核不同,如以下链接所述:https://stackoverflow.com/a/14388707/86375 该页面似乎声称 Linux 将在多个绑定器之间循环接收数据包。

    最终结果,如果您希望像原始发布者那样使用单个已发送数据报进行多对多发送,并且您尝试使用 IP 单播,而不是 IP 多播,您可能会失望。 (我的经验和上面的链接表明您可以进行多重绑定,但这并不意味着在 Linux 或 Windows 上多次传递接收到的数据报)

    原发帖者应该尝试过使用多播。

    【讨论】:

      猜你喜欢
      • 2021-07-09
      • 2012-09-17
      • 2019-05-12
      • 2018-02-27
      • 2013-05-15
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      相关资源
      最近更新 更多