#include "WebSocketWithoutConnect.h"

Далі в головній функції main необхідно створити екземпляр даного класу, проініціалізувати буфер для відправки повідомлення та за допомогою вище створених екземплярів класів провести обмін повідомленнями.

#define _CRT_SECURE_NO_WARNINGS

#include <iostream>

#include "WebSocketWithoutConnect.h"

void init(char* sendBuf)

{

size_t count;

puts("Input text:");

_cgets_s(sendBuf, (size_t)256, (size_t*)(&count));

}

int main()

{

WebSocketWithoutConnect* wss_;

sockaddr_in sockAddr_;

SOCKET s_, ss_;

char sendBuf[1024];

init(sendBuf);

wss_ = new WebSocketWithoutConnect(sockAddr_, ss_, 5002, 'C');

wss_->sendMessage(sendBuf);

}



2.3 Програма B

Згідно із поставленим завданням, програмна В повинна містити засобми для передачі повідомлень за допомогою іменованого каналу. Повідомлення для відправки зчитується з клавіатури. Отримане повідомлення виводиться у файл. Для більшої зручності розіб'ємо код програми на модулі, які будемо використовувати під час виконання поставленого завдання.

В головному .срр файлі програми підключаються необхідні файли, .h, в яких описані необхідні класи. Також необхідно реалізувати даний клас. Лістинг даних класів наведено в додатку А. При створенні програми B, ми будемо використовувати клас NamedPipe. Необхідно підключити їх використовуючи наступний код:

#include "NamedPipe.h"

Далі в головній функції main необхідно створити екземпляри даних класів, проініціалізувати буфер для відправки повідомлення та за допомогою вище створених екземплярів класів провести обмін повідомленнями.

#include <iostream>

#include "NamedPipe.h"

int main()

{

HANDLE h_;

NamedPipe* namedPipe_;

wchar_t namePipeName[] = L"\\\\.\\Pipe\\pipeEB1";

char receiveBuf[1024];

namedPipe_ = new NamedPipe(namePipeName, h_, 'E');

namedPipe_->receiveMessage(receiveBuf);

FILE* f;

fopen_s(&f, "FromE.txt", "w");

fputs(receiveBuf, f);

fclose(f);

}

2.4 Програма C

Згідно із поставленим завданням, програмна С повинна містити засоби для передачі даних через сокети без та з встановленням зв'язку, а також засобми для передачі повідомлень за допомогою поштової скриньки. Повідомлення для відправки вводиться із клавіатури(перша частина), та зчитується з файлу. Отримане повідомлення виводиться на екран. Для більшої зручності розіб'ємо код програми на модулі, які будемо використовувати під час виконання поставленого завдання.

В головному .срр файлі програми підключаються необхідні файли, .h, в яких описані необхідні класи. Також необхідно реалізувати дані класи. Лістинг даних класів наведено в додатку А. При створенні програми C, ми будемо використовувати класи SocketWithoutConnect, SocketWithConnection i MailSlot. Необхідно підключити їх використовуючи наступний код:

#include "MailSlot.h"

#include "WebSocketWithoutConnect.h"

#include "WebSocketWithConnection.h"

Далі в головній функції main необхідно створити екземпляри даних класів, проініціалізувати буфер для відправки повідомлення та за допомогою вище створених екземплярів класів провести обмін повідомленнями.

#define _CRT_SECURE_NO_WARNINGS

#include <iostream>

#include "MailSlot.h"

#include "WebSocketWithoutConnect.h"

#include "WebSocketWithConnection.h"

void init(char* buf)

{

puts("Input the message:");

gets_s(buf, 126);

FILE* f;

fopen_s(&f, "FromC.txt", "r");

char buf1[126];

fgets(buf1, 126, f);

fclose(f);

strcat(buf, " ");

strcat(buf, buf1);

puts("Message for send:");

puts(buf);

}

int main()

