发送广播 Winsock C++

sending broadcasts winsock c++

本文关键字:C++ Winsock 广播      更新时间:2023-10-16

我正在尝试每 3 秒广播一次当前时间,每 10 秒广播一次当前日期。我正在生成 3 个线程:1 个侦听器、1 个广播时间和 1 个广播日期。此应用程序正在我的笔记本电脑上发生。

我的桌面(同一个内部网)上有一个 udp 侦听器,我用它来检查我的广播。

当我在笔记本电脑上启动广播应用程序时,我立即在我的桌面侦听器上收到时间和日期(这显然是意料之中的)。 问题是我只收到前 2 个广播(时间和日期)。 我的桌面侦听器没有捕获后续广播,我无法解释原因。 我的笔记本电脑应用程序(广播)也有一个侦听器,它可以很好地拾取它们。

桌面侦听

器拾取第一组广播,这告诉我广播正在工作,但我不明白为什么笔记本电脑接收所有广播而侦听器没有。

这是完整的广播应用程序代码(它很长),非常感谢任何帮助。

#include <iostream>
#include <conio.h>
#include <WinSock2.h>
#include <ctime>
#include <string>
#include <Windows.h>
#include <process.h>
#include <conio.h>
#pragma comment (lib, "ws2_32.lib")
using namespace std;
#define PORT 7777
struct tm *currentTimeAndDate;
char currentDate[16];
char currentTime[16];
SOCKET sock;
char recvBuff[50];
int recvBuffLen = 50;
struct sockaddr_in Recv_addr;
struct sockaddr_in Sender_addr;
int len = sizeof(struct sockaddr_in);
void getDate()
{
    string s;
    char a[100];
    time_t t = time(0); // get time now
    struct tm *now = localtime(&t);
    strftime(currentDate, 80, "%d/%m/%Y", now);
}
void getTime()
{
    string s;
    char a[100];
    time_t t = time(0); // get time now
    struct tm *now = localtime(&t);
    strftime(currentTime, 80, "%H:%M:%S", now);
}
void recvFunct(void *param)
{
    while(1)
    {
        recvfrom(sock, recvBuff, recvBuffLen, 0, (sockaddr *)&Sender_addr, &len);
        cout << "received message: " << recvBuff << endl;
    }
}
void sendFunct1(void *param)
{
    while(1)
    {
        getTime();
        if(sendto(sock, currentTime, strlen(currentTime)+1, 0, (sockaddr *)&Sender_addr, sizeof(Sender_addr)) < 0)
        {
            perror("borhot send: ");
            _getch();
            closesocket(sock);
        }
        Sleep(3000);
    }
}
void sendFunct2(void *param)
{
    while(1)
    {
        getDate();
        if(sendto(sock, currentDate, strlen(currentDate)+1, 0, (sockaddr *)&Sender_addr, sizeof(Sender_addr)) < 0)
        {
            perror("borhot send: ");
            _getch();
            closesocket(sock);
        }
        Sleep(10000);
    }
}
int main()
{
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &wsaData);
    sock = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
    char broadcast = 'a';
    if(setsockopt(sock, SOL_SOCKET, SO_BROADCAST, &broadcast, sizeof(broadcast)) < 0)
    {
        perror("broadcast options");
        _getch();
        closesocket(sock);
        return 1;
    }
    Recv_addr.sin_family = AF_INET;
    Recv_addr.sin_port = htons(PORT);
    Recv_addr.sin_addr.s_addr = INADDR_ANY;
    Sender_addr.sin_family = AF_INET;
    Sender_addr.sin_port = htons(PORT);
    Sender_addr.sin_addr.s_addr = inet_addr("255.255.255.255");
    if(bind(sock, (sockaddr*)&Recv_addr, sizeof(Recv_addr)) < 0)
    {
        perror("bind");
        _getch();
        closesocket(sock);
        return 1;
    }
    _beginthread(recvFunct, 0, NULL);
    _beginthread(sendFunct1, 0, NULL);
    _beginthread(sendFunct2, 0, NULL);
    cout << "spawned threads, press any key to exit.. n";
    _getch();
    closesocket(sock);
    WSACleanup();
    return 0;
}

您的 recvFunct 使用 Sender_addr 来存储发件人地址。因此,发送函数中的目标地址会受到损害。

笔记本电脑的网卡地址存储在该变量中。这就是您停止发送广播的原因。