Клиент-серверная программа для повторного использования порта и адреса в C - PullRequest
0 голосов
/ 22 октября 2018

Мне нужно заново создать сценарий клиента, в котором одна и та же пара ip: port повторно используется, когда мы устанавливаем новое соединение.

Я хочу создать программу на основе этого сценария:
Клиент устанавливает соединение с сервером, используя порт XXXX.
Клиент разрывает соединение.
Клиент устанавливает другое соединение с сервером, используя тот же порт XXXX.

Я изменил простой код сервер / клиент, например, я вызвал bind () перед accept () в коде клиента.Когда я запускаю первый раунд клиентской программы, она работает, но во втором раунде соединение принимается сервером, но сообщение от клиента к серверу не передается.

Может кто-нибудь взглянуть на код и помочь мне в этом?

server.c

#include <stdio.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>

int Create_Socket(void)
{
    int c_socket;
    printf("Creating Socket\n");

    c_socket = socket(AF_INET, SOCK_STREAM, 0);

    return c_socket;
}


int Bind_Socket(int socket)
{
    int bind_s = -1;
    int server_port = 7777;
    struct sockaddr_in server = {0};
    printf("Creating bind\n");

    server.sin_family = AF_INET;
    server.sin_addr.s_addr = inet_addr("22.0.0.1");
    server.sin_port = htons(server_port);

    bind_s = bind(socket, (struct sockaddr *)&server, sizeof(server));

    return bind_s;
}


int main(int argc, char *argv[])
{
    int socket_description, socket, client_length, read_size;

    struct sockaddr_in server_address, client_address;

    char client_message[200] = {0};

    char message[100] = {0};

    const char *pMessage = "Hello Vishnu Vijayan";


    //Create Socket
    socket_description = Create_Socket();
    if(socket_description == -1)
    {
        printf("Could not create socket\n");
        return 1;
    }
    printf("Socket Created\n");


    //Bind Socket
    if(Bind_Socket(socket_description) < 0)
    {
        perror("Bind failed");
        return 1;
    }
    printf("Bind done\n");

    listen(socket_description, 3);


    while(1)
    {
        printf("Waiting for incoming connections.... \n");

        client_length = sizeof(struct sockaddr_in);

        //accept connection from an incoming client
        socket = accept(socket_description, (struct sockaddr *)&client_address, (socklen_t*)&client_length);

        if(socket < 0)
        {
            perror("Accept failed");
            return 1;
        }
        printf("Connection accepted\n");


        memset(client_message, '\0', sizeof(client_message));
        memset(message, '\0', sizeof(message));

        //Receive a reply from client
        if(recv(socket, client_message, 200, 0) < 0)
        {
            printf("recv failed\n");
            break;
        }
        printf("Client reply : %s\n", client_message);

        strcpy(message, pMessage);


        //Send some data
        if(send(socket, message, strlen(message), 0) < 0)
        {
            printf("Send failed\n");
            return 1;
        }

        close(socket);
        sleep(1);
    }

    return 0;
}

client.c

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>


int Bind_Socket(int socket)
{
        int bind_s = -1;
        int client_port = 7777;
        struct sockaddr_in client = {0};
        printf("Creating bind\n");

        int reuse = 1;

        if(setsockopt(socket, SOL_SOCKET, SO_REUSEADDR, (const char*)&reuse, sizeof(reuse)) < 0)
        {
                perror("SO_REUSEADDR failed");
                return -1;
        }

        if(setsockopt(socket, SOL_SOCKET, SO_REUSEPORT, (const char*)&reuse, sizeof(reuse)) < 0)
        {
                perror("SO_REUSEPORT failed");
                return -1;
        }

        client.sin_family = AF_INET;
        client.sin_addr.s_addr = inet_addr("20.0.0.1");
        client.sin_port = htons(client_port);

        bind_s = bind(socket, (struct sockaddr *)&client, sizeof(client));

        return bind_s;
}



int Receive_Socket(int socket, char* from_server, int length)
{
    int receive_s = 1;

    receive_s = recv(socket, from_server, length, 0);

    printf("Response : %s\n", from_server);

    return receive_s;   
}


int Send_Socket(int socket, char *send_to_server, int length)
{
    int send_s = -1;

    send_s = send(socket, send_to_server, length, 0);

    return send_s;
}


int Connect_Socket(int socket)
{
    int connect_s = -1;
    int server_port = 7777;
    struct sockaddr_in server = {0};
    printf("Connecting socket\n");

    server.sin_addr.s_addr = inet_addr("22.0.0.1");
    server.sin_family = AF_INET;
    server.sin_port = htons(server_port);

    connect_s = connect(socket, (struct sockaddr *)&server, sizeof(struct sockaddr_in));

    return connect_s;
}


int Create_Socket(void)
{
    int c_socket;
    printf("Creating Socket\n");

    c_socket = socket(AF_INET, SOCK_STREAM, 0);

    return c_socket;
}

int main(int argc, char *argv[])
{
    int socket, read_size;

    struct sockaddr_in server_address;

    char send_to_server[100] = {0};

    char server_reply[200] = {0};


    //Create Socket
    socket = Create_Socket();
    if(socket == -1)
    {
        printf("Could not create socket\n");
        return 1;
    }
    printf("Created Socket\n");


    //Bind Socket
   if(Bind_Socket(socket) < 0)
   {
        perror("Bind failed");
       return 1;
   }
   printf("Bind done\n");


    //Connect to server
    if(Connect_Socket(socket) < 0)
    {
        perror("Connect failed");
        return 1;
    }
    printf("Successfully connected with server\n");

    printf("Enter the message: ");
    gets(send_to_server);

    //Send data to server
    Send_Socket(socket, send_to_server, strlen(send_to_server));

    //Receive data from server
    read_size = Receive_Socket(socket, server_reply, 200);

    printf("Server Response : %s\n\n", server_reply);

    close(socket);

    return 0;
}

1 Ответ

0 голосов
/ 24 октября 2018

Возможно, вы захотите прочитать следующий ответ:
https://stackoverflow.com/a/14388707/15809

Особенно примечания о закрытии сокетов TCP в состоянии TIME_WAIT, а также о том, как SO_REUSEPORT может привести к некоторому распределению нагрузкипод линуксом.Я думаю, что любой из этих двух эффектов мог бы сыграть здесь роль.

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