{

HANDLE h_, m_;

MailSlot* mailSlot_;

wchar_t nameMailSlot[] = L"\\\\.\\Mailslot\\Mailslot";

WebSocketWithoutConnect* ws_;

WebSocketWithConnection* wss_;

sockaddr_in sockAddr_, wssSockAddr_;

SOCKET s_, ss_;

char sendBuf[1024];

char receiveBuf[1024];

init(sendBuf);

mailSlot_ = new MailSlot(nameMailSlot, m_, 'D');

mailSlot_->receiveMessage(receiveBuf);

std::cout << "Received Message:" << receiveBuf;

ws_ = new WebSocketWithoutConnect(sockAddr_, s_, 5002, 'A');

ws_->receiveMessage(sendBuf);

wss_ = new WebSocketWithConnection(wssSockAddr_, ss_, 5001, 'E');

wss_->receiveMessage(sendBuf);

}

2.5 Програма D

Згідно із поставленим завданням, програмна Д повинна містити засоби для передачі даних за допомогою поштової скриньки. Повідомлення для відправки зчитується з двох файлів. Отримане повідомлення виводиться на екран. Для більшої зручності розіб'ємо код програми на модулі, які будемо використовувати під час виконання поставленого завдання.

В головному .срр файлі програми підключаються необхідні файли, .h, в яких описані необхідні класи. Також необхідно реалізувати дані класи. Лістинг даних класів наведено в додатку А. При створенні програми D, ми будемо використовувати клас MailSlot. Необхідно підключити їх використовуючи наступний код:

#include "MailSlot.h"

Далі в головній функції main необхідно створити екземпляри даних класів, проініціалізувати буфер для відправки повідомлення та за допомогою вище створених екземплярів класів провести обмін повідомленнями.

#include <iostream>

#include "MailSlot.h"

void init(char* sendbuf) {

FILE* f;

char* buf1 = new char[512];

fopen_s(&f, "FromD1.txt", "r");

fgets(sendbuf, 127, f);

fclose(f);

fopen_s(&f, "FromD2.txt", "r");

fgets(buf1, 512, f);

fclose(f);

strcat(sendbuf, buf1);

delete[]buf1;

}

int main()

{

HANDLE h_, m_;

MailSlot* mailSlot_;

wchar_t nameMailSlot[] = L"\\\\.\\Mailslot\\Mailslot";

char sendBuf[1024];

char receiveBuf[1024];

init(sendBuf);

mailSlot_ = new MailSlot(nameMailSlot, m_, 'C');

mailSlot_->sendMessage(sendBuf);

}

2.6 Програма Е

Згідно із поставленим завданням, програмна Е повинна містити засоби для передачі даних через іменований канал та сокет зі встановленням зв'язку. Повідомлення для відправки зчитується з клавіатури. Отримане повідомлення виводиться у файл. Для більшої зручності розіб'ємо код програми на модулі, які будемо використовувати під час виконання поставленого завдання.

В головному .срр файлі програми підключаються необхідні файли, .h, в яких описані необхідні класи. Також необхідно реалізувати даний клас. Лістинг даних класів наведено в додатку А. При створенні програми E, ми будемо використовувати клас NamedPipe і SocketWithConnecion. Необхідно підключити його використовуючи наступний код:

#include " NamedPipe.h"

#include "SocketWithConnection.h"

Далі в головній функції main необхідно створити екземпляри даних класів, проініціалізувати буфер для відправки повідомлення та за допомогою вище створених екземплярів класів провести обмін повідомленнями.

#include <iostream>

#include "NamedPipe.h"

#include "WebSocketWithConnection.h"

void init(char* sendBuf)

{

char buf1[512];

size_t count;

FILE* f;

fopen_s(&f, "FromE.txt", "r");

fgets(sendBuf, 512, f);

fclose(f);

puts("Input text:");

_cgets_s(buf1, (size_t)512, (size_t*)(&count));

strcat(sendBuf, buf1);

puts("Message for send:");

}

int main()

{

HANDLE m_;

wchar_t name[] = L"\\\\.\\Pipe\\pipeEB1";

WebSocketWithConnection* wss_;

NamedPipe* nP_;

sockaddr_in sockAddr_, wssSockAddr_;

SOCKET ss_;

char sendBuf[1024];

char receiveBuf[1024];

init(sendBuf);

nP_ = new NamedPipe(name, m_, 'B');

nP_->sendMessage(sendBuf);

wss_ = new WebSocketWithConnection(wssSockAddr_, ss_, 5001, 'A');

wss_->sendMessage(sendBuf);

}



