Клиент-сервер на СИ++. Запись клиентом строки и её чтение с сервера

#include "stdafx.h"
#include <windows.h>
#include <iostream>
 
 
int _tmain(int argc, _TCHAR* argv[])
{
    HANDLE hslot;
 
    TCHAR slotname[35] = TEXT("\\\\.\\mailslot\\demoslot"); // Имя клиента
    hslot = CreateFile(slotname, GENERIC_WRITE, // Тип доступа - запись 
        FILE_SHARE_READ, // Разрешает последующие операции открытия объекта, которые требуют доступа для чтения.
        NULL, 
        OPEN_EXISTING, // Открывает файл. Функция завершается ошибкой, если файл не существует.
        0, // Атрибуты файла(архивирован, только для чтения, скрытый). У нас файл обычный 
        NULL);
    // Клиент выступает как файл
 
    if (hslot == INVALID_HANDLE_VALUE)
    {
        std::cout << "SLOT WRITING FAILED" << std::endl;
        std::cout << "PRESS KEY TO FINISH" << std::endl;
        std::cin.get();
        return 0;
    }
 
    std::cout << "SLOT IS WAITING" << std::endl;
    TCHAR just_write[20] = TEXT("Hello, server"); // Наше сообщение
    DWORD dwBytesWrite;
    if (!WriteFile(hslot, just_write, sizeof(just_write), &dwBytesWrite, NULL))
    {
        // Выводим в случае провала отправки сообщения
        std::cout << "WRITE FAILED" << std::endl;
        CloseHandle(hslot);
        std::cout << "PRESS KEY TO FINICH" << std::endl;
        std::cin.get();
        return 0;
    }
    // В случае успеха выводим то, что отправили
    std::wcout << "Data WRITTEN TO BOX: " << just_write << std::endl;
    std::cout << "PRESS KEY TO FINISH" << std::endl;
    CloseHandle(hslot);
    std::cin.get();
 
    return 0;
    return 0;
}

#include "stdafx.h"
#include <windows.h>
#include <iostream>
 
 
int _tmain(int argc, _TCHAR* argv[])
{
    HANDLE hslot;
    TCHAR slotname[35] = TEXT("\\\\.\\mailslot\\demoslot"); // Имя сервера
    hslot = CreateMailslot(slotname, 0, MAILSLOT_WAIT_FOREVER, NULL); // Создаём сервер
 
    // Аргументы функции CreateMailslot
    //1) slotname - Имя сервера
    //2) 0 - максимальный размер получаемого сообщения(если стоит ноль, то сообщение может быть любого размера)
    //3) MAILSLOT_WAIT_FOREVER - определяет количество времени ожидания сообщения. В нашем случае ждём ВЕЧНО
    //4) NULL - указываем, может ли наследоваться(у нас нет)
 
    if (hslot == INVALID_HANDLE_VALUE) // Если не получилось создать сервер
    {
        std::cout << "SLOT FAILED" << std::endl;
        std::cout << "PRESS KEY TO FINISH" << std::endl;
        std::cin.get();
        return 0; // Завершаем программу
    }
 
    std::cout << "SERVER SLOT IS WAITING" << std::endl; // Выводим сообщение о том, что сервер ждёт от нас ответа
    TCHAR message[] = TEXT("");
    DWORD dwBytesRead; // Сколько байтов прочитали
    // Производим чтение из файла
    if (!ReadFile(hslot, message, sizeof(message), &dwBytesRead, (LPOVERLAPPED)NULL))
    {
        std::cout << "READING SLOT FAILED" << std::endl;
        CloseHandle(hslot);
        std::cout << "PRESS KEY TO FINISH" << std::endl;
        std::cin.get();
        return 0;
    }
    std::wcout << "Data Read: " << message << std::endl;
    std::cout << "PRESS KEY TO FINISH" << std::endl;
    CloseHandle(hslot);
    std::cin.get();
 
    return 0;
    return 0;
}

#include    <windows.h>
#include    <iostream>
 
using namespace std;
 
HANDLE  hWatchThreadMailClient, hWatchThreadMailServer;
DWORD   dwThreadIDMailClient, dwThreadIDMailServer;
 
BOOL FAR PASCAL MailSlotServer(LPSTR lpData)
{
    HANDLE      hMailSlot;
    DWORD       cbMessage, cMessage, cbRead;
    BOOL        fResult;
    char        *pdata = NULL;
    LPCSTR      lpszSlotName = "\\\\.\\mailslot\\TestMailSlot";
 
    hMailSlot = CreateMailslotA(lpszSlotName,
        0,                                      // no maximum message size        
        MAILSLOT_WAIT_FOREVER,          // no time-out for read operations 
        (LPSECURITY_ATTRIBUTES)NULL);   // no security attributes 
 
    if (hMailSlot == INVALID_HANDLE_VALUE)
        return FALSE;
    else
    {
        // бесконечный цикл
        while (TRUE)
        {
            cMessage = cbMessage = cbRead = 0;
 
            fResult = GetMailslotInfo(hMailSlot,
                (LPDWORD)NULL,                      // no maximum message size
                &cbMessage,                             // size of next message
                &cMessage,                              // number of messages
                (LPDWORD)NULL);                     // no read time-out
 
            if (!fResult)
                break;                                  // выходим геть !
 
            if (cbMessage == MAILSLOT_NO_MESSAGE)// а нету ничего
                continue;
 
            pdata = new char[cbMessage];
 
            fResult = ReadFile(hMailSlot, pdata, cbMessage, &cbRead, (LPOVERLAPPED)NULL);
 
            if (!fResult)
            {
                delete[]pdata;
                break;                                  // выходим геть !
            }
 
            cout << "Server: " << pdata << endl;
            delete[]pdata;
        }
    }
    return FALSE;
} // end of MailSlotServer()
 
BOOL FAR PASCAL MailSlotClient(LPSTR lpData)
{
    BOOL        fResult;
    HANDLE      hFile;
    DWORD       cbWritten;
    const char  *pTest = "Test of MailSlot";
 
    hFile = CreateFileA("\\\\*\\mailslot\\TestMailSlot",
        GENERIC_WRITE,
        FILE_SHARE_READ,            // required to write to a mailslot
        (LPSECURITY_ATTRIBUTES)NULL,
        OPEN_EXISTING,
        FILE_ATTRIBUTE_NORMAL,
        (HANDLE)NULL);
 
    if (hFile == INVALID_HANDLE_VALUE)
        return FALSE;
    else
    {
        // бесконечный цикл
        while(TRUE)
        {
            cout << "Client: " << pTest << endl;
            fResult = WriteFile(hFile,
                pTest,
                strlen(pTest)+1,
                &cbWritten,
                (LPOVERLAPPED)NULL);
 
            if (!fResult)
            {
                CloseHandle(hFile);
                break;
            }
            Sleep(1000);
        }
    }
    return FALSE;
} // end of MailSlotClient()
 
int main()
{
    hWatchThreadMailClient = CreateThread((LPSECURITY_ATTRIBUTES)NULL, 0,
        (LPTHREAD_START_ROUTINE)MailSlotClient, 0, 0, &dwThreadIDMailClient);
 
    hWatchThreadMailServer = CreateThread((LPSECURITY_ATTRIBUTES)NULL, 0,
        (LPTHREAD_START_ROUTINE)MailSlotServer, 0, 0, &dwThreadIDMailServer);
 
    while (TRUE);
    return 0;
}