Модельный SQL-интерпретатор (1115016), страница 2
Текст из файла (страница 2)
При работе с одной ЭВМиспользуется UNIX-домен, где адреса интерпретируются как имена файлов в UNIX. Вэтом случае в качестве первого параметра указывается константа AF_UNIX (AF —Address Family).Второй параметр определяет тип канала связи с сокетом, который должен бытьиспользован.Существует несколько типов каналов связи с сокетом, доступных при межпроцессномвзаимодействии в UNIX, но обычно используются следующие два:SOCK_STREAM — при этом типе связи поступающим в канал байтам информациигарантируется «доставка» в порядке их поступления; пока непрерывный поток байтовне прекратится, никакие другие данные приниматься каналом не будут (аналогом такойсвязи является доставка письма с уведомлением о вручении);SOCK_DGRAM — этот тип связи используется для посылки отдельных пакетовинформации, называемых дейтаграммами (сообщениями); при этом не гарантируется,что пакеты будут доставлены на место назначения в порядке поступления, а вдействительности не гарантируется, что они все вообще будут доставлены (примертакого типа связи — доставка незаказного письма через обычную почту).Третий параметр позволяет программисту выбрать нужный протокол для канала связи.Если этот параметр равен нулю, ОС выберет нужный протокол автоматически.Функция socket возвращает целое положительное число — номер сокет-дескриптора(который можно использовать, например, в функциях read и write аналогичнофайловому дескриптору).
Если же сокет по каким-либо причинам не был создан(например, очень много открытых файлов), возвращается −1, а в переменную errnoзаписывается причина неудачи.Константы, используемые в качестве аргументов при вызове socket, определены вовключаемых файлах <sys/socket.h> и <sys/types.h>.2.1.2.Функция bindЭта функция используется сервером для присваивания сокету имени. До выполненияфункции bind (т.е.
присваивания какого-либо имени, вид которого зависит от адресногодомена) сокет недоступен программам-клиентам.3Волкова И.А., Головин И.Г., Кузина Л.Н., Мальковский М.Г.int socket (int domain, int type, int protocol);Первый параметр — сокет-дескриптор, который данная функция именует. Второйпараметр — указатель на структуру имени сокета struct sockaddr. Тип этой структурызависит от домена. Для UNIX-домена этот тип называется sockaddr_un, он определен вовключаемом файле sys/un.h и выглядит таким образом:struct sockaddr_un {short sun_family;char sun_path[108];};В качестве первого элемента структуры, обозначающего класс адресов, мы будемиспользовать константу AF_UNIX, второй элемент — имя файла, который будетсоответствовать используемому сокету.Файл с именем, указанным в sun_path, действительно создается, поэтому послеокончания работы с данным сокетом надо выполнить функцию unlink, в противномслучае другие программы, которые попытаются использовать данное имя, получатсообщение об ошибке.2.1.3.Функция listenФункция listen используется сервером, чтобы информировать ОС, что он ожидает(«слушает») запросы связи на данном сокете.
Без такой функции всякое требованиесвязи с этим сокетом будет отвергнуто.int listen(int s, int backlog);Первый аргумент — сокет для прослушивания, второй аргумент (backlog) — целоеположительное число, определяющее, сколько запросов связи может быть принято насокет одновременно. В большинстве систем это значение должно быть не больше пяти.Заметим, что это число не имеет отношения к числу соединений, которое можетподдерживаться сервером. Аргумент backlog имеет отношение только к числу запросовна соединение, которые приходят одновременно. Число установленных соединенийможет превышать это число.2.1.4.Функция acceptЭта функция используется сервером для принятия связи на сокет. Сокет должен бытьуже слушающим в момент вызова функции.
Если сервер устанавливает связь склиентом, то функция accept возвращает новый сокет-дескриптор, через который ипроисходит общение клиента с сервером. Пока устанавливается связь клиента ссервером, функция accept блокирует другие запросы связи с данным сервером, а послеустановления связи «прослушивание» запросов возобновляется.int accept(int s, struct sockaddr * name, int * anamelen);Первый аргумент функции — сокет-дескриптор для принятия связей от клиентов.Второй аргумент — указатель на адрес клиента (структура sockaddr) для4Модельный SQL-интерпретатор. Методическое пособие.соответствующего домена.
Третий аргумент — указатель на целое число, содержащеедлину буфера для записи адреса клиента. Второй и третий аргументы заполняютсясоответствующими значениями в момент установления связи клиента с сервером ипозволяют серверу точно определить, с каким именно клиентом он общается. Еслизаданная длина буфера для хранения адреса меньше необходимой, функция возвращаетошибку (−1). Если же сервер не интересуется адресом клиента, в качестве второго итретьего аргументов можно задать NULL-указатели.2.1.5.Функция connectФункция connect используется процессом-клиентом для установления связи с сервером.int connect(int s, struct sockaddr * name, int namelen);Первый аргумент — сокет-дескриптор клиента. Второй аргумент — указатель на адрессервера (структура sockaddr) для соответствующего домена.
Третий аргумент — целоечисло — длина структуры адреса.Функция возвращает 0, если вызов успешный, и −1 иначе.2.1.6.Функция sendФункция служит для записи данных в сокет.int send(int s, void * buf, int len, int flags);Первый аргумент — сокет-дескриптор, в который записываются данные. Второй итретий аргументы — соответственно, адрес и длина буфера с записываемыми данными.Четвертый параметр — это комбинация битовых флагов, управляющих режимамизаписи.
Если аргумент flags равен нулю, то запись в сокет (и, соответственно,считывание) происходит в порядке поступления байтов. Если значение flags естьMSG_OOB, то записываемые данные передаются потребителю вне очереди.Функция возвращает число записанных в сокет байтов (в нормальном случае должнобыть равно значению параметра len) или −1 в случае ошибки. Отметим, что запись всокет не означает, что данные приняты на другом конце соединения процессомпотребителем. Для этого процесс-потребитель должен выполнить функцию recv (см.ниже).
Таким образом, функции чтения и записи в сокет выполняются асинхронно.2.1.7.Функция recvФункция служит для чтения данных из сокета.int recv(int s, void * buf, int len, int flags);Первый аргумент — сокет-дескриптор, из которого читаются данные. Второй и третийаргументы — соответственно, адрес и длина буфера для записи читаемых данных.Четвертый параметр — это комбинация битовых флагов, управляющих режимамичтения. Если аргумент flags равен нулю, то считанные данные удаляются из сокета.Если значение flags есть MSG_PEEK, то данные не удаляются и могут быть считаныпоследующим вызовом (или вызовами) recv.5Волкова И.А., Головин И.Г., Кузина Л.Н., Мальковский М.Г.Функция возвращает число считанных байтов или −1 в случае ошибки.
Следуетотметить, что нулевое значение не является ошибкой. Оно сигнализирует об отсутствиизаписанных в сокет процессом-поставщиком данных.2.1.8.Функция shutdownЭта функция используется для немедленного закрытия всех или части связей на сокет.int shutdown(int s, int how);Первый аргумент функции — сокет-дескриптор, который должен быть закрыт. Второйаргумент — целое значение, указывающее, каким образом закрывается сокет, а именно:RD— сокет закрывается для чтения;WR— сокет закрывается для записи;RDWR— сокет закрывается для чтения и для записи.2.1.9.Функция closeЭта функция закрывает сокет и разрывает все соединения с этим сокетом.
В отличие отфункции shutdown функция close может дожидаться окончания всех операций с сокетом,обеспечивая «нормальное», а не аварийное закрытие соединений.int close (int s);Аргумент функции — закрываемый сокет-дескриптор.Ниже приводятся примеры программ, демонстрирующих использование описанныхвыше функций.2.2. Пример-оболочка программы «Клиент»#include <sys/types.h>#include <sys/socket.h>#include <sys/un.h>#include <stdio.h>#define ADDRESS “mysocket” // адрес для связиvoid main (){char c;int i, s, len;FILE *fp;struct sockaddr_un sa;// получаем свой сокет-дескриптор:if ((s = socket (AF_UNIX, SOCK_STREAM, 0)) < 0){perror (“client: socket”);exit (1);}// создаем адрес, по которому будем связываться с сервером:sa.sun_family = AF_UNIX;strcpy (sa.sun_path, ADDRESS);// пытаемся связаться с сервером:len = sizeof ( sa.sun_family) + strlen ( sa.sun_path);6Модельный SQL-интерпретатор.
Методическое пособие.if ( connect ( s, (struct sockaddr *)&sa, len) < 0 ){perror (“client: connect”);exit (1);}/*--------------------------------------------- */// читаем сообщения сервера, пишем серверу:fp = fdopen (s, “r”);c = fgetc (fp);/* ............................ */send (s, “client”, 7, 0);/* ............................ */close (s);exit (0);}2.3. Пример-оболочка программы «Сервер»#include <sys/types.h>#include <sys/socket.h>#include <sys/un.h>#include <stdio.h>#define ADDRESS “mysocket” // адрес для связиvoid main (){char c;inti, d, d1, len, ca_len;FILE * fp;struct sockaddr_un sa, ca;// получаем свой сокет-дескриптор:if((d = socket (AF_UNIX, SOCK_STREAM, 0)) < 0) {perror (“client: socket”);exit (1);}// создаем адрес, c которым будут связываться клиентыsa.sun_family = AF_UNIX;strcpy (sa.sun_path, ADDRESS);// связываем адрес с сокетом;// уничтожаем файл с именем ADDRESS, если он существует,// для того, чтобы вызов bind завершился успешноunlink (ADDRESS);len = sizeof ( sa.sun_family) + strlen (sa.sun_path);if ( bind ( d, (struct sockaddr *)&sa, len) < 0 ) {perror (“server: bind”);exit (1);}// слушаем запросы на сокетif ( listen ( d, 5) < 0 ) {perror (“server: listen”);exit (1);7Волкова И.А., Головин И.Г., Кузина Л.Н., Мальковский М.Г.}// связываемся с клиентом через неименованный сокет с дескриптором d1:ca_len = sizeof ca;if (( d1 = accept ( d, (struct sockaddr *)&ca, &ca_len)) < 0 ) {perror (“server: accept”);exit (1);}/* ------------------------------------------ */// читаем запросы клиента, пишем клиенту:fp = fdopen (d1, “r”);c = fgetc (fp);/* ................................