3. РОЗРОБКА ТА ВИКОНАННЯ ТЕСТОВОГО ПРИКЛАДУ

Даний програмний комплекс повинен бути реалізований для використання на операційній системі сімейства Windows. Тому інструментом для створення даного комплексу буде програмний додаток Microsoft Visual Studio 2010 (рис. 3.1), який спеціалізується на створенні програм для операційних систем Windows.

Рисунок 3.1 Середовище програмування Visual Studio 2017

Для зручності розробки та тестування програм, необхідно створити пустий проект Visual C++ та дати йому назву. Після цього створимо ще чотири проекти консольних додатків С++, що будуть відповідати кожній з програм, що використовуються в комплексі (рис. 3.2).

Рисунок 3.2 Вигляд пустого проекту



Кожен проект повинен мати назву, що відповідає його задачі. Після створення проектів здійснюється написання коду. Далі цей код буде компілюватись, і у разі успішної процедури компіляції створюється програма, яка буде готова до роботи. Загальний вигляд проектів програмного комплексу представлено на рисунку 3.3.

Рисунок 3.3 Вигляд програми

Зовнішній вигляд запущених програм представлений на рисунках 3.4 - 3.8.

Рисунок 3.4 Зовнішній вигляд програми A



Рисунок 3.5 Зовнішній вигляд програми D

Рисунок 3.6 Зовнішній вигляд програми E

Рисунок 3.7 Зовнішній вигляд програми C



Рисунок 3.8 Зовнішній вигляд програми B



4. ІНСТРУКЦІЯ КОРИСТУВАЧА

Для роботи з даним програмним комплексом комп'ютер користувача повинен мати такі параметри:

– процесор Pentium-IV 1.0 GHz і вище

– версія операційної системи: Windows 7 і вище

– об'єм оперативної пам'яті: 1 Gb і вище

– монітор з розширенням екрану не менше 1024х800 та передачею кольорів в 32 біт

– об'єм відеопам'яті: не менше 256 Mb

Користувачу доступно п'ять програм. Вони мають такі ж назви, що й назви хостів. Для правильної роботи ці програми повинні знаходитись на одному персональному комп'ютері. Програми запускаються почергово одна за іншою, як вказано на схемі в технічному завданні. Кожна з програм містить підказки для користувача, яким потрібно слідувати для успішного виконання всіх програм.



ВИСНОВКИ

У результаті виконання курсової роботи було спроектовано та розроблено програмний комплекс, що здійснює передачу даних між різними персональними комп'ютерами. Кожна програма комплексу виконує ті задачі, які вимагались індивідуальним завданням.

Під час розробки програмного забезпечення були отримані навички зі створення програм для роботи у мережі Windows на основі потокового та дайтаграмного передавання інформації з використанням поштових скриньок, іменованих каналів та сокетів з використанням синхрон¬ного і асинхронного режимів роботи функцій.

Це дозволило зрозуміти інформаційну структуру протоколів обміну даними, аспекти клієнт-серверної організації програмного забезпечення, основи організації комп'ютерних мереж, аспекти обмеження доступу до ресурсів, аспекти програмування файлів і потоків, аспекти роботи поштових скриньок, аспекти роботи іменованих каналів, принципи організації обміну даними за допомогою інтерфейсу прикладного програмування Winsock, аспекти використання адрес комп'ютерів та портів, види встановлення з'єднань між комп'ютерами та відповідні протоколи, технологію введення-виведення інформації у Winsock, мовні засоби, що застосовуються при створенні прикладних програм для роботи у мережах, переваги та недоліки технологій прикладного програмування у мережах.

Після завершення розробки програмного комплексу було проведено тестування даного комплексу, що дозволило виявити та усунути помилки у розробці та впевнетись у правильності роботи програм.



СПИСОК ВИКОРИСТАНИХ ДЖЕРЕЛ

1. Прикладне програмування у комп'ютерних мережах: навчальний посібник / О. Д. Азаров, О. І. Черняк, Л. А. Савицька - Вінниця : ВНТУ, 2016. - 130 с.

