Как установить пользовательскую передачу сообщений с виртуальной машины AWS Ubuntu на локальный ПК - PullRequest
0 голосов
/ 05 апреля 2019

Я пытаюсь настроить простую систему клиент-сервер для передачи сообщений, используя локальный ПК и облачную виртуальную машину (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;
}

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...