Получение пакетов UDP с использованием winsock - PullRequest
1 голос
/ 14 октября 2010

Я постоянно получаю UDP-пакеты от порта. Следующее - журнал от wireshark. Как получать эти пакеты непрерывно, используя программирование winsock. Я пытался, но я не могу получить. После вызова recvfrom () он не записывается в буфер. Дайте мне идею, как получить каждый пакет в буфере и записать каждый пакет в текстовый файл. Пожалуйста, помогите мне. Заранее спасибо ...

IP-адрес источника: 192.168.13.25, а номер порта - 2780 (Источник - это оборудование, которое будет непрерывно отправлять UDP-пакеты) IP-адрес назначения - 192.168.13.250, а номер порта - 45141 (пункт назначения - мой компьютер) В моем коде я привязываюсь к 192.168.13.250 (ПК) и порту 2780 (Аппаратное обеспечение). Затем я вызываю recvfrom (). Есть ли несоответствие в Ip & port? так какой IP и порт нет мне нужно получить от пользователя для bind () и recvfrom ()?

No  Time        Source          Destination     Proto  Info                                                                       
1   0.000000    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
2   0.000416    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
3   0.000846    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
4   0.001281    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
5   0.001716    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
6   0.002152    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
7   0.002589    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141
8   0.003025    192.168.13.25   192.168.13.250  UDP    Source port: lbc-control  Destination port: 45141

Ниже мой код:

int main(void) {
    SOCKET recvSockID;
    WSADATA wsaData = {0};
    FILE *udp;
    FILE *fp ;

    struct sockaddr_in sock_addr;
    struct sockaddr_in cliAddr;

    static int recvData;
    int iResult = 0;
    int sock_len = sizeof(sock_addr);
    int sockCli_len = sizeof(cliAddr);
    int recvResult;
    static int iteration;

    fp = fopen("outOfSeq.txt","a");

    if((udp = fopen("udpData.txt","w")) == 0)
        printf("udpData.txt not opened\n");

    printf("\n Enter Destination IP Address : ");
    scanf_s("%s",inputData.destIPAddr,16);

    printf("\n Enter Destination port from which to receive data : "); 
    scanf_s("%d",&inputData.portNo,5);

    printf("\n Enter No.of iterations : "); 
    scanf_s("%d",&inputData.noIteration,2);

    iResult = WSAStartup(MAKEWORD(2, 2), &wsaData);
    if(iResult < 0) {
        printf("windows socket startup error\n");
    } 

    recvSockID = socket(AF_INET, SOCK_DGRAM, 0);
    if(recvSockID < 0) {
        printf("Socket creation error\n");
        WSACleanup();
    }

    sock_addr.sin_family = AF_INET;
    sock_addr.sin_port = htons(inputData.portNo);
    sock_addr.sin_addr.s_addr = inet_addr(inputData.destIPAddr);
    //sock_addr.sin_addr.s_addr = htonl(INADDR_ANY);

    if(bind(recvSockID, (struct sockaddr *)&sock_addr,
        sizeof(struct sockaddr)) < 0)
    {
        printf("bind() failed: %ld.\n", WSAGetLastError());
        closesocket(recvSockID);
        return 0;
    }

    memset(udpBuf, 0, sizeof(udpBuf));

    iteration = inputData.noIteration;
    recvData = 1;

    while (recvData) {
        printf("receiving data\n");
        recvResult =  recvfrom(recvSockID, udpBuf, sizeof(udpBuf),
            0, (struct sockaddr *)&cliAddr, &sockCli_len); 

        if (recvResult <= 0) {
            printf("recvResult = %d\n", recvResult);

            printf("Error Code: %d",WSAGetLastError());

            printf("Socket receive()- error\n");
            return 0;
            //break;
            //goto exit;
        } else
            printf("Socket receive()- success\n");

        printf("completed rx data\n");

        fwrite(udpBuf, sizeof(udpBuf), 1, udp);
        memset(udpBuf, 0, sizeof(udpBuf));

        if (iteration != 0) {
            iteration--;
            if (iteration <= 0)
                recvData = 0;
        }
    }

//exit:
    if(udp) {
        fclose(udp);
        udp = 0; 
    }

    //shutdown socket
    closesocket(recvSockID);    
    fclose(udp);

    return 0;
}

1 Ответ

1 голос
/ 14 октября 2010
  1. fwrite(udpBuf, sizeof(udpBuf), 1, udp)

    Вы должны передать recvResult вместо sizeof(udpBuf).

  2. Возможно, вы не сразу видите байтыв вашем файле из-за файловой буферизации.Однако после close вы должны увидеть данные.

    Если вы хотите отключить буферизацию, используйте setvbuf(udp, NULL, _IONBF, 0) или, в качестве альтернативы, вызывайте fflush(udp) после каждой операции записи.

ОБНОВЛЕНИЕ:

Если вы вообще не принимаете дейтаграммы, вероятно, вы связываете неправильный адрес или порт.

...