2. Олифер Виктор Григорьевич. Компьютерные сети. Принципы, технологии, протоколы: Учебник для вузов. 4-е изд. / В. Г. Олифер, Н. А. Олифер. - СПб.: Питер, 2010. - 944 с. - ISBN 978-5-49807-389-7.

3. Таненбаум Э. Компьютерные сети. 5-е изд. / Э. Таненбаум. - СПб.: Питер, 2012. - 992 с. - ISBN 978-5-459-00342-0

4. Трегубенко, І. Б. Сучасні технології програмування в мережах [Електронний ресурс] / І. Б. Трегубенко, Г. Т. Олійник, О. М. Панаско. - 2-е вид.. - Черкаси : ЧДТУ, 2010. - 175 с.

5. Харт Джонсон М. Системное программирование в среде Windows, 3-е издание. : Пер. с англ. - М. : Издательский дом «Вильямс», 2005. - 592 с. : ил. - Парал. тит. англ.

6. Сучкова, Л.И. Win32 API: основы программирования: учебное пособие/ Л.И. Сучкова; АлтГТУ им. ИИ. Ползунова. -Барнаул, АлтГТУ, 2010. - 138 с, ил.

7. Саймонд Ричард Microsoft Windows API. Справочник системного администратора. Второе издание, дополненное : Пер. с англ./Ричард Саймон - К.: ООО «ТИД «ДС», 2004. - 1216 с.

8. Гальченко В.Г. Лабораторный практикум. Системное программирование в среде WIN32. Создание Windows приложений. Учебное пособие / В.Г.Гальченко. - Томск: Изд. ТПУ, 2009.- 68 с.

9. Давидов В. Visual C++. Разработка Windows-приложений с помощью MFC i API-функций / В. Давидов - Санкт-Петербург: «БХВ-Петербург», 2008. - 576 с.

10. Джонс Э. Программирование в сетях Microsoft Windows. Мастер-класс. / Э. Джонс, Дж. Оланд ; пер. с англ. - Спб. : Питер; М. - 608 с. : ил.



ДОДАТОК

Вихідний код програмного комплексу

Вихідний код програмного комплексу

MailSlot

#include "MailSlot.h"

MailSlot::MailSlot(

wchar_t* _mailSlotName,

HANDLE& _MailSlot,

char _name) :

programName_(_name),

MailSlot_(_MailSlot),

count_(0),

wMailSlotString_(_mailSlotName),

MailSlotString_(wMailSlotString_.begin(), wMailSlotString_.end())

{

}

MailSlot::~MailSlot()

{

}

void MailSlot::sendMessage(char sendBuf[]) const

{

std::cout<<"\nClient of mailslot for sending message to " << programName_;

std::cout << "\nWait when " << programName_ <<" creates server of mailslot...";

do

{

MailSlot_ = CreateFile(MailSlotString_.c_str(), GENERIC_READ | GENERIC_WRITE, FILE_SHARE_READ | FILE_SHARE_WRITE, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);

Sleep(100);

} while (MailSlot_ == INVALID_HANDLE_VALUE);

int kilk = NULL;

std::cout << "\nPress any key for sending message to " << programName_;

_getch();

WriteFile(MailSlot_, sendBuf, strlen(sendBuf), (LPDWORD)&kilk, NULL);

std::cout << "\nMessage was sended to " << programName_;

CloseHandle(MailSlot_);

}

void MailSlot::receiveMessage(char *receiveBuf) const

{

std::cout << "\nServer of mailslot for received message from " << programName_;

HANDLE mailslotBForC;

mailslotBForC = CreateMailslot(MailSlotString_.c_str(), 1024, MAILSLOT_WAIT_FOREVER, NULL);

std::cout << "\nWait for receive message from " << programName_;

while (!ReadFile(mailslotBForC, receiveBuf, 1024, (LPDWORD)&count_, NULL))

Sleep(100);

receiveBuf[count_] = 0;

CloseHandle(mailslotBForC);

}

NamedPipe

#include "NamedPipe.h"

NamedPipe::NamedPipe(

wchar_t* _namedPipeName,

HANDLE& _namedPipe,

char _name) :

programName_(_name),

namedPipe_(_namedPipe),

count_(0),

wNamedPipeString_(_namedPipeName),

