Почему этот одноадресный UDP не получен клиентом?

Почему этот одноадресный не получает клиент? Я отрабатывал это часами. Grr ..; (

  • Я отправляю ценовые тики в форме nn.dd; например, 42,23, 93,75. Всего 5 байтов для тестовых целей.
  • IP-адрес сервера (генератор тиков): 192.168.1.101
  • Адрес клиента 192.168.1.102
  • Возвращаемое значение sendto команда 5, как и должно быть.
  • Я могу успешно пропинговать в обоих направлениях: клиент с сервера и сервер с клиента; около 3 мс времени отклика.
  • Обе машины находятся в одной сети.
  • Цены генерируются и отправляются, как показано ниже
  • Клиентский процесс на одной машине, (с тем же IP-адресом 192.168.1.101) в другом терминале, работает нормально, как показано в фрагменте 2 ниже.
  • Полный код включен во фрагмент 3 и 4
  • Linksys WRT54GL v1.1 со стоковым BIOS
  • Этот код является модифицированной версией UDP-примера Beej здесь:
    http://beej.us/guide/bgnet/output/html/multipage/clientserver.html#datagram
  • ПРИМЕЧАНИЕ. Запустите сервер с tickGenerator 192.168.1.101 helloWorld (конечно, используйте свой IP-адрес (а)). «Привет мир» из примера Биджа будет игнорироваться; Я взломал генератор случайных цен.

Выход генератора тиков: правильно генерирует тиковые данные из 192.168.1.101:

Price unicasted: 49.58
Price unicasted: 50.00
Price unicasted: 50.24
...

Клиент в отдельном окне терминала на одной машине (также из 192.168.1.101) правильно получает многоадресную рассылку:

listener: waiting to recvfrom...
listener: got packet from 192.168.1.101
listener: packet is 5 bytes long
listener: packet contains "49.58"listener: got packet from 192.168.1.101
listener: packet is 5 bytes long
listener: packet contains "50.00"listener: got packet from 192.168.1.101
listener: packet is 5 bytes long
listener: packet contains "50.24"...

Отдельная машина на 192.168.1.102 просто зависает …

Генератор тиков:

/*
** talker.c -- a datagram "client" 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>

#include <time.h>
#include <stdlib.h>
#include <math.h>
#include <chrono>
#include <thread>
#include <iostream>

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

void reverse(char *str, int len) {
int i=0, j=len-1, temp;
while (i<j)
{
temp = str[i];
str[i] = str[j];
str[j] = temp;
i++; j--;
}
}
int intToStr(int x, char str[], int d)
{
int i = 0;
while (x) {
str[i++] = (x%10) + '0';
x = x/10;
}
while (i < d)
str[i++] = '0';

reverse(str, i);
str[i] = '\0';
return i;
}
void ftoa(float n, char *res, int afterpoint) {
int ipart = (int)n;
float fpart = n - (float)ipart;
int i = intToStr(ipart, res, 0);
if (afterpoint != 0) {
res[i] = '.';
fpart = fpart * 100;
intToStr((int)fpart, res + i + 1, afterpoint);
}
}
float randPrice() {
int b;
float d;
b = 4950 + rand() % 100 + 1;
d = (float)b/100;
return d;
}
int main(int argc, char *argv[])
{
int sockfd;
struct addrinfo hints, *servinfo, *p;
int rv;
int numbytes;

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

memset(&hints, 0, sizeof hints);
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_DGRAM;

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

// loop through all the results and make a socket
for(p = servinfo; p != NULL; p = p->ai_next) {
if ((sockfd = socket(p->ai_family, p->ai_socktype,
p->ai_protocol)) == -1) {
perror("talker: socket");
continue;
}

break;
}

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

char myPrice[6];
float f;

while(1) {
f = randPrice();
ftoa(f, myPrice, 2); // Convert price to string
std::cout << "Price multicasted: " << myPrice << std::endl;
if ((numbytes = sendto(sockfd, myPrice, strlen(myPrice), 0, p->ai_addr, p->ai_addrlen)) == -1) {
perror("talker: sendto");
exit(1);
}
std::this_thread::sleep_for(std::chrono::milliseconds(1000));
}

freeaddrinfo(servinfo);

printf("talker: sent %d bytes to %s\n", numbytes, argv[1]);
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];

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 (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;

while(1) {
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;
}

0

Решение

Проблема в привязке слушателя. Вы должны связать с INADDR_ANY, а не с конкретным IP-адресом.

Также было бы интересно узнать, на какой фактический IP-адрес отправляет отправитель.

0

Другие решения

Других решений пока нет …