Я пытаюсь настроить простую систему клиент-сервер для передачи сообщений, используя локальный ПК и облачную виртуальную машину (Ubuntu 16), размещенную на AWS.Сейчас это довольно просто и будет расширено, например, с помощью protobuf, но сейчас речь идет о создании базового рабочего примера, прежде чем я начну интегрировать схему связи в мою реальную программу.
«Сервер» ожидает запроса от«клиент», а затем отправит данные клиенту.При запуске клиент получает IP-адрес сервера.
Если я запускаю серверную часть на моей виртуальной машине AWS, а клиентскую часть - на моем локальном ПК, все работает отлично, данные передаются.Однако, это не работает наоборот, я не могу получить доступ к своему локальному ПК с виртуальной машины AWS.Я уверен, что группы безопасности AWS верны, так как он работает с сервером, работающим на виртуальной машине.Кроме того, IP-адрес локальной машины должен быть правильным, так как при запуске сервера на виртуальной машине он выводит IP-адрес клиента, который запросил данные.
Я искал раньше на некоторых форумах и выяснил,Как правило, доступ к локальному ПК с виртуальной машины AWS сложнее.Однако я не нашел решения своей проблемы, и я предполагаю, что должна быть возможность отправлять данные из облачной виртуальной машины на локальный ПК ...
Спасибо за любую помощь!
***** Client side *****
-- call client with IP of server as arg --
#define PORT "3490" // the port client will be connecting to
int main(int argc, char *argv[])
{
int sockfd, numbytes;
unsigned char buf[MAXDATASIZE];
struct addrinfo hints, *servinfo, *p;
int rv;
char s[INET6_ADDRSTRLEN];
memset(&hints, 0, sizeof hints);
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
if ((rv = getaddrinfo(argv[1], PORT, &hints, &servinfo)) != 0) {
fprintf(stderr, "getaddrinfo: %s\n", gai_strerror(rv));
return 1;
}
// loop through all the results and connect 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) {
continue;
}
if (connect(sockfd, p->ai_addr, p->ai_addrlen) == -1) {
close(sockfd);
continue;
}
break;
}
inet_ntop(p->ai_family, get_in_addr((struct sockaddr *)p->ai_addr), s, sizeof s);
printf("client: connecting to %s\n", s);
freeaddrinfo(servinfo);
if ((numbytes = recv(sockfd, buf, MAXDATASIZE-1, 0)) == -1) {
exit(1);
}
//deserialize and output data -- omitted
return 0;
}
***** Server side *****
int main(void)
{
srand (time(NULL));
mydata md0; //data structure that will be sent
//write members of md0 -- omitted
unsigned char buf[MAXDATASIZE],*ptr;
ptr = Serialize_mydata(buf,&md0);
int sockfd, new_fd; // listen on sock_fd, new connection on new_fd
struct addrinfo hints, *servinfo, *p;
struct sockaddr_storage their_addr; // connector's address information
socklen_t sin_size;
struct sigaction sa;
int yes=1;
char s[INET6_ADDRSTRLEN];
int rv;
memset(&hints, 0, sizeof hints);
hints.ai_family = AF_UNSPEC;
hints.ai_socktype = SOCK_STREAM;
hints.ai_flags = AI_PASSIVE; // use my IP
if ((rv = getaddrinfo(NULL, PORT, &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("server: socket");
continue;
}
if (setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &yes, sizeof(int)) == -1) {
exit(1);
}
if (bind(sockfd, p->ai_addr, p->ai_addrlen) == -1) {
close(sockfd);
continue;
}
break;
}
freeaddrinfo(servinfo); // all done with this structure
if (listen(sockfd, BACKLOG) == -1) {
exit(1);
}
sa.sa_handler = sigchld_handler; // reap all dead processes
sigemptyset(&sa.sa_mask);
sa.sa_flags = SA_RESTART;
if (sigaction(SIGCHLD, &sa, NULL) == -1) {
exit(1);
}
printf("server: waiting for connections...\n");
while(1) { // main accept() loop
sin_size = sizeof their_addr;
new_fd = accept(sockfd, (struct sockaddr *)&their_addr, &sin_size);
if (new_fd == -1) {
continue;
}
inet_ntop(their_addr.ss_family, get_in_addr((struct sockaddr *)&their_addr), s, sizeof s);
printf("server: got connection from %s\n", s);
if (!fork()) { // this is the child process
close(sockfd); // child doesn't need the listener
if (send(new_fd, buf, ptr - buf, 0) == -1)
close(new_fd);
exit(0);
}
close(new_fd); // parent doesn't need this
}
return 0;
}