namedPipeString_(wNamedPipeString_.begin(), wNamedPipeString_.end())

{

}

NamedPipe::~NamedPipe()

{

}

void NamedPipe::sendMessage(char sendBuffer_[]) const

{

std::cout << "\nServer of named pipe for sending message to " << programName_;

std::cout << "\nWait when " << programName_ << " connects...";

namedPipe_ = CreateNamedPipe(namedPipeString_.c_str(), PIPE_ACCESS_OUTBOUND, PIPE_TYPE_BYTE, 1, 256, 0, 1000, NULL);

while (namedPipe_ != INVALID_HANDLE_VALUE)

{

if (ConnectNamedPipe(namedPipe_, NULL) != FALSE) // wait for someone to connect to the pipe

{

puts("\nConnected.");

break;

}

}

std::cout << "\nPress any key for send message to " << programName_;

_getch();

WriteFile(namedPipe_, sendBuffer_, 1024, (LPDWORD)&count_, NULL);

puts("\nMessage was sended to " + programName_);

DisconnectNamedPipe(namedPipe_);

CloseHandle(namedPipe_);

}

void NamedPipe::receiveMessage(char* outStr) const

{

std::cout << "\nClient of named pipe for receiving message from " << programName_;

std::cout << "\nWait for creating server of named pipe P1 on " << programName_ << "...";

while (!WaitNamedPipe(namedPipeString_.c_str(), NMPWAIT_WAIT_FOREVER))

Sleep(100);

if (namedPipe_ != INVALID_HANDLE_VALUE)

{

namedPipe_ = CreateFile(namedPipeString_.c_str(), GENERIC_READ, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);

puts("\nConnected.");

}

puts("\nWait for receive message...");

ReadFile(namedPipe_, outStr, 1024, (LPDWORD)&count_, NULL);

outStr[count_] = 0;

CloseHandle(namedPipe_);

}

Socket With Connection

#include "WebSocketWithConnection.h"

WebSocketWithConnection::WebSocketWithConnection(

sockaddr_in& _sockaddress,

SOCKET& _socket,

unsigned short _port,

char _name) :

programName_(_name),

port_(_port),

socket_(_socket),

sockaddress_(_sockaddress)

{

}

WebSocketWithConnection::~WebSocketWithConnection()

{

}

void WebSocketWithConnection::sendMessage(char sendBuf[]) const

{

int result_;

WSADATA wsaData_;

result_ = WSAStartup(0x0202, &wsaData_);

if (result_ != NO_ERROR)

{

wprintf(L"WSAStartup failed with error: %d\n", result_);

}

socket_ = socket(AF_INET, SOCK_DGRAM, 0);

sockaddress_.sin_family = AF_INET;

sockaddress_.sin_port = htons(port_);

long adr1;

inet_pton(AF_INET, "127.0.0.1", &adr1);

sockaddress_.sin_addr.S_un.S_addr = adr1;

std::cout << "\nClient of sockets with connection for sending message to " << programName_;

socket_ = socket(AF_INET, SOCK_STREAM, 0);

if (socket_ == INVALID_SOCKET)

{

wprintf(L"socket failed with error: %ld\n", WSAGetLastError());

WSACleanup();

}

std::cout << "\nWait for connecting to " << programName_ << "....";

while (connect(socket_, (sockaddr*)&sockaddress_, sizeof(sockaddress_)) == SOCKET_ERROR)

Sleep(100);

std::cout << "\nConnected to " << programName_;

std::cout << "\nPress any key for send message to " << programName_;

_getch();

send(socket_, sendBuf, strlen(sendBuf), 0);

std::cout << "\nMessage was sended to " << programName_;

closesocket(socket_);

}

void WebSocketWithConnection::receiveMessage(char* receiveBuf) const

