// Server.cpp: Hauptprojektdatei.
#include "stdafx.h"
#include "mainForm.h"
using namespace Server;
using namespace System;
using namespace System::Diagnostics;
using namespace System::IO;
using namespace System::IO::Pipes;
void NamedPipeServerStream_WaitForConnectionThreadProcess(void);
[STAThreadAttribute]
int main(array<System::String ^> ^args)
{
bool processIsActive = false;
Process ^current = Process::GetCurrentProcess();
array<Process ^> ^processes = Process::GetProcessesByName(current->ProcessName);
for each (Process ^process in processes) {
if(process->Id != current->Id) {
if (Reflection::Assembly::GetExecutingAssembly()->Location->Replace("/", "\\") == current->MainModule->FileName) {
processIsActive = true;
}
}
}
Threading::Thread ^NamedPipeServerStream_WaitForConnection;
if(processIsActive == false) {
NamedPipeServerStream_WaitForConnection = gcnew Threading::Thread(gcnew Threading::ThreadStart(&NamedPipeServerStream_WaitForConnectionThreadProcess));
NamedPipeServerStream_WaitForConnection->Start();
// Aktivieren visueller Effekte von Windows XP, bevor Steuerelemente erstellt werden
Application::EnableVisualStyles();
Application::SetCompatibleTextRenderingDefault(false);
// Hauptfenster erstellen und ausführen
Application::Run(gcnew mainForm());
}
else {
System::Text::Decoder ^decoder = System::Text::Encoding::UTF8->GetDecoder();
array<Byte> ^bytes = gcnew array<Byte>(10);
array<Char> ^chars = gcnew array<Char>(10);
NamedPipeClientStream ^pipeStream = gcnew NamedPipeClientStream("messagepipe");
pipeStream->Connect();
pipeStream->ReadMode = PipeTransmissionMode::Message;
int numBytes;
do {
String ^message = "";
do {
numBytes = pipeStream->Read(bytes, 0, bytes->Length);
int numChars = decoder->GetChars(bytes, 0, numBytes, chars, 0);
message += gcnew String(chars, 0, numChars);
} while (!pipeStream->IsMessageComplete);
decoder->Reset();
//Console::WriteLine(message);
Microsoft::VisualBasic::Interaction::MsgBox(message,Microsoft::VisualBasic::MsgBoxStyle::OkOnly,"messagepipe");
} while (numBytes != 0);
}
NamedPipeServerStream_WaitForConnection->Abort();
return 0;
}
void NamedPipeServerStream_WaitForConnectionThreadProcess(void) {
System::Text::UTF8Encoding ^encoding = gcnew System::Text::UTF8Encoding();
String ^message1 = "Named Pipe Message Example.";
String ^message2 = "Another Named Pipe Message Example.";
array<Byte> ^bytes;
NamedPipeServerStream ^pipeStream = gcnew NamedPipeServerStream("messagepipe",PipeDirection::InOut,1,PipeTransmissionMode::Message,PipeOptions::None);
pipeStream->WaitForConnection();
// Let’s send two messages.
bytes = encoding->GetBytes(message1);
pipeStream->Write(bytes, 0, bytes->Length);
bytes = encoding->GetBytes(message2);
pipeStream->Write(bytes, 0, bytes->Length);
}
