Простой C клиент / сервер udp не работает - PullRequest
0 голосов
/ 04 марта 2020

Я пытаюсь написать серверную программу, которая просто отображает любые необработанные данные, которые она получает от кого-либо через udp. Клиент может отправить некоторые данные в любое время. Никаких ошибок не появляется, за исключением сообщения «Ошибка сокета: ресурс временно недоступен», что означает, что recvfrom не имеет данных для приема (потому что он предположительно не получает никаких пакетов).

Клиент просто отправляет «тест»! " 127.0.0.0:12345, в то время как сервер прослушивает неблокирующий сокет на порту 12345. Возможно, стоит отметить, что я на linux.

Почему server не отображает пакеты, которые это очевидно отправляется с client? Я не вижу, что мне не хватает.

common.h

#include <stdlib.h>
#include <stdint.h>
#include <stdio.h>
#include <errno.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <fcntl.h>

typedef struct sockaddr_in sockaddr_in;
typedef struct sockaddr sockaddr;

int createSocket(uint16_t port)
{
    int handle = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);

    if (handle <= 0)
    {
        printf("failed to create socket\n");
        return 0;
    }

    sockaddr_in address;
    address.sin_family = AF_INET;
    address.sin_addr.s_addr = INADDR_ANY;
    address.sin_port = htons(port);

    if (bind(handle, (const sockaddr*)&address, sizeof(sockaddr_in)) < 0)
    {
        printf("failed to bind socket\n");
        return 0;
    }

    int nonBlocking = 1;
    if (fcntl(handle, F_SETFL, O_NONBLOCK, nonBlocking) == -1)
    {
        printf("failed to set non-blocking\n");
        return 0;
    }

    return handle;
}

int sendData(uint32_t a, uint32_t b, uint32_t c, uint32_t d, uint16_t port, int handle, char* packet_data, int packet_size)
{
    uint32_t address = (a << 24) | (b << 16) | (c << 8) | d;

    sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = htonl(address);
    addr.sin_port = htons(port);

    int sent_bytes = sendto(handle, (const char*)packet_data, packet_size, 0, (sockaddr*)&address, sizeof(sockaddr_in));

    if (sent_bytes != packet_size)
    {
        printf("failed to send packet (%d/%d)\n", sent_bytes, packet_size);
        return 0;
    }
}

сервер. c

#include "common.h"
#include <time.h>

void main(void){
    int socket = createSocket(12345);
    if (!socket){
        perror("Socket error");
    }
    int true=1;
    setsockopt(socket, SOL_SOCKET, SO_REUSEADDR, (const void*)&true, 1);
    // so that we can immediately reuse the port if the server stops running

    char buffer[100] = "No data";
    if(!listen(socket, 0)){
        perror("Socket error");
    }

    //struct timespec delay = {0,33333333}; // 30Hz
    struct timespec delay = {0,100000000}; // 100Hz

    int running = 1;
    int ret = 0;
    while(running){
        ret = recvfrom(socket, &buffer, 100, 0, NULL, NULL);
        if (ret < 0){
            perror("Socket error");
        } else if (ret > 0){
            printf("%d: %s\n", ret, buffer);
        }

        nanosleep(&delay,NULL); 
    }
}

клиент. c

#include "common.h"

void main(void){
    int socket = createSocket(0);
    printf("Started client on port %d\n", socket);

    if(!sendData(127,0,0,0,12345, socket, "test!", 5)){
        perror("Socket error");
    } else {
        printf("Sent data.\n");
    }
}

1 Ответ

0 голосов
/ 04 марта 2020

Я передал указатель на address, где я должен был передать указатель на addr в common.h -> sendTo ().

Кроме того, я отправлял пакеты на 127.0 .0.0, когда это должно было быть 127.0.0.1 (спасибо @yano).

Исправленный код:

int sendData(uint32_t a, uint32_t b, uint32_t c, uint32_t d, uint16_t port, int handle, char* packet_data, int packet_size)
{
    uint32_t address = (a << 24) | (b << 16) | (c << 8) | d;

    sockaddr_in addr;
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = htonl(address);
    addr.sin_port = htons(port);

    int sent_bytes = sendto(handle, (const char*)packet_data, packet_size, 0, (sockaddr*)&addr, sizeof(sockaddr_in));

    if (sent_bytes != packet_size)
    {
        printf("failed to send packet (%d/%d)\n", sent_bytes, packet_size);
        return 0;
    }
}
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...