{

std::cout << "\nServer of socket with connection for receiving message from " << programName_;

WSADATA WsaData;

SOCKET localSock;

sockaddr_in localAddr;

int count;

int res = WSAStartup(0x0202, &WsaData);

if (res != NO_ERROR)

{

wprintf(L"WSAStartup failed with error: %d\n", res);

}

localSock = socket(AF_INET, SOCK_STREAM, 0);

localAddr.sin_family = AF_INET;

localAddr.sin_port = htons(port_);

localAddr.sin_addr.S_un.S_addr = htonl(INADDR_ANY);

bind(localSock, (sockaddr*)&localAddr, sizeof(localAddr));

sockaddress_.sin_family = AF_INET;

sockaddress_.sin_port = htons(port_);

sockaddress_.sin_addr.S_un.S_addr = htonl(INADDR_LOOPBACK);

listen(localSock, 8);

int addrLen = sizeof(sockaddress_);

puts("\nWait for accept...");

std::cout << "\nWait for accept " << programName_ << ".....";

socket_ = accept(localSock, (sockaddr*)&sockaddress_, &addrLen);

std::cout << "\nAccepted " << programName_ << ".";

std::cout << "\nWait for receive message from " << programName_ << ".....";

count = recv(socket_, receiveBuf, 1024, 0);

receiveBuf[count] = 0;

std::cout << "\nMessage from " << programName_ << " was received!";

shutdown(socket_, SD_BOTH);

closesocket(socket_);

}

Socket Without Connection

#include "WebSocketWithoutConnect.h"

WebSocketWithoutConnect::WebSocketWithoutConnect(

sockaddr_in& _sockaddress,

SOCKET& _socket,

unsigned short _port,

char _name) :

programName_(_name),

port_(_port),

socket_(_socket),

sockaddress_(_sockaddress)

{

}

WebSocketWithoutConnect::~WebSocketWithoutConnect()

{

}

void WebSocketWithoutConnect::sendMessage(char sendBuf[]) const

{

int result_;

std::cout << "\nSocket without connection for sending message to " << programName_;

WSADATA wsaData_;

result_ = WSAStartup(0x0202, &wsaData_);

if (result_ != NO_ERROR)

{

wprintf(L"WSAStartup failed with error: %d\n", result_);

}

socket_ = socket(AF_INET, SOCK_DGRAM, 0);

if (socket_ == INVALID_SOCKET) {

wprintf(L"socket failed with error: %ld\n", WSAGetLastError());

WSACleanup();

}

sockaddress_.sin_family = AF_INET;

sockaddress_.sin_port = htons(port_);

long adr1;

inet_pton(AF_INET, "127.0.0.1", &adr1);

sockaddress_.sin_addr.S_un.S_addr = adr1;

std::cout << "\nIf " << programName_ << " is waiting for receiving, press any key for send message";

_getch();

result_ = sendto(socket_, sendBuf, strlen(sendBuf), 0, (sockaddr*)&sockaddress_, sizeof(sockaddress_));

if (result_ == SOCKET_ERROR) {

wprintf(L"sendto failed with error: %d\n", WSAGetLastError());

closesocket(socket_);

WSACleanup();

}

std::cout << "\nMessage was sended to " << programName_;

closesocket(socket_);

}

void WebSocketWithoutConnect::receiveMessage(char* receiveBuf) const

{

WSADATA wsaData;

int count;

int isrecive = WSAStartup(0x0202, &wsaData);

if (isrecive != NO_ERROR)

{

wprintf(L"WSAStartup failed with error: %d\n", isrecive);

}

std::cout << "\nSocket without connection for receive message from " << programName_;

sockaddress_.sin_port = htons(port_);

sockaddress_.sin_family = AF_INET;

sockaddress_.sin_addr.S_un.S_addr = htonl(INADDR_LOOPBACK);

socket_ = socket(AF_INET, SOCK_DGRAM, NULL);

if (socket_ == INVALID_SOCKET)

{

wprintf(L"socket failed with error: %ld\n", WSAGetLastError());

WSACleanup();

}

bind(socket_, (sockaddr*)&sockaddress_, sizeof(sockaddress_));

count = recv(socket_, receiveBuf, 1024, 0);

receiveBuf[count] = 0;

}

Програма А

#define _CRT_SECURE_NO_WARNINGS

#include <iostream>

#include "WebSocketWithoutConnect.h"

void init(char* sendBuf)

{

size_t count;

puts("Input text:");

_cgets_s(sendBuf, (size_t)256, (size_t*)(&count));

}

int main()

