Сокет C: проблема с connect () и / или accept () между клиентами. 111: соединение отказано

Question

Здравствуйте, дамы и господа, у меня небольшая проблема с accept(). У меня есть несколько клиентов и один сервер. Клиенты могут подключаться и общаться просто отлично с сервером. Но в какой-то момент мне нужно, чтобы некоторые клиенты были напрямую связаны друг с другом, и у меня возникли некоторые трудности. У клиентов происходит множество потоков, где один из них - handle_connection(), а у него while(1), с бесконечным циклом listen() и accept() для любых входящих соединений. Всякий раз, когда клиент пытается connect() другому клиенту, connect() возвращает ошибку, 111: Соединение отклонено. Я знаю, что у меня правильный IP-адрес и правильный порт (я указал порт только для соединений между клиентами). Клиент, ожидающий подключения, ничего не замечает, нового подключения нет, нада. Я скопировал некоторые части кода в надежде, что кто-то укажет, что я делаю неправильно. Спасибо за любые комментарии!

Это весь код на стороне клиента. void * handle_connections(void * arg) - это поток, который зацикливается на accept() любых входящих соединений. У моего сервера очень похожий процесс, и он работает очень хорошо. (не уверен, почему это не работает здесь). Это та часть клиента, которая ожидает нового входящего соединения. int handle_request(void * arg, struct message * msg) вызывается в одной точке во время программы и пытается подключиться к клиенту, указанному в struct message * msg, который включает struct sockaddr_in с IP-адресом и номером порта и т. Д.

#define SERVER_PORT 10000
#define CLIENT_PORT     3456
#define MAX_CONNECTION  20
#define MAX_MSG     50

void * handle_connections(void * arg)
{
    struct fd_info * info;
    struct sockaddr_in client_address;
    struct timeval timeout;
    fd_set readset, copyset;

    bzero((char * ) &client_address, sizeof(client_address)); // copy zeroes into string
    client_address.sin_family = AF_INET;
    client_address.sin_addr.s_addr = htonl(INADDR_ANY);
    client_address.sin_port = htons(CLIENT_PORT);

    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    rv = listen(sockfd,MAX_CONNECTION);


    while(1)
    {
        new_sockfd = accept(sockfd, (struct sockaddr *) &client_address, &client_addr_len); //blocks

        if (new_sockfd < 0) {
            printf("C: ERROR accept() %i: %s \n", errno, strerror(errno));
            sleep(2);
        } else {
            printf("C: accepted\n");
            FD_SET(new_sockfd, &readset);   // sets bit for new_sockfd to list of sockets to watch out for
            if (maxfd < new_sockfd)
                maxfd = new_sockfd;
            if (minfd > new_sockfd)
                minfd = new_sockfd;
        }       //end if else (new_sockfd)

    }   // end of the forever while loop
}

int handle_request(void * arg, struct message * msg)
{
    char * cname, gname, payload;
    char * command[3];

    int i, rv, sockfd, client_addr_len;

    struct sockaddr_in client_address;
    struct fd_info * info;

    info = (struct fd_info *) arg;
    sockfd = info->sock_fd;


    sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd == -1)
    {
        printf("HR: ERROR socket() %i: %s \n", errno, strerror(errno));
        break;
    }
    else if (sockfd > 0)
    {
        printf("HR: new socks is %i \n", sockfd);
        printf("HR: sin_family is %i: %i\n", msg->peer.client_address.sin_family, msg->peer.client_address.sin_port);
        //*************************************************************
        //this is the part that returns error 111: Connection refused!!!
        //*************************************************************
        rv = connect(sockfd, (struct sockaddr *) &msg->peer.client_address, sizeof(struct sockaddr));
        if (rv == -1) 
        {
            printf("HR: ERROR: connect() %i: %s \n", errno, strerror(errno));
            printf("HR: at %li \n", msg->peer.client_address.sin_addr.s_addr);
            break;
        }
        else if (rv > 0)
        {
            info->max_fd = sockfd;
            printf("HR: connected successfully!! \n");
        }
    }   
}

Answer 1

Ваша проблема в том, что вы не звоните bind() до listen(), поэтому вы прослушиваете соединения через случайно выбранный порт, а не порт, который хотите прослушивать.

Вам нужно:

if (bind(sockfd, &client_address, sizeof client_address)))
{
    perror("bind");
    /* Handle this error somehow */
 }

до listen().

Обратите внимание, что структура sockaddr, переданная в accept(), не является адресом для прослушивания - это выходной параметр для accept() для хранения адреса клиента, который подключился при возврате accept().