Очереди сообщений.

#define MAXBUF 100
#define PERM 0666

// Структура для передачи сообщений
typedef struct msgbuf{
// тип сообщения для чтения или записи
   long type;       
// для содержания сообщения
   char buf[MAXBUF]; 
// могут быть и еще другие поля
}Message;

#include <stdio.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <stdlib.h>
#include <sys/msg.h>
#include "mes.h"

int main(){
// сообщение
  Message privet;
// ключ для создания системного ресурса
  key_t key; 
// дескриптор очереди сообщений
  int mesid; 

  int lng,n;
// получение ключа 
// нужно имя заведомо существующего файла
// и символ
  if ((key = ftok( "server", 'A' ) ) < 0 ){
     printf("Can't get key\n");
     exit(1);
  }
// для записи сообщения, его тип 
//указывается в структуре
// будем читать и писать тип 1
  privet.type=1L;

// создание очереди сообщений
  if( ( mesid = msgget(key, PERM|IPC_CREAT ) ) < 0 ){
    printf("Can't create message's queue\n");
    exit(1);
  }
// чтение из очереди сообщений
// если сообщений в очереди нет, программа в ожидании
// сообщение должен послать клиент
  n = msgrcv( mesid, &privet, sizeof(Message), privet.type, 0);
// для печати - 0 в конце
  privet.buf[n]='\0';

// n - количество прочитанных байт
// если что-то прочитали, то печать 
  if ( n > 0 ){
   printf("Privet: %s poluchen ot %ld\n", privet.buf, privet.type);

// Подготовка нового сообщения для отправки    
  lng = sprintf(privet.buf, "Thank's\n");

// отправка сообщения 
     if ( msgsnd( mesid, (void*)&privet, lng, 0) < 0 ){
       printf("Can't write message\n");
       exit(1);
     }
  }else{
    printf("The message is not valid\n");
    exit(1);
 }

 return 0;
}

#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/msg.h>
#include <stdio.h>
#include <stdlib.h>

#include "mes.h"

int main(){
  Message privet;
  int key;
  int mesid; 
  int lng,n;

  if ( ( key = ftok("server", 'A' ) ) < 0 ){
    printf("Can't get key\n");
    exit(1);
  }
// Очередь уже создана, получаем 
// дескриптор
  if( ( mesid = msgget( key, 0 ) ) < 0 ){
    printf("Can't get message's queue\n");
    exit(1);
  }

// Создаем сообщение для посылки 
  privet.type = 1L;
 lng = sprintf(privet.buf, "Q-ku");

// отсылаем сообщение (сервер его ждет)
  if ( msgsnd( mesid, (void*)&privet, lng, 0) < 0 ){
    printf("Can't write message\n");
    exit(1);
 }
 char c;
 c = getchar();
// Удалаем очередь сообщений когда не нужна
// сервер может и не успеть прочитать сообщение
 if( msgctl( mesid, IPC_RMID, 0 ) < 0 ){
   printf("Can't delete queue\n");
   exit(1);
 }
return 0;
}

#include <stdio.h>
#include <sys/types.h>
#include <unistd.h>
#include <sys/ipc.h>
#include <stdlib.h>
#include <sys/msg.h>
#include <time.h>
#include <errno.h>
#include <string.h>

#include <iostream>
#include <cstdlib>
#include <fstream>

#define PERM 0666

using namespace std;

class Sender{
// внутренняя структура для сообщений
   struct Mess{
      long long type;// тип сообщения
// само сообщение
        char buf[100];
// Дополнительные поля: 
      int len; // размер сообщения в байтах
// pid процесса, посылавшего сообщение
        int pid; 
   };
// сообщение
   Mess msg;
   int key; // ключ
// дескриптор очереди сообщений
   int mesid; 
// pid текущего процесса
   int pid;
   public:
// Конструктор для сервера
// Требуется имя файла и символ
      Sender(const char*, char);
// Конструктор для клиента. 
// Добавляется еще параметр для различия
      Sender(const char*, char, int);
// деструктор
      ~Sender();
// чтение с возвратом кода ошибки
// ms - тело сообщения, type - тип сообщения
      unsigned char read( void* ms, long long type);

// посылка с возвратом кода ошибки
// ms - тело сообщения, type - тип сообщения
// len - размер тела сообщения
      unsigned char send( void* ms, int len, long long type);
// удаление очереди сообщений
      void delQueue();
};

#include "sender.h"

int main(){
   int err;
   string buf;
   int len, queue = 0;
   cout << getpid() << endl;
   Sender snd("serv", 'A', 77);
   cout << "читаем..." << endl;
   err = snd.read( (void*) buf.c_str(), 1L);
   cout << "прочитали" << buf << endl;
// очередь удалять будет сервер
}

#include "sender.h"

int main(){
   string buf = "1";
   int err;
   int len, queue = 0;
   char m1;
   cout << getpid() << endl;
   Sender snd("serv",'A');
   err = snd.send((void*)buf.c_str(), sizeof(char), 1L);
   buf = "2";
   err = snd.send((void*)buf.c_str(), sizeof(char), 1L);
   while( buf != "*" ){
      cin >> buf;
  }
  snd.delQueue();
}