{

WebSocketWithoutConnect* wss_;

sockaddr_in sockAddr_;

SOCKET s_, ss_;

char sendBuf[1024];

init(sendBuf);

wss_ = new WebSocketWithoutConnect(sockAddr_, ss_, 5002, 'C');

wss_->sendMessage(sendBuf);

}

Програма В

#include <iostream>

#include "NamedPipe.h"

int main()

{

HANDLE h_;

NamedPipe* namedPipe_;

wchar_t namePipeName[] = L"\\\\.\\Pipe\\pipeEB1";

char receiveBuf[1024];

namedPipe_ = new NamedPipe(namePipeName, h_, 'E');

namedPipe_->receiveMessage(receiveBuf);

FILE* f;

fopen_s(&f, "FromE.txt", "w");

fputs(receiveBuf, f);

fclose(f);

}

Програма С

#define _CRT_SECURE_NO_WARNINGS

#include <iostream>

#include "MailSlot.h"

#include "WebSocketWithoutConnect.h"

void init(char* buf)

{

puts("Input the message:");

gets_s(buf, 512);

FILE* f;

fopen_s(&f, "FromC.txt", "r");

char buf1[512];

fgets(buf1, 512, f);

fclose(f);

strcat(buf, " ");

strcat(buf, buf1);

puts("Message for send:");

puts(buf);

}

int main()

{

HANDLE h_, m_;

MailSlot* mailSlot_;

wchar_t nameMailSlot[] = L"\\\\.\\Mailslot\\Mailslot";

WebSocketWithoutConnect* ws_;

sockaddr_in sockAddr_, wssSockAddr_;

SOCKET s_, ss_;

char sendBuf[1024];

char receiveBuf[1024];

init(sendBuf);

mailSlot_ = new MailSlot(nameMailSlot, m_, 'D');

mailSlot_->receiveMessage(receiveBuf);

std::cout << "Received Message:" << receiveBuf;

mailSlot_->sendMessage(sendBuf);

ws_ = new WebSocketWithoutConnect(sockAddr_, s_, 6100, 'E');

ws_->sendMessage(sendBuf);

ws_ = new WebSocketWithoutConnect(sockAddr_, s_, 6101, 'E');

ws_->receiveMessage(receiveBuf);

std::cout << "\nMessage Received: " << receiveBuf;

_getch();

}

Програма Д

#include <iostream>

#include "MailSlot.h"

void init(char* sendbuf) {

FILE* f;

char* buf1 = new char[512];

fopen_s(&f, "FromD1.txt", "r");

fgets(sendbuf, 127, f);

fclose(f);

fopen_s(&f, "FromD2.txt", "r");

fgets(buf1, 512, f);

fclose(f);

strcat(sendbuf, buf1);

delete[]buf1;

}

int main()

{

HANDLE h_, m_;

MailSlot* mailSlot_;

wchar_t nameMailSlot[] = L"\\\\.\\Mailslot\\Mailslot";

char sendBuf[1024];

char receiveBuf[1024];

init(sendBuf);

mailSlot_ = new MailSlot(nameMailSlot, m_, 'C');

mailSlot_->sendMessage(sendBuf);

}

Програма Е

#include <iostream>

#include "NamedPipe.h"

#include "WebSocketWithConnection.h"

void init(char* sendBuf)

{

char buf1[512];

size_t count;

FILE* f;

fopen_s(&f, "FromE.txt", "r");

fgets(sendBuf, 512, f);

fclose(f);

puts("Input text:");

_cgets_s(buf1, (size_t)512, (size_t*)(&count));

strcat(sendBuf, buf1);

puts("Message for send:");

}

int main()

{

HANDLE m_;

wchar_t name[] = L"\\\\.\\Pipe\\pipeEB1";

WebSocketWithConnection* wss_;

NamedPipe* nP_;

sockaddr_in sockAddr_, wssSockAddr_;

SOCKET ss_;

char sendBuf[1024];

char receiveBuf[1024];

init(sendBuf);

nP_ = new NamedPipe(name, m_, 'B');

nP_->sendMessage(sendBuf);

wss_ = new WebSocketWithConnection(wssSockAddr_, ss_, 5001, 'A');

wss_->sendMessage(sendBuf);

}

Размещено на Allbest.ru

...