Операционная система UNIX

Клиент создает сокет датаграмм и связывает его со своим уникальным адресом. Уникальность адреса определяется уникальностью имени файла. Поскольку одновременно могут работать несколько клиентов, возникает задача выполнения условия уникальности. Для этого мы используем функцию mktemp(3C), позволяющую по заданному шаблону /tmp/clnt.XXXX и на основании идентификатора текущего процесса получить уникальное имя, заменяя соответствующим образом символы 'X'. Связывание сокета позволяет при отправлении сообщения неявно указать его "адрес отправителя", так что серверу не составляет труда отправить сообщение обратно.

Клиент:

#include

#include

#include < sys/un.h>

char *msg = "Здравствуй, Мир!\n";

#define MAXBUF 256

char buf[MAXBUF];

main {

 struct sockaddr_un serv_addr, clnt_addr;

 int sockfd;

 int saddrlen, caddrlen, msglen, n;

 /* Установим адрес сервера, с которым мы будем обмениваться

    данными. Для этого заполним структуру данных sockaddr_un,

    которую будем использовать при отправлении данных серверу

    с помощью вызова sendto. Значение адреса известно

    по предварительной договоренности */

 bzero(&serv_addr, sizeof(serv_addr));

 serv_addr.sun_family = AF_UNIX;

 strcpy(serv_addr.sun_path, "./echo.server");

 saddrlen = sizeof(serv_addr.sun_family) +

 strlen(serv_addr.sun_path);

 /* Создадим сокет датаграмм */

 if ((sockfd = socket(AF_UNIX, SOCK_DGRAM, 0)) < 0) {

  printf("Невозможно создать сокет\n");

  exit(1);

 }

 /* Необходимо связать сокет с некоторым локальным адресом,

    чтобы сервер имел возможность возвратить посланное сообщение.

    Этот адрес должен быть уникальным в пределах коммуникационного

    домена - т.е. данной операционной системы. Для обеспечения

    этого условия, воспользуемся функцией mktemp(3C), которая

    возвращает уникальное имя, основанное на представленном

    шаблоне и идентификаторе нашего процесса PID */

 bzero(&clnt_addr, sizeof(clnt_addr));

 clnt_addr.sun_family = AF_UNIX;

 strcpy(clnt_addr.sun_path, "/tmp/clnt.XXXX");

 mktemp(clnt_addr.sun_path);

 caddrlen =

  sizeof(clnt addr.sun_family) + strlen(clnt_addr.sun_path);

 if (bind(sockfd, (struct sockaddr*)&clnt_addr,

  caddrlen) < 0) {

  printf("Ошибка связывания сокета\n");

  exit(1);

 }

 /* Итак, отправляем сакраментальное приветствие */

 msglen = strlen(msg);

 if (sendto(sockfd, msg, msglen, 0,

  (struct sockaddr*)&serv addr, saddrlen) != msglen) {

  printf("Ошибка передачи сообщения\n");

  exit(1);

 }

 /* Прочитаем эхо*/

 if ((n = recvfrom(sockfd, buf, MAXBUF, 0, NULL, 0)) < 0) {

  printf("Ошибка получения сообщения\n");

  exit(1);

 }

 /* И выведем его на экран */

 printf("Эхо: %s\n", buf);

 /* Уберем за собой */

 close(sockfd);

 unlink(clnt_addr.sun_path);

 exit(0);

}

Сравнение различных систем межпроцессного взаимодействия

Заканчивая разговор о межпроцессном взаимодействии в UNIX, приведем сводную сравнительную таблицу рассмотренных систем.