Компьютерные сети. 6-е изд.

write(s, argv[2], strlen(argv[2])+1);

/* Получить файл, записать на стандартное устройство вывода */

while (1) {

    bytes = read(s, buf, BUF_SIZE); /* Читать из сокета */

    if (bytes <= 0) exit(0);        /* Проверка конца файла */

    write(1, buf, bytes);           /* Записать на стандартное устройство вывода */

}

}

Илл. 6.6. Клиентская программа для использования сокетов. Серверная программа представлена на следующей странице

#include                    /* Серверная программа */

#include

#include

#include

#include

#include

#include

#include

#define SERVER_PORT 8080                 /* По договоренности между клиентом и сервером */

#define BUF_SIZE 4096                    /* Размер передаваемых блоков */

#define QUEUE_SIZE 10

int main(int argc, char *argv[])

{ int s, b, l, fd, sa, bytes, on = 1;

char buf[BUF_SIZE];                     /* буфер для исходящего файла */

struct sockaddr_in channel;             /* содержит IP-адрес */

/* Создать структуру адреса для привязки к сокету */

memset(&channel, 0, sizeof(channel));   /* Обнуление channel */

channel.sin_family = AF_INET;

channel.sin_addr.s_addr = htonl(INADDR_ANY);

channel.sin_port = htons(SERVER_PORT);

/* Пассивный режим. Ожидание соединения */

s = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);  /* Создать сокет */

if (s <0) {printf("сбой вызова сокета"); exit(-1);}

setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *) &on, sizeof(on));

b = bind(s, (struct sockaddr *) &channel, sizeof(channel));

if (b < 0) {printf("сбой связывания"); exit(-1);}

l = listen(s, QUEUE_SIZE);              /* Определение размера очереди */

if (l < 0) {printf("сбой ожидания"); exit(-1);}

/* Теперь сокет установлен и привязан. Ожидание и обработка соединения. */

while (1) {

    sa = accept(s, 0, 0);                /* Блокировка в ожидании запроса соединения */

    if (sa < 0) {printf("сбой доступа"); exit(-1);}

    read(sa, buf, BUF_SIZE);             /* Считать имя файла из сокета */

    /* Получить и возвратить файл. */

    fd = open(buf, O_RDONLY);            /* Открыть файл для обратной отправки */

    if (fd < 0) {printf("сбой открытия файла");

    while (1) {

        bytes = read(fd, buf, BUF_SIZE); /* Читать из файла */

        if (bytes <= 0) break;           /* Проверка конца файла */

        write(sa, buf, bytes);           /* Записать байты в сокет */

    }

    close(fd);                           /* Закрыть файл */

    close(sa);                           /* Разорвать соединение */

}

}

Сначала рассмотрим ту часть программы, которая описывает сервер. Она начинается с включения некоторых стандартных заголовков, последние три из которых содержат основные структуры данных и определения, относящиеся к интернету. Затем SERVER_PORT определяется как 8080. Значение выбрано случайным образом. Любое число от 1024 до 65 535 также подойдет, если только оно не используется другим процессом; порты с номерами 1023 и ниже зарезервированы для привилегированных пользователей.

В последующих двух строках определяются две необходимые серверу константы. Первая из них задает размер блока данных для передачи файлов (в байтах). Вторая определяет максимальное количество незавершенных соединений, после установки которых новые соединения будут отвергаться.

После объявления локальных переменных начинается сама программа сервера. Вначале она инициирует структуру данных, которая будет содержать IP-адрес сервера. Эта структура вскоре будет привязана к серверному сокету. Вызов memset полностью обнуляет структуру данных. Последующие три присваивания заполняют три поля этой структуры. Последнее содержит порт сервера. Функции htonl и htons преобразуют значения в стандартный формат, что позволяет программе нормально выполняться на устройствах с представлением числовых разрядов little-endian (например, Intel x86) и big-endian (например, SPARC).

После этого сервер создает и проверяет сокет на ошибки (определяется по s < 0). В окончательной версии программы сообщение об ошибке может быть чуть более понятным. Вызов setsockopt нужен для того, чтобы порт мог использоваться несколько раз, а сервер — бесконечно, обрабатывая запрос за запросом. Теперь IP-адрес привязывается к сокету и выполняется проверка успешного завершения вызова bind. Конечным этапом инициализации является вызов listen. Он свидетельствует о готовности сервера к приему входящих вызовов и сообщает системе о том, что нужно ставить в очередь до QUEUE_SIZE вызовов, пока сервер обрабатывает текущий вызов. При заполнении очереди прибытие новых запросов спокойно игнорируется.