type TpipeData = packed record  //Имя можно изменить, а тип packed record оставьте

  pEvent:byte;

  ClientName: string[40];                 //Строка фиксированной длины обязательна

  Date:TdateTime;

End;

type

  TPipeThread = class(TThread)

  private

  PipeData:TPipeData;            //Переменная, описывающая сдруктуру данных канала

  Protected

    procedure Execute; override; //Здесь мы будем создавать канал и читать данные из него

  public

    procedure ShowData;          //Здесь будем передовать данные форме

    constructor Create(CreateSuspended: Boolean); reintroduce; overload; //Создание потока

  end;

procedure TPipeThread.Execute;

var

  hPipe: THandle; //Указатель на наш канал

  bytesRead: DWORD;  //Количество прочитанных байт

begin

   hPipe := CreateNamedPipe('\.\PIPE\OurPipe', //Наше имя

      PIPE_ACCESS_INBOUND,                      // сервер может только читать канал

      PIPE_WAIT or                              // Синхронная работа

      PIPE_READMODE_MESSAGE or                  // метод чтения - пакеты

      PIPE_TYPE_MESSAGE,

      PIPE_UNLIMITED_INSTANCES,                 // Бесконечно много клиентов

      SizeOf(Tpipedata),                        //размер буфера чтения

      SizeOf(Tpipedata),                        // размер буфера записи

      100,                                      // Тайм-аут

      nil);                                     // Артребуты безопасности.

    if hPipe = INVALID_HANDLE_VALUE then Exit;  //Если не удалось создать канал, то выходим

 

    while true do //Теперь читаем, пока не надоест!

    begin

     try

        ConnectNamedPipe(hPipe, nil);           //Подключаемся к каналу, второй параметр нужен только, если вместо PIPE_WAIT вы указали PIPE_NOWAIT

 

        //Далее читаем, параметры – указатель на канал, наш буфер, кол-во прочитанных байт, и последнее опять таки только для PIPE_NOWAIT.

        if ReadFile(hPipe, PipeData, SizeOf(TpipeData), bytesRead, nil) then

        Synchronize(ShowData);                 //Синхронизируемся с главным потоком

      finally

        DisconnectNamedPipe(hPipe);            //Закрываем канал, параметры – только указатель

      end;

     end;

end;

procedure TPipeThread.ShowData;

begin

Case PipeData.pEvent of

1:form1.Memo1.Lines.Add('======Событие 1======');

2:form1.Memo1.Lines.Add('=========Событие 2==========');

end;

form1.Memo1.Lines.Add('Программа '+PipeData.Clientname+' открыла канал');

form1.Memo1.Lines.Add(DateTostr(PipeData.Date));

form1.Memo1.Lines.Add('');

end;

procedure SendToServer; // Замечу, что должна быть переменная такого же типа TpipeData, как и у сервера. Допустим, это Data

var

  Data:TpipeData;

  hPipe: THandle;

  bytesWritten: DWORD;

begin

hPipe := CreateFile('\.\PIPE\OurPipe',    //Как видите, здесь мы подключаемся даже не к каналу, а к файлу

    GENERIC_WRITE,                         //Только запись

    FILE_SHARE_READ or                     // Обмениваемся чтенью\записью

    FILE_SHARE_WRITE,

    nil,                                   //Артрибуты безопасности

    OPEN_EXISTING,                         // Канал должен быть создан

    0, 0);

if hPipe = INVALID_HANDLE_VALUE then Exit; //Если произошла ошибка, выходим

 

Data.pEvent:=0;

Data.ClientName:='PipeClient';

Data.Date:=Time;                           //Функция Time записана в модуле SysUtils и возвращает текущее время

              

if WriteFile(hPipe, Data, SizeOf(TpipeData), bytesWritten,

    nil) then  DisconnectNamedPipe(hpipe); //Если удачно запиали, закрываем